Method insertQuery

lib/dialects/abstract/query-generator.js:101–262

* Returns an insert into command * * @param {string} table * @param {object} valueHash attribute value pairs * @param {object} modelAttributes * @param {object} [options] * * @private

(table, valueHash, modelAttributes, options)

   * @private
   */
  insertQuery(table, valueHash, modelAttributes, options) {
    options = options || {};
    _.defaults(options, this.options);

    const modelAttributeMap = {};
    const bind = [];
    const fields = [];
    const returningModelAttributes = [];
    const values = [];
    const quotedTable = this.quoteTable(table);
    const bindParam = options.bindParam === undefined ? this.bindParam(bind) : options.bindParam;
    let query;
    let valueQuery = class="st">'';
    let emptyQuery = class="st">'';
    let outputFragment = class="st">'';
    let returningFragment = class="st">'';
    let identityWrapperRequired = false;
    let tmpTable = class="st">''; class="cm">//tmpTable declaration for trigger

    if (modelAttributes) {
      _.each(modelAttributes, (attribute, key) => {
        modelAttributeMap[key] = attribute;
        if (attribute.field) {
          modelAttributeMap[attribute.field] = attribute;
        }
      });
    }

    if (this._dialect.supports[class="st">'DEFAULT VALUES']) {
      emptyQuery += class="st">' DEFAULT VALUES';
    } else if (this._dialect.supports[class="st">'VALUES ()']) {
      emptyQuery += class="st">' VALUES ()';
    }

    if (this._dialect.supports.returnValues && options.returning) {
      const returnValues = this.generateReturnValues(modelAttributes, options);

      returningModelAttributes.push(...returnValues.returnFields);
      returningFragment = returnValues.returningFragment;
      tmpTable = returnValues.tmpTable || class="st">'';
      outputFragment = returnValues.outputFragment || class="st">'';
    }

    if (_.get(this, [class="st">'sequelize', class="st">'options', class="st">'dialectOptions', class="st">'prependSearchPath']) || options.searchPath) {
      class="cm">// Not currently supported with search path (requires output of multiple queries)
      options.bindParam = false;
    }

    if (this._dialect.supports.EXCEPTION && options.exception) {
      class="cm">// Not currently supported with bind parameters (requires output of multiple queries)
      options.bindParam = false;
    }

    valueHash = Utils.removeNullValuesFromHash(valueHash, this.options.omitNull);
    for (const key in valueHash) {
      if (Object.prototype.hasOwnProperty.call(valueHash, key)) {
        const value = valueHash[key];
        fields.push(this.quoteIdentifier(key));