Method insertMany

packages/core/src/EntityManager.ts:1869–1921

* Fires native multi-insert query. Calling this has no side effects on the context (identity map).

(
    entityNameOrEntities: EntityName<Entity> | Entity[],
    data?: RequiredEntityData<Entity>[] | Entity[],
    options: NativeInsertUpdateOptions<Entity> = {},
  )

   * Fires native multi-insert query. Calling this has no side effects on the context (identity map).
   */
  async insertMany<Entity extends object>(
    entityNameOrEntities: EntityName<Entity> | Entity[],
    data?: RequiredEntityData<Entity>[] | Entity[],
    options: NativeInsertUpdateOptions<Entity> = {},
  ): Promise<Primary<Entity>[]> {
    const em = this.getContext(false);
    em.prepareOptions(options);

    let entityName: EntityName<Entity>;

    if (data === undefined) {
      entityName = ((entityNameOrEntities as Entity[])[0] as Dictionary).constructor;
      data = entityNameOrEntities as Entity[];
    } else {
      entityName = entityNameOrEntities as EntityName<Entity>;
    }

    if (data.length === 0) {
      return [];
    }

    if (Utils.isEntity<Entity>(data[0])) {
      const meta = helper<Entity>(data[0]).__meta;
      const css = data.map(row => {
        if (options.schema && helper(row).getSchema() == null) {
          helper(row).setSchema(options.schema);
        }

        if (!helper(row).__managed) {
          em.#unitOfWork.unsetIdentity(row);
        }

        const payload = em.#comparator.prepareEntity(row) as EntityData<Entity>;
        return new ChangeSet<Entity>(row as Entity, ChangeSetType.CREATE, payload, meta);
      });
      await em.#unitOfWork.getChangeSetPersister().executeInserts(css, { ctx: em.#transactionContext, ...options });

      return css.map(cs => cs.getPrimaryKey()!);
    }

    data = data.map(row => QueryHelper.processObjectParams(row));
    data.forEach(row => validateParams(row, 'insert data'));
    const res = await em.driver.nativeInsertMany<Entity>(entityName, data as EntityData<Entity>[], {
      ctx: em.#transactionContext,
      ...options,
    });

    if (res.insertedIds) {
      return res.insertedIds;
    }

    return [res.insertId];
  }

  /**
   * Fires native update query. Calling this has no side effects on the context (identity map).