Function nativeInsert

packages/sql/src/AbstractSqlDriver.ts:927–964

(
    entityName: EntityName<T>,
    data: EntityDictionary<T>,
    options: NativeInsertUpdateOptions<T> = {},
  )

  }

  async nativeInsert<T extends object>(
    entityName: EntityName<T>,
    data: EntityDictionary<T>,
    options: NativeInsertUpdateOptions<T> = {},
  ): Promise<QueryResult<T>> {
    options.convertCustomTypes ??= true;
    const meta = this.metadata.get(entityName);
    const collections = this.extractManyToMany(meta, data);
    const qb = this.createQueryBuilder(
      entityName,
      options.ctx,
      'write',
      options.convertCustomTypes,
      options.loggerContext,
    ).withSchema(this.getSchemaName(meta, options));
    qb.setAbortOptions(pickAbortOptions(options));
    const res = await this.rethrow(qb.insert(data as unknown as RequiredEntityData<T>).execute('run', false));
    res.row = res.row || {};
    let pk: any;

    if (meta.primaryKeys.length > 1) {
      // owner has composite pk
      pk = Utils.getPrimaryKeyCond(data as T, meta.primaryKeys);
    } else {
      /* v8 ignore next */
      res.insertId = data[meta.primaryKeys[0]] ?? res.insertId ?? res.row[meta.primaryKeys[0]];

      if (options.convertCustomTypes && meta?.getPrimaryProp().customType) {
        pk = [meta!.getPrimaryProp().customType!.convertToDatabaseValue(res.insertId, this.platform)];
      } else {
        pk = [res.insertId];
      }
    }

    await this.processManyToMany(meta, pk, collections, false, options);

    return res;
  }

  override async nativeClone<T extends object>(
    entityName: EntityName<T>,