transaction-manager.js

var Utils = require('./utils')

var TransactionManager = module.exports = function(sequelize) {
  this.sequelize         = sequelize
  this.connectorManagers = {}

  try {
    this.ConnectorManager = require("./dialects/" + sequelize.getDialect() + "/connector-manager")
  } catch(err) {
    throw new Error("The dialect " + sequelize.getDialect() + " is not supported.")
  }
}

TransactionManager.prototype.getConnectorManager = function(uuid) {
  uuid = uuid || 'default'

  if (!this.connectorManagers.hasOwnProperty(uuid)) {
    var config = Utils._.extend({ uuid: uuid }, this.sequelize.config)

    if (uuid !== 'default') {
      config.pool = Utils._.extend(
        {},
        Utils._.clone(config.pool || {}),
        {
          minConnections: 1,
          maxConnections: 1,
          useReplicaton:  false
        }
      )
      config.keepDefaultTimezone = true
    }

    this.connectorManagers[uuid] = new this.ConnectorManager(this.sequelize, config)
  }

  return this.connectorManagers[uuid]
}

TransactionManager.prototype.releaseConnectionManager = function(uuid) {
  this.connectorManagers[uuid].cleanup();
  delete this.connectorManagers[uuid]
}

TransactionManager.prototype.query = function(sql, callee, options) {
  options      = options || {}
  options.uuid = 'default'

  if (options.transaction) {
    options.uuid = options.transaction.id
  }

  return this.getConnectorManager(options.uuid).query(sql, callee, options)
}