Function AggregateFunctions

lib/AggregateFunctions.js:7–176

(opts)

module.exports = AggregateFunctions;

function AggregateFunctions(opts) {
  if (typeof opts.driver.getQuery !== "function") {
    throw new ORMError('NO_SUPPORT', "This driver does not support aggregate functions");
  }
  if (!Array.isArray(opts.driver.aggregate_functions)) {
    throw new ORMError('NO_SUPPORT', "This driver does not support aggregate functions");
  }

  var aggregates    = [ [] ];
  var group_by      = null;
  var used_distinct = false;

  var appendFunction = function (fun) {
    return function () {
      var args = (arguments.length && Array.isArray(arguments[0]) ? arguments[0] : Array.prototype.slice.apply(arguments));

      if (args.length > 0) {
        aggregates[aggregates.length - 1].push({ f: fun, a: args, alias: aggregateAlias(fun, args) });
        aggregates.push([]);
      } else {
        aggregates[aggregates.length - 1].push({ f: fun, alias: aggregateAlias(fun, args) });
      }

      if (fun === "distinct") {
        used_distinct = true;
      }

      return proto;
    };
  };
  var proto = {
    groupBy: function () {
      group_by = Array.prototype.slice.apply(arguments);
      return this;
    },
    limit: function (offset, limit) {
      if (typeof limit === "number") {
        opts.limit = [ offset, limit ];
      } else {
        opts.limit = [ 0, offset ]; // offset = limit
      }
      return this;
    },
    order: function () {
      opts.order = Utilities.standardizeOrder(Array.prototype.slice.apply(arguments));
      return this;
    },
    select: function () {
      if (arguments.length === 0) {
        throw new ORMError('PARAM_MISMATCH', "When using append you must at least define one property");
      }
      if (Array.isArray(arguments[0])) {
        opts.propertyList = opts.propertyList.concat(arguments[0]);
      } else {
        opts.propertyList = opts.propertyList.concat(Array.prototype.slice.apply(arguments));
      }
      return this;
    },