diff --git a/lib/migration.js b/lib/migration.js index 9bd05a5..7449ceb 100644 --- a/lib/migration.js +++ b/lib/migration.js @@ -41,8 +41,14 @@ function mixinMigration(MySQL, mysql) { } var table = self.tableEscaped(model); self.execute('SHOW FIELDS FROM ' + table, function(err, fields) { + if (err) console.log('Failed to discover "' + table + '" fields', err); + self.execute('SHOW INDEXES FROM ' + table, function(err, indexes) { - self.discoverForeignKeys(self.table(model), {}, function(discoverErr, foreignKeys) { + if (err) console.log('Failed to discover "' + table + '" indexes', err); + + self.discoverForeignKeys(self.table(model), {}, function(err, foreignKeys) { + if (err) console.log('Failed to discover "' + table + '" foreign keys', err); + if (!err && fields && fields.length) { self.alterTable(model, fields, indexes, foreignKeys, done); } else { @@ -94,8 +100,14 @@ function mixinMigration(MySQL, mysql) { async.each(models, function(model, done) { var table = self.tableEscaped(model); self.execute('SHOW FIELDS FROM ' + table, function(err, fields) { + if (err) console.log('Failed to discover "' + table + '" fields', err); + self.execute('SHOW INDEXES FROM ' + table, function(err, indexes) { - self.discoverForeignKeys(self.table(model), {}, function(discoverErr, foreignKeys) { + if (err) console.log('Failed to discover "' + table + '" indexes', err); + + self.discoverForeignKeys(self.table(model), {}, function(err, foreignKeys) { + if (err) console.log('Failed to discover "' + table + '" foreign keys', err); + self.alterTable(model, fields, indexes, foreignKeys, function(err, needAlter) { if (err) { return done(err);