var logger = require('../config/logger')('migration');
-var Sequence = function () {};
+var Sequence = function() {};
-Sequence.prototype.enqueue = function (fn) {
+Sequence.prototype.enqueue = function(fn) {
this.tail = this.tail ? this.tail.finally(fn) : fn();
};
-var Migration = function (queryInterface) {
+var Migration = function(queryInterface) {
this.queryInterface = queryInterface;
this.sequence = new Sequence();
};
-Migration.prototype.changeColumn = function (table, column, type) {
+Migration.prototype.changeColumn = function(table, column, type) {
var _this = this;
- this.sequence.enqueue(function () {
+ this.sequence.enqueue(function() {
return _this.queryInterface
.changeColumn(table, column, type)
- .then(function () {
+ .then(function() {
logger.info('Changed column %s in table %s', column, table);
})
- .catch(function (err) {
+ .catch(function(err) {
logger.info(JSON.stringify(err));
});
});
};
-Migration.prototype.addColumn = function (table, column, type) {
+Migration.prototype.addColumn = function(table, column, type) {
var _this = this;
- this.sequence.enqueue(function () {
+ this.sequence.enqueue(function() {
return _this.queryInterface
.addColumn(table, column, type)
- .then(function () {
+ .then(function() {
logger.info('Added column %s to %s', column, table);
})
- .catch(function (err) {
+ .catch(function(err) {
logger.info(JSON.stringify(err));
});
});
};
-Migration.prototype.dropTable = function (table) {
+Migration.prototype.dropTable = function(table) {
var _this = this;
- this.sequence.enqueue(function () {
+ this.sequence.enqueue(function() {
return _this.queryInterface
.dropTable(table, {
force: true
})
- .then(function () {
+ .then(function() {
logger.info('table dropped %s', table);
})
- .catch(function (err) {
+ .catch(function(err) {
logger.info(JSON.stringify(err));
});
});
};
-Migration.prototype.addIndex = function (table, column, indexName) {
+Migration.prototype.addIndex = function(table, column, indexName) {
var _this = this;
- this.sequence.enqueue(function () {
+ this.sequence.enqueue(function() {
return _this.queryInterface.addIndex(table, column, {
indexName: indexName
})
- .then(function () {
+ .then(function() {
logger.info('addIndex %s %s %s', table, column.join(','), indexName);
})
- .catch(function (err) {
+ .catch(function(err) {
logger.info(JSON.stringify(err));
});
});
};
-Migration.prototype.removeIndex = function (table, indexName) {
+Migration.prototype.removeIndex = function(table, indexName) {
var _this = this;
- this.sequence.enqueue(function () {
+ this.sequence.enqueue(function() {
return _this.queryInterface.removeIndex(table, indexName)
- .then(function () {
+ .then(function() {
logger.info('removeIndex %s %s', table, indexName);
})
- .catch(function (err) {
+ .catch(function(err) {
logger.info(JSON.stringify(err));
});
});
};
-Migration.prototype.query = function (sql) {
+Migration.prototype.query = function(sql) {
var _this = this;
- this.sequence.enqueue(function () {
+ this.sequence.enqueue(function() {
return _this.queryInterface.sequelize.query(sql)
- .then(function () {
+ .then(function() {
logger.info('query %s', sql);
})
- .catch(function (err) {
+ .catch(function(err) {
logger.info(JSON.stringify(err));
});
});
};
-Migration.prototype.removeColumn = function (table, column) {
+Migration.prototype.removeColumn = function(table, column) {
var _this = this;
- this.sequence.enqueue(function () {
+ this.sequence.enqueue(function() {
return _this.queryInterface.removeColumn(table, column)
- .then(function () {
+ .then(function() {
logger.info('Removed column %s from %s', column, table);
})
- .catch(function (err) {
+ .catch(function(err) {
logger.info(util.inspect(err, {
showHidden: false,
depth: null
});
};
-Migration.prototype.renameColumn = function (table, oldColumn, newColumn) {
+Migration.prototype.renameColumn = function(table, oldColumn, newColumn) {
var _this = this;
- this.sequence.enqueue(function () {
+ this.sequence.enqueue(function() {
return _this.queryInterface.renameColumn(table, oldColumn, newColumn)
- .then(function () {
+ .then(function() {
logger.info('Renamed column from %s to %s on %s', oldColumn, newColumn, table);
})
- .catch(function (err) {
+ .catch(function(err) {
logger.info(util.inspect(err, {
showHidden: false,
depth: null
});
};
-Migration.prototype.final = function (resolve) {
- this.sequence.enqueue(function () {
+Migration.prototype.final = function(resolve) {
+ this.sequence.enqueue(function() {
return resolve();
});
};
module.exports = {
- up: function (queryInterface, Sequelize) {
- return new BPromise(function (resolve) {
+ up: function(queryInterface, Sequelize) {
+ return new BPromise(function(resolve) {
var migration = new Migration(queryInterface);
// START report_jscripty_answers
});
},
- down: function (queryInterface, Sequelize) {
+ down: function(queryInterface, Sequelize) {
// var migration = new Migration(queryInterface);
}
};
\ No newline at end of file