}
function executeMigration (actualVersion, entity, callback) {
- const versionScript = entity.version
+ const versionScript = parseInt(entity.version)
// Do not execute old migration scripts
if (versionScript <= actualVersion) return callback(null)
db.sequelize.transaction().asCallback(function (err, t) {
if (err) return callback(err)
- migrationScript.up({ transaction: t }, function (err) {
+ const options = {
+ transaction: t,
+ queryInterface: db.sequelize.getQueryInterface(),
+ Sequelize: db.Sequelize
+ }
+ migrationScript.up(options, function (err) {
if (err) {
t.rollback()
return callback(err)
return callback(err)
}
- t.commit()
+ t.commit().asCallback(callback)
})
})
})