yujunjun/knex
1
0
Fork 0
mirror of https://github.com/knex/knex.git synced 2026-01-05 19:47:55 +00:00
Code Issues Packages Projects Releases Wiki Activity

Allow enabling/disabling transaction per-migration

Browse Source 
Not just disabling transaction per-migration, but also enabling
it in case transactions were turned globally off with
config.disableTransactions.
This commit is contained in:
harriha 2015-08-30 14:57:55 +03:00 committed by Rhys van der Waerden
parent 3d85822a28
commit b1f2c258df
1 changed files with 15 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
src/migrate/index.js
View File

@ -192,6 +192,18 @@ export default class Migrator {
});
}
// If transaction conf for a single migration is defined, use that.
// Otherwise, rely on the common config. This allows enabling/disabling
// transaction for a single migration by will, regardless of the common
// config.
_useTransaction(migration, allTransactionsDisabled) {
var singleTransactionValue = _.get(migration, 'config.transaction');
return _.isBoolean(singleTransactionValue) ?
singleTransactionValue :
!allTransactionsDisabled;
}
// Runs a batch of `migrations` in a specified `direction`,
// saving the appropriate database information as the migrations are run.
_waterfallBatch(batchNo, migrations, direction) {
@ -206,10 +218,10 @@ export default class Migrator {
// We're going to run each of the migrations in the current "up"
current = current.then(() => {
if (disableTransactions) {
return warnPromise(migration[direction](knex, Promise), name)
if (this._useTransaction(migration, disableTransactions)) {
return this._transaction(migration, direction, name)
}
return this._transaction(migration, direction, name)
return warnPromise(migration[direction](knex, Promise), name)
})
.then(() => {
log.push(path.join(directory, name));