You cannot select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
42 lines
1.1 KiB
JavaScript
42 lines
1.1 KiB
JavaScript
|
|
var Transaction = require('../../transaction')
|
|
var assign = require('lodash/object/assign');
|
|
var inherits = require('inherits')
|
|
var debug = require('debug')('knex:tx')
|
|
var helpers = require('../../helpers')
|
|
|
|
function Transaction_MySQL() {
|
|
Transaction.apply(this, arguments)
|
|
}
|
|
inherits(Transaction_MySQL, Transaction)
|
|
|
|
assign(Transaction_MySQL.prototype, {
|
|
|
|
query: function(conn, sql, status, value) {
|
|
var t = this
|
|
var q = this.trxClient.query(conn, sql)
|
|
.catch(function(err) {
|
|
return err.errno === 1305
|
|
}, function() {
|
|
helpers.warn('Transaction was implicitly committed, do not mix transactions and DDL with MySQL (#805)')
|
|
})
|
|
.catch(function(err) {
|
|
status = 2
|
|
value = err
|
|
t._completed = true
|
|
debug('%s error running transaction query', t.txid)
|
|
})
|
|
.tap(function() {
|
|
if (status === 1) t._resolver(value)
|
|
if (status === 2) t._rejecter(value)
|
|
})
|
|
if (status === 1 || status === 2) {
|
|
t._completed = true
|
|
}
|
|
return q;
|
|
}
|
|
|
|
})
|
|
|
|
module.exports = Transaction_MySQL
|