db-migrate-pg - npm Package Compare versions

Comparing version 1.2.1 to 1.2.2

index.js

@@ -8,3 +8,3 @@ var util = require('util');
 var PgDriver = Base.extend({
-  init: function(connection, schema, intern) {
+  init: function (connection, schema, intern) {
     this.log = intern.mod.log;
@@ -19,3 +19,3 @@ this.type = intern.mod.type;
 
-  startMigration: function(cb) {
+  startMigration: function (cb) {
     if (!this.internals.notransactions) {
@@ -26,3 +26,3 @@ return this.runSql('BEGIN;').nodeify(cb);
 
-  endMigration: function(cb) {
+  endMigration: function (cb) {
     if (!this.internals.notransactions) {
@@ -33,6 +33,6 @@ return this.runSql('COMMIT;').nodeify(cb);
 
-  createColumnDef: function(name, spec, options, tableName) {
+  createColumnDef: function (name, spec, options, tableName) {
     // add support for datatype timetz, timestamptz
     // https://www.postgresql.org/docs/9.5/static/datatype.html
-    spec.type = spec.type.replace(/^(time|timestamp)tz$/, function($, type) {
+    spec.type = spec.type.replace(/^(time|timestamp)tz$/, function ($, type) {
       spec.timezone = true;
@@ -61,3 +61,3 @@ return type;
 
-  _translateSpecialDefaultValues: function(
+  _translateSpecialDefaultValues: function (
     spec,
@@ -78,3 +78,3 @@ options,
 
-  mapDataType: function(str) {
+  mapDataType: function (str) {
     switch (str) {
@@ -94,3 +94,3 @@ case 'json':
 
-  createDatabase: function(dbName, options, callback) {
+  createDatabase: function (dbName, options, callback) {
     var spec = '';
@@ -106,3 +106,3 @@
 
-  dropDatabase: function(dbName, options, callback) {
+  dropDatabase: function (dbName, options, callback) {
     var ifExists = '';
@@ -121,3 +121,3 @@
 
-  createSequence: function(sqName, options, callback) {
+  createSequence: function (sqName, options, callback) {
     var spec = '';
@@ -137,3 +137,3 @@ var temp = '';
 
-  switchDatabase: function(options, callback) {
+  switchDatabase: function (options, callback) {
     if (typeof options === 'object') {
@@ -154,3 +154,3 @@ if (typeof options.database === 'string') {
 
-  dropSequence: function(dbName, options, callback) {
+  dropSequence: function (dbName, options, callback) {
     var ifExists = '';
@@ -173,3 +173,3 @@ var rule = '';
 
-  createMigrationsTable: function(callback) {
+  createMigrationsTable: function (callback) {
     var options = {
@@ -191,3 +191,3 @@ columns: {
       .then(
-        function(result) {
+        function (result) {
           if (result && result.length > 0 && result[0].server_version_num) {
@@ -209,5 +209,5 @@ var version = result[0].server_version_num;
         // not all DBs support server_version_num, fall back to server_version
-        function() {
+        function () {
           return this.all('show server_version').then(
-            function(result) {
+            function (result) {
               if (result && result.length > 0 && result[0].server_version) {
@@ -231,3 +231,3 @@ var version = result[0].server_version;
       .then(
-        function(result) {
+        function (result) {
           var searchPath;
@@ -257,3 +257,3 @@ var searchPathes = result[0].search_path.split(',');
       .then(
-        function() {
+        function () {
           return this.all(
@@ -268,3 +268,3 @@ "SELECT table_name FROM information_schema.tables WHERE table_name = '" +
       .then(
-        function(result) {
+        function (result) {
           if (result && result.length < 1) {
@@ -280,3 +280,3 @@ return this.createTable(this.internals.migrationTable, options);
 
-  createSeedsTable: function(callback) {
+  createSeedsTable: function (callback) {
     var options = {
@@ -298,3 +298,3 @@ columns: {
       .then(
-        function(result) {
+        function (result) {
           if (result && result.length > 0 && result[0].version) {
@@ -314,3 +314,3 @@ var version = result[0].version;
       .then(
-        function(result) {
+        function (result) {
           var searchPath;
@@ -331,3 +331,3 @@
       .then(
-        function() {
+        function () {
           return this.all(
@@ -342,3 +342,3 @@ "SELECT table_name FROM information_schema.tables WHERE table_name = '" +
       .then(
-        function(result) {
+        function (result) {
           if (result && result.length < 1) {
@@ -354,3 +354,3 @@ return this.createTable(this.internals.seedTable, options);
 
-  createColumnConstraint: function(spec, options, tableName, columnName) {
+  createColumnConstraint: function (spec, options, tableName, columnName) {
     var constraint = [];
@@ -400,3 +400,3 @@ var callbacks = [];
       callbacks.push(
-        function(tableName, columnName, comment, callback) {
+        function (tableName, columnName, comment, callback) {
           var sql = util.format(
@@ -420,3 +420,3 @@ "COMMENT on COLUMN %s.%s IS '%s'",
 
-  renameTable: function(tableName, newTableName, callback) {
+  renameTable: function (tableName, newTableName, callback) {
     let options = {};
@@ -436,3 +436,3 @@ if (typeof callback === 'object') {
 
-  removeColumn: function(tableName, columnName, callback) {
+  removeColumn: function (tableName, columnName, callback) {
     let options = {};
@@ -461,3 +461,3 @@ if (typeof callback === 'object') {
 
-  renameColumn: function(tableName, oldColumnName, newColumnName, callback) {
+  renameColumn: function (tableName, oldColumnName, newColumnName, callback) {
     let options = {};
@@ -478,3 +478,3 @@ if (typeof callback === 'object') {
 
-  changeColumn: function(tableName, columnName, columnSpec, callback) {
+  changeColumn: function (tableName, columnName, columnSpec, callback) {
     let options = {};
@@ -488,3 +488,3 @@ if (typeof callback === 'object') {
 
-    function setNotNull() {
+    function setNotNull () {
       var setOrDrop = columnSpec.notNull === true ? 'SET' : 'DROP';
@@ -501,3 +501,3 @@ var sql = util.format(
 
-    function setUnique() {
+    function setUnique () {
       var sql;
@@ -526,3 +526,3 @@ var constraintName = tableName + '_' + columnName + '_key';
 
-    function setDefaultValue() {
+    function setDefaultValue () {
       var sql;
@@ -553,3 +553,3 @@
 
-    function setType() {
+    function setType () {
       if (columnSpec.type !== undefined) {
@@ -560,6 +560,6 @@ var using =
             : util.format(
-                'USING "%s"::%s',
-                columnName,
-                this.mapDataType(columnSpec.type)
-              );
+              'USING "%s"::%s',
+              columnName,
+              this.mapDataType(columnSpec.type)
+            );
         var len = columnSpec.length
@@ -581,3 +581,3 @@ ? util.format('(%s)', columnSpec.length)
 
-  addForeignKey: function(
+  addForeignKey: function (
     tableName,
@@ -595,3 +595,3 @@ referencedTableName,
     var columns = Object.keys(fieldMapping);
-    var referencedColumns = columns.map(function(key) {
+    var referencedColumns = columns.map(function (key) {
       return '"' + fieldMapping[key] + '"';
@@ -612,3 +612,3 @@ });
 
-  removeForeignKey: function(tableName, keyName, callback) {
+  removeForeignKey: function (tableName, keyName, callback) {
     let options = {};
@@ -620,12 +620,11 @@ if (typeof callback === 'object') {
 
-    if (type)
-      var sql = util.format(
-        'ALTER TABLE "%s" DROP CONSTRAINT "%s"',
-        tableName,
-        keyName
-      );
+    var sql = util.format(
+      'ALTER TABLE "%s" DROP CONSTRAINT "%s"',
+      tableName,
+      keyName
+    );
     return this.runSql(sql).nodeify(callback);
   },
 
-  insert: function() {
+  insert: function () {
     var index = 1;
@@ -637,3 +636,3 @@
 
-    arguments[index] = arguments[index].map(function(value) {
+    arguments[index] = arguments[index].map(function (value) {
       return typeof value === 'string' ? value : JSON.stringify(value);
@@ -645,3 +644,3 @@ });
 
-  runSql: function() {
+  runSql: function () {
     var callback;
@@ -675,4 +674,4 @@ var minLength = 1;
     return new Promise(
-      function(resolve, reject) {
-        var prCB = function(err, data) {
+      function (resolve, reject) {
+        var prCB = function (err, data) {
           return err ? reject(err) : resolve(data);
@@ -689,3 +688,3 @@ };
 
-  _getKV: function(table, key) {
+  _getKV: function (table, key) {
     var sql =
@@ -700,3 +699,3 @@ 'SELECT * FROM ' +
 
-  all: function(...params) {
+  all: function (...params) {
     let cb;
@@ -710,7 +709,7 @@ if (typeof params[params.length - 1] === 'function') {
     return new Promise(
-      function(resolve, reject) {
-        var prCB = function(err, data) {
+      function (resolve, reject) {
+        var prCB = function (err, data) {
           return err ? reject(err) : resolve(data);
         };
-        params.push(function(err, result) {
+        params.push(function (err, result) {
           prCB(err, result ? result.rows : result);
@@ -724,3 +723,3 @@ });
 
-  close: function(callback) {
+  close: function (callback) {
     this.connection.end();
@@ -745,3 +744,3 @@ if (typeof callback === 'function') {
 
-exports.connect = function(config, intern, callback) {
+exports.connect = function (config, intern, callback) {
   if (config.native) {
@@ -754,3 +753,3 @@ pg = pg.native;
   var db = config.db || new pg.Client(config);
-  db.connect(function(err) {
+  db.connect(function (err) {
     if (err) {
@@ -757,0 +756,0 @@ callback(err);

package.json

 {
   "name": "db-migrate-pg",
-  "version": "1.2.1",
+  "version": "1.2.2",
   "description": "A postgresql driver for db-migrate",
@@ -35,3 +35,3 @@ "main": "index.js",
     "db-migrate-base": "^2.3.0",
-    "pg": "^7.8.0",
+    "pg": "^8.0.3",
     "semver": "^5.0.3"
@@ -38,0 +38,0 @@ },

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

28015

increased by0.16%

Worsened metrics

Lines of code

633

decreased by-0.16%

Dependency changes

• + Addedpg@8.13.0(transitive)

• + Addedpg-cloudflare@1.1.1(transitive)

• + Addedpg-connection-string@2.7.0(transitive)

• + Addedpg-pool@3.7.0(transitive)

• + Addedpg-protocol@1.7.0(transitive)

• - Removedbuffer-writer@2.0.0(transitive)

• - Removedpacket-reader@1.0.0(transitive)

• - Removedpg@7.18.2(transitive)

• - Removedpg-connection-string@0.1.3(transitive)

• - Removedpg-packet-stream@1.1.0(transitive)

• - Removedpg-pool@2.0.10(transitive)

• - Removedsemver@4.3.2(transitive)

• Updatedpg@^8.0.3