mirror of
https://github.com/knex/knex.git
synced 2025-07-30 04:10:20 +00:00
f735dcb9c8
Adds ?? for interpolating identifiers in raw
statements. Also adds raw(sql, obj) for
named :key syntax. Alternatively, 🔑
(trailing colon) may be used to specify an
identifier as a parameter.
53 lines
1.4 KiB
JavaScript
53 lines
1.4 KiB
JavaScript
'use strict';
|
|
|
|
var inherits = require('inherits')
|
|
var Promise = require('../../promise')
|
|
var Transaction = require('../../transaction')
|
|
var assign = require('lodash/object/assign');
|
|
var debugTx = require('debug')('knex:tx')
|
|
|
|
function Oracle_Transaction(client, container, config, outerTx) {
|
|
Transaction.call(this, client, container, config, outerTx)
|
|
}
|
|
inherits(Oracle_Transaction, Transaction)
|
|
|
|
assign(Oracle_Transaction.prototype, {
|
|
|
|
// disable autocommit to allow correct behavior (default is true)
|
|
begin: function() {
|
|
return Promise.resolve()
|
|
},
|
|
|
|
commit: function(conn, value) {
|
|
return Promise.promisify(conn.commit, conn)()
|
|
.return(value)
|
|
.then(this._resolver, this._rejecter)
|
|
},
|
|
|
|
rollback: function(conn, err) {
|
|
return Promise.promisify(conn.rollback, conn)()
|
|
.throw(err)
|
|
.then(this._resolver, this._rejecter)
|
|
},
|
|
|
|
acquireConnection: function(config) {
|
|
var t = this
|
|
return Promise.try(function() {
|
|
return config.connection || t.client.acquireConnection()
|
|
}).tap(function(connection) {
|
|
if (!t._outerTx) {
|
|
return connection.setAutoCommit(false)
|
|
}
|
|
}).disposer(function(connection) {
|
|
if (!config.connection) {
|
|
t.client.releaseConnection(connection)
|
|
} else {
|
|
debugTx('%s: not releasing external connection', t.txid)
|
|
}
|
|
})
|
|
}
|
|
|
|
})
|
|
|
|
module.exports = Oracle_Transaction
|