Function Driver

lib/Drivers/DML/postgres.js:63–111

(config, connection, opts)

};

function Driver(config, connection, opts) {
  var functions = switchableFunctions.client;

  this.dialect = 'postgresql';
  this.config = config || {};
  this.opts   = opts || {};

  if (!this.config.timezone) {
    this.config.timezone = "local";
  }

  this.query  = new Query({ dialect: this.dialect, timezone: this.config.timezone });
  this.customTypes = {};

  if (connection) {
    this.db = connection;
  } else {
    if (this.config.query && this.config.query.ssl) {
      config.ssl = true;
      this.config = _.extend(this.config, config);
    // } else {
    //   this.config = _.extend(this.config, config);
    //   this.config = config.href || config;
    }

    pg.types.setTypeParser(20, Number);

    if (opts.pool) {
      functions = switchableFunctions.pool;
      this.db = new pg.Pool(this.config);
    } else {
      this.db = new pg.Client(this.config);
    }
  }

  _.extend(this.constructor.prototype, functions);

  this.constructor.prototype.execSimpleQueryAsync = Promise.promisify(this.constructor.prototype.execSimpleQuery);

  this.aggregate_functions = [
    "ABS", "CEIL", "FLOOR", "ROUND",
    "AVG", "MIN", "MAX",
    "LOG", "EXP", "POWER",
    "ACOS", "ASIN", "ATAN", "COS", "SIN", "TAN",
    "RANDOM", "RADIANS", "DEGREES",
    "SUM", "COUNT",
    "DISTINCT"
  ];
}

_.extend(Driver.prototype, shared, DDL);