Method nativeUpdateMany

packages/mongodb/src/MongoDriver.ts:435–497

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

  }

  override async nativeUpdateMany<T extends object>(
    entityName: EntityName<T>,
    where: FilterQuery<T>[],
    data: EntityDictionary<T>[],
    options: NativeInsertUpdateOptions<T> & UpsertManyOptions<T> = {},
  ): Promise<QueryResult<T>> {
    where = where.map(row => {
      if (Utils.isPlainObject(row)) {
        return this.renameFields(entityName, row as T, true);
      }

      return row;
    });
    data = data.map(row => {
      this.handleVersionProperty(entityName, row, true);
      return this.renameFields(entityName, row);
    });
    options = { ...options };

    const meta = this.metadata.find(entityName);
    /* v8 ignore next */
    const rename = (field: keyof T) =>
      meta ? ((meta.properties[field as EntityKey<T>]?.fieldNames[0] as keyof T) ?? field) : field;

    if (options.onConflictFields && Array.isArray(options.onConflictFields)) {
      options.onConflictFields = options.onConflictFields.map(rename);
    }

    if (options.onConflictMergeFields) {
      options.onConflictMergeFields = options.onConflictMergeFields.map(rename) as never[];
    }

    if (options.onConflictExcludeFields) {
      options.onConflictExcludeFields = options.onConflictExcludeFields.map(rename) as never[];
    }

    /* v8 ignore next */
    const pk = meta?.getPrimaryProps()[0].fieldNames[0] ?? '_id';
    const res = await this.rethrow(
      this.getConnection('write').bulkUpdateMany<T>(
        entityName,
        where as object[],
        data as object[],
        options.ctx,
        options.upsert,
        options,
        options.signal,
      ),
    );

    if (res.insertedIds) {
      let i = 0;
      res.rows = where.map(cond => {
        if (Utils.isEmpty(cond)) {
          return { [pk]: res.insertedIds![i++] };
        }

        return { [pk]: cond[pk as EntityKey] };