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.

49 lines
1.4 KiB
JavaScript

var makeKnex = require('../../util/make-knex')
var Promise = require('../../promise')
var helpers = require('../../helpers')
var inherits = require('inherits')
var EventEmitter = require('events').EventEmitter
function Transaction_WebSQL(client, container) {
helpers.warn('WebSQL transactions will run queries, but do not commit or rollback')
var trx = this
this._promise = Promise.try(function() {
container(makeKnex(makeClient(trx, client)))
})
}
inherits(Transaction_WebSQL, EventEmitter)
function makeClient(trx, client) {
var trxClient = Object.create(client.constructor.prototype)
trxClient.config = client.config
trxClient.connectionSettings = client.connectionSettings
trxClient.transacting = true
trxClient.on('query', function(arg) {
trx.emit('query', arg)
client.emit('query', arg)
})
trxClient.commit = function() {}
trxClient.rollback = function() {}
return trxClient
}
var promiseInterface = [
'then', 'bind', 'catch', 'finally', 'asCallback',
'spread', 'map', 'reduce', 'tap', 'thenReturn',
'return', 'yield', 'ensure', 'nodeify', 'exec'
]
// Creates a method which "coerces" to a promise, by calling a
// "then" method on the current `Target`
promiseInterface.forEach(function(method) {
Transaction_WebSQL.prototype[method] = function() {
return (this._promise = this._promise[method].apply(this._promise, arguments))
}
})
module.exports = Transaction_WebSQL