Function nativeDelete

packages/sql/src/AbstractSqlDriver.ts:1652–1674

(
    entityName: EntityName<T>,
    where: FilterQuery<T> | string | any,
    options: DeleteOptions<T> = {},
  )

  }

  async nativeDelete<T extends object>(
    entityName: EntityName<T>,
    where: FilterQuery<T> | string | any,
    options: DeleteOptions<T> = {},
  ): Promise<QueryResult<T>> {
    const meta = this.metadata.get(entityName);
    const pks = this.getPrimaryKeyFields(meta);

    if (Utils.isPrimaryKey(where) && pks.length === 1) {
      where = { [pks[0]]: where };
    }

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

    const qb = this.createQueryBuilder(entityName, options.ctx, 'write', false, options.loggerContext)
      .delete(where)
      .withSchema(this.getSchemaName(meta, options));
    qb.setAbortOptions(pickAbortOptions(options));

    return this.rethrow(qb.execute('run', false));
  }

  /**
   * Fast comparison for collection snapshots that are represented by PK arrays.