Added: Options containing pre/post/success functions.

lib/migrator.js

@@ -166,17 +166,37 @@ module.exports = (function() {
       }
       }
     }).run()
     }).run()
   }
   }
-  
-  Migrator.prototype.execute = function(filename) {
+
+  /**
+   * Explicitly executes one or multiple migrations.
+   *
+   * @param filename {String|Array} Absolute filename(s) of the migrations script
+   * @param options  {Object}       Can contain three functions, before, after and success, which are executed before
+   *                                or after each migration respectively, with one parameter, the migration.
+   */
+  Migrator.prototype.exec = function(filename, options) {
 
 
     var self = this;
     var self = this;
     return new Utils.CustomEventEmitter(function(emitter) {
     return new Utils.CustomEventEmitter(function(emitter) {
       var chainer = new Utils.QueryChainer;
       var chainer = new Utils.QueryChainer;
       var addMigration = function(filename) {
       var addMigration = function(filename) {
-        self.options.logging('Adding migration script at ' + filename )
+        self.options.logging('Adding migration script at ' + filename)
         var migration = new Migration(self, filename)
         var migration = new Migration(self, filename)
         chainer.add(migration, 'execute', [{ method: 'up' }], {
         chainer.add(migration, 'execute', [{ method: 'up' }], {
+          before: function(migration) {
+            if (options && Utils._.isFunction(options.before)) {
+              options.before.call(self, migration);
+            }
+          },
+          after: function(migration) {
+            if (options && Utils._.isFunction(options.after)) {
+              options.after.call(self, migration);
+            }
+          },
           success: function(migration, callback) {
           success: function(migration, callback) {
+            if (options && Utils._.isFunction(options.success)) {
+              options.success.call(self, migration);
+            }
             callback();
             callback();
           }
           }
         })
         })