Fixed applySqlChanges and addForeignKeys to include options

Author: rathreya

lib/migration.js

@@ -161,7 +161,7 @@ function mixinMigration(PostgreSQL) {
       const action = actions.shift();
       const pendingChanges = action && action() || [];
       if (pendingChanges.length) {
-        self.applySqlChanges(model, pendingChanges, function (err, result) {
+        self.applySqlChanges(model, pendingChanges, options, function (err, result) {
           if (!err) {
             applyPending(actions, cb, err, result);
           } else {
@@ -201,7 +201,7 @@ function mixinMigration(PostgreSQL) {
             self.getModelDefinition(model).settings.foreignKeys,
             actualFks);
 
-          self.addForeignKeys(model, fkSQL, cb);
+          self.addForeignKeys(model, fkSQL, options, cb);
         },
       ], function (err, result) {
         cb(err, result[0]);
@@ -438,13 +438,15 @@ 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) {
@@ -456,7 +458,7 @@ function mixinMigration(PostgreSQL) {
               }
               const fkSQL = self.getForeignKeySQL(model,
                 self.getModelDefinition(model).settings.foreignKeys);
-              self.addForeignKeys(model, fkSQL, function (err, result) {
+              self.addForeignKeys(model, fkSQL, options, function (err, result) {
                 cb(err);
               });
             });
@@ -621,11 +623,17 @@ function mixinMigration(PostgreSQL) {
     }
   };
 
-  PostgreSQL.prototype.addForeignKeys = function (model, fkSQL, cb) {
+  PostgreSQL.prototype.addForeignKeys = function (model, fkSQL, options, cb) {
     const self = this;
 
+    if ((!cb) && typeof options === 'function') {
+      cb = options;
+      options = {};
+    }
+    options = options || {};
+
     if (fkSQL && fkSQL.length) {
-      self.applySqlChanges(model, [fkSQL.toString()], function (err, result) {
+      self.applySqlChanges(model, [fkSQL.toString()], options, function (err, result) {
         if (err) cb(err);
         else
           cb(null, result);

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@apexdesigner/loopback-connector-postgresql",
-  "version": "7.0.7",
+  "version": "7.0.8",
   "description": "Loopback PostgreSQL Connector",
   "keywords": [
     "LoopBack",