Skip to content

Commit 592dfe7

Browse files
author
Tal Almagor
committed
fix verbose issues
1 parent fd363de commit 592dfe7

File tree

2 files changed

+13
-9
lines changed

2 files changed

+13
-9
lines changed

lib/client.js

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -166,21 +166,21 @@ var Client = (function () {
166166
var promise = new Promise(function (resolve, reject) {
167167
self._getConnection(connectionConfig, function (err, connection) {
168168
if (err) return reject(err);
169-
_private._logger.info("Starting transaction");
169+
_private._logger.debug("Starting transaction");
170170
connection.beginTransaction(function (err) {
171171
if (err) reject(err);
172172
connection.query(multipleStatements, undefined, function (err, result) {
173173
if (err) {
174-
_private._logger.info("Something went wrong here, rolling back.");
174+
_private._logger.debug("Something went wrong here, rolling back.");
175175
connection.rollback(function () {
176176
reject(err);
177177
connection.end();
178178
});
179179
} else {
180-
_private._logger.info("Committing");
180+
_private._logger.debug("Committing");
181181
connection.commit(function (err) {
182182
if (err) {
183-
_private._logger.info("Commit failed, rolling back.");
183+
_private._logger.debug("Commit failed, rolling back.");
184184
connection.rollback(function () {
185185
reject(err);
186186
connection.end();

lib/schema.js

Lines changed: 9 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -124,8 +124,8 @@ var SchemaManager = (function () {
124124
_private._addObject = function (obj) {
125125
var ov = _private._parseObject(obj);
126126
_private._logger.info(
127-
"Saving version `%s` to `%s`.`%s`",
128-
ov.version, self._schema, _private._revisionTbl
127+
"Saving object %s/%s to `%s`.`%s`",
128+
ov.version, ov.script, self._schema, _private._revisionTbl
129129
);
130130
return _private._client.execute(
131131
_private._escape("INSERT INTO ??.?? SET ? ON DUPLICATE KEY UPDATE ?", [ov, ov])
@@ -180,14 +180,14 @@ var SchemaManager = (function () {
180180
promise = _private._client._getConnection()
181181
.then(function connect(connection) {
182182
conn = Promise.promisifyAll(connection);
183-
_private._logger.info("Starting transaction");
183+
_private._logger.debug("Starting transaction");
184184
return conn.beginTransactionAsync();
185185
})
186186
.then(function migrate() {
187187
return exec(conn);
188188
})
189189
.then(function commit() {
190-
_private._logger.info("Committing transaction");
190+
_private._logger.debug("Committing");
191191
return conn.commitAsync();
192192
})
193193
.catch(function (e) {
@@ -197,7 +197,7 @@ var SchemaManager = (function () {
197197
_private._logger.error(e);
198198
}
199199
if (conn) {
200-
_private._logger.info("Something went wrong, rolling back");
200+
_private._logger.debug("Something went wrong, rolling back");
201201
return conn.rollbackAsync();
202202
} else {
203203
return Promise.resolve();
@@ -210,6 +210,10 @@ var SchemaManager = (function () {
210210
);
211211
}
212212

213+
_private._logger.info("Running migration script %s/%s (%s)",
214+
migration.version, migration.rank || 1, migration.script
215+
);
216+
213217
return promise
214218
.then(function () {
215219
end = new Date;

0 commit comments

Comments
 (0)