Method insert

packages/core/src/EntityManager.ts:1764–1806

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

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

   * Fires native insert query. Calling this has no side effects on the context (identity map).
   */
  async insert<Entity extends object>(
    entityNameOrEntity: 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 = (entityNameOrEntity as Dictionary).constructor;
      data = entityNameOrEntity as Entity;
    } else {
      entityName = entityNameOrEntity as EntityName<Entity>;
    }

    if (Utils.isEntity<Entity>(data)) {
      if (options.schema && helper(data).getSchema() == null) {
        helper(data).setSchema(options.schema);
      }

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

      const meta = helper(data).__meta;
      const payload = em.#comparator.prepareEntity(data);
      const cs = new ChangeSet(data, ChangeSetType.CREATE, payload, meta);
      await em.#unitOfWork.getChangeSetPersister().executeInserts([cs], { ctx: em.#transactionContext, ...options });

      return cs.getPrimaryKey()!;
    }

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

    return res.insertId!;
  }

  /**
   * Clones rows matching the condition at the database level via INSERT...SELECT.