Function _insertMany

lib/model.js:3045–3281

(arr, options)

};

async function _insertMany(arr, options) {
  options = options || {};
  const preFilter = buildMiddlewareFilter(options, 'pre');
  const postFilter = buildMiddlewareFilter(options, 'post');

  try {
    [arr] = await this._middleware.execPre('insertMany', this, [arr], { filter: preFilter });
  } catch (error) {
    await this._middleware.execPost('insertMany', this, [arr], { error, filter: postFilter });
  }
  const ThisModel = this;
  const limit = options.limit || 1000;
  const rawResult = !!options.rawResult;
  const ordered = typeof options.ordered === 'boolean' ? options.ordered : true;
  const throwOnValidationError = typeof options.throwOnValidationError === 'boolean' ? options.throwOnValidationError : false;
  const lean = !!options.lean;

  const asyncLocalStorage = this.db.base.transactionAsyncLocalStorage?.getStore();
  if ((!options || !Object.hasOwn(options, 'session')) && asyncLocalStorage?.session != null) {
    options = { ...options, session: asyncLocalStorage.session };
  }

  if (!Array.isArray(arr)) {
    arr = [arr];
  }

  const validationErrors = [];
  const validationErrorsToOriginalOrder = new Map();
  const results = ordered ? null : new Array(arr.length);
  async function validateDoc(doc, index) {
    // If option `lean` is set to true bypass validation and hydration
    if (lean) {
      return doc;
    }
    let createdNewDoc = false;
    if (!(doc instanceof ThisModel)) {
      if (doc != null && typeof doc !== 'object') {
        throw new ObjectParameterError(doc, 'arr.' + index, 'insertMany');
      }
      doc = new ThisModel(doc);
      createdNewDoc = true;
    }

    if (options.session != null) {
      doc.$session(options.session);
    }
    return doc.$validate(createdNewDoc ? { _skipParallelValidateCheck: true } : null)
      .then(() => doc)
      .catch(error => {
        if (ordered === false) {
          error.index = index;
          validationErrors.push(error);
          validationErrorsToOriginalOrder.set(error, index);
          results[index] = error;
          return;
        }
        throw error;
      });