db-migrate
Advanced tools
Comparing version 0.9.16 to 0.9.17
@@ -411,2 +411,5 @@ var util = require('util'); | ||
var args = this._makeParamArgs(arguments); | ||
log.sql.apply(null, arguments); | ||
return this.connection.query.apply(this.connection, args); | ||
@@ -413,0 +416,0 @@ }, |
@@ -153,4 +153,13 @@ var util = require('util'); | ||
var searchPath; | ||
var searchPath, | ||
search_pathes = result[0].search_path.split(','); | ||
for (var i = 0; i < search_pathes.length; ++i) { | ||
if (search_pathes[i].indexOf('"') !== 0) { | ||
search_pathes[i] = '"' + search_pathes[i] + '"'; | ||
} | ||
} | ||
result[0].search_path = search_pathes.join(','); | ||
// if the user specified a different schema, prepend it to the | ||
@@ -331,4 +340,12 @@ // search path. This will make all DDL/DML/SQL operate on the specified | ||
params = arguments; | ||
log.sql.apply(null, params); | ||
this.connection.query.apply(this.connection, [params[0], function(err, result){ | ||
params[1](err, result.rows); | ||
if(err) { | ||
params[1](err, null); | ||
return; | ||
} | ||
params[1](err, result.rows); | ||
}]); | ||
@@ -335,0 +352,0 @@ }, |
@@ -98,2 +98,5 @@ var util = require('util'); | ||
all: function() { | ||
log.sql.apply(null, arguments); | ||
this.connection.all.apply(this.connection, arguments); | ||
@@ -100,0 +103,0 @@ }, |
@@ -14,3 +14,3 @@ { | ||
], | ||
"version": "0.9.16", | ||
"version": "0.9.17", | ||
"engines": { | ||
@@ -17,0 +17,0 @@ "node": ">=0.6.0" |
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
130558
2495