transaction-manager.js

'use strict';

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);
};