Function nativeUpdate

packages/sql/src/AbstractSqlDriver.ts:1366–1439

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

  }

  async nativeUpdate<T extends object>(
    entityName: EntityName<T>,
    where: FilterQuery<T>,
    data: EntityDictionary<T>,
    options: NativeInsertUpdateOptions<T> & UpsertOptions<T> = {},
  ): Promise<QueryResult<T>> {
    options.convertCustomTypes ??= true;
    const meta = this.metadata.get(entityName);
    const pks = this.getPrimaryKeyFields(meta);
    const collections = this.extractManyToMany(meta, data);
    let res = { affectedRows: 0, insertId: 0, row: {} } as QueryResult<T>;

    if (Utils.isPrimaryKey(where) && pks.length === 1) {
      /* v8 ignore next */
      where = { [meta.primaryKeys[0] ?? pks[0]]: where } as FilterQuery<T>;
    }

    if (!options.upsert && options.unionWhere?.length) {
      where = (await this.applyUnionWhere(meta, where as ObjectQuery<T>, options, true)) as FilterQuery<T>;
    }

    if (Utils.hasObjectKeys(data)) {
      const qb = this.createQueryBuilder<T>(
        entityName,
        options.ctx,
        'write',
        options.convertCustomTypes,
        options.loggerContext,
      ).withSchema(this.getSchemaName(meta, options));
      qb.setAbortOptions(pickAbortOptions(options));

      if (options.upsert) {
        /* v8 ignore next */
        const uniqueFields =
          options.onConflictFields ??
          ((Utils.isPlainObject(where) ? (Utils.keys(where) as EntityKey<T>[]) : meta.primaryKeys) as (keyof T)[]);
        const returning = getOnConflictReturningFields(meta, data, uniqueFields, options);
        qb.insert(data as T)
          .onConflict(uniqueFields as any)
          .returning(returning as any);

        if (!options.onConflictAction || options.onConflictAction === 'merge') {
          const fields = getOnConflictFields(meta, data, uniqueFields, options);
          qb.merge(fields as any);
        }

        if (options.onConflictAction === 'ignore') {
          qb.ignore();
        }

        if (options.onConflictWhere) {
          qb.where(options.onConflictWhere as any);
        }
      } else {
        qb.update(data).where(where as any);

        // reload generated columns and version fields
        const returning: string[] = [];