Function ORM

lib/ORM.js:178–215

(driver_name, driver, settings)

exports.addAdapter = adapters.add;

function ORM(driver_name, driver, settings) {
  this.validators  = exports.validators;
  this.enforce     = exports.enforce;
  this.settings    = settings;
  this.driver_name = driver_name;
  this.driver      = driver;
  this.driver.uid  = hat();
  this.tools       = {};
  this.models      = {};
  this.plugins     = [];
  this.customTypes = {};

  for (var k in Query.Comparators) {
    this.tools[Query.Comparators[k]] = Query[Query.Comparators[k]];
  }

  events.EventEmitter.call(this);

  var onError = function (err) {
    if (this.settings.get("connection.reconnect")) {
      if (typeof this.driver.reconnect === "undefined") {
        return this.emit("error", new ORMError("Connection lost - driver does not support reconnection", 'CONNECTION_LOST'));
      }
      this.driver.reconnect(function () {
        this.driver.on("error", onError);
      }.bind(this));

      if (this.listeners("error").length === 0) {
        // since user want auto reconnect,
        // don't emit without listeners or it will throw
        return;
      }
    }
    this.emit("error", err);
  }.bind(this);

  driver.on("error", onError);
}

util.inherits(ORM, events.EventEmitter);