Added options input to methods in migration missing options input

Author: rathreya

lib/migration.js

@@ -17,14 +17,21 @@ function mixinMigration(PostgreSQL) {
     return !!(fields && indexes);
   };
 
-  PostgreSQL.prototype.showFields = function(model, cb) {
+  PostgreSQL.prototype.showFields = function(model, options, cb) {
+
+    if ((!cb) && typeof options === 'function') {
+      cb = options;
+      options = {};
+    }
+    options = options || {};
+
     const sql = 'SELECT column_name AS "column", data_type AS "type", ' +
     'datetime_precision AS time_precision, ' +
     'is_nullable AS "nullable", character_maximum_length as "length"' // , data_default AS "Default"'
     + ' FROM "information_schema"."columns" WHERE table_name=\'' +
     this.table(model) + '\' and table_schema=\'' +
     this.schema(model) + '\'';
-    this.execute(sql, function(err, fields) {
+    this.execute(sql, options, function(err, fields) {
       if (err) {
         return cb(err);
       } else {
@@ -36,7 +43,14 @@ function mixinMigration(PostgreSQL) {
     });
   };
 
-  PostgreSQL.prototype.showIndexes = function(model, cb) {
+  PostgreSQL.prototype.showIndexes = function(model, options, cb) {
+
+    if ((!cb) && typeof options === 'function') {
+      cb = options;
+      options = {};
+    }
+    options = options || {};
+
     const sql = 'SELECT t.relname AS "table", i.relname AS "name", ' +
           'am.amname AS "type", ix.indisprimary AS "primary", ' +
           'ix.indisunique AS "unique", ' +
@@ -56,7 +70,7 @@ function mixinMigration(PostgreSQL) {
           this.table(model) + '\'' +
           ' and (ns.oid = t.relnamespace and ns.nspname=\'' +
           this.schema(model) + '\')';
-    this.execute(sql, function(err, indexes) {
+    this.execute(sql, options, function(err, indexes) {
       if (err) {
         return cb(err);
       } else {
@@ -70,9 +84,17 @@ function mixinMigration(PostgreSQL) {
    * @param {String} model The model name
    * @param {Object[]} actualFields Actual columns in the table
    * @param {Object[]} actualIndexes Actual indexes in the table
+   * @param {Object} options Options object
    * @param {Function} [cb] The callback function
    */
-  PostgreSQL.prototype.alterTable = function(model, actualFields, actualIndexes, cb) {
+  PostgreSQL.prototype.alterTable = function (model, actualFields, actualIndexes, options, cb) {
+
+    if ((!cb) && typeof options === 'function') {
+      cb = options;
+      options = {};
+    }
+    options = options || {};
+
     const self = this;
     const m = this._models[model];
     const propNames = Object.keys(m.properties).filter(function(name) {
@@ -329,11 +351,18 @@ function mixinMigration(PostgreSQL) {
    * @param {String} model The model name
    * @param {Function} [cb] The callback function
    */
-  PostgreSQL.prototype.createTable = function(model, cb) {
+  PostgreSQL.prototype.createTable = function(model, options, cb) {
     const self = this;
     const name = self.tableEscaped(model);
     const modelDef = this.getModelDefinition(model);
 
+    if ((!cb) && typeof options === 'function') {
+      cb = options;
+      options = {};
+    }
+    options = options || {};
+
+
     // collects all extensions needed to be created
     let createExtensions;
     Object.keys(this.getModelDefinition(model).properties).forEach(function(propName) {
@@ -356,17 +385,19 @@ function mixinMigration(PostgreSQL) {
       createExtensions +
       'CREATE SCHEMA ' +
       self.escapeName(self.schema(model)),
+      options,
       function(err) {
         if (err && err.code !== '42P06') {
           return cb && cb(err);
         }
         self.execute('CREATE TABLE ' + name + ' (\n  ' +
           self.propertiesSQL(model) + '\n)',
+          options,
         function(err, info) {
           if (err) {
             return cb(err, info);
           }
-          self.addIndexes(model, undefined, function(err) {
+          self.addIndexes(model, undefined, options, function(err) {
             if (err) {
               return cb(err);
             }