Method nativeInsertMany

packages/oracledb/src/OracleDriver.ts:64–97

(
    entityName: EntityName<T>,
    data: EntityDictionary<T>[],
    options: NativeInsertUpdateManyOptions<T> = {},
  )

  }

  override async nativeInsertMany<T extends object>(
    entityName: EntityName<T>,
    data: EntityDictionary<T>[],
    options: NativeInsertUpdateManyOptions<T> = {},
  ): Promise<QueryResult<T>> {
    options.processCollections ??= true;
    options.convertCustomTypes ??= true;
    const meta = this.metadata.get<T>(entityName);
    const pks = this.getPrimaryKeyFields(meta) as EntityKey<T>[];
    const collections = options.processCollections ? data.map(d => this.extractManyToMany(meta, d)) : [];
    const qb = this.createQueryBuilder<T>(entityName, options.ctx, 'write', options.convertCustomTypes).withSchema(
      this.getSchemaName(meta, options),
    );
    qb.insert(data as RequiredEntityData<T>[]);

    const res = await this.rethrow(qb.execute('run'));
    let pk: any[];

    if (pks.length > 1) {
      // owner has composite pk
      pk = data.map(d => Utils.getPrimaryKeyCond(d as T, pks));
    } else {
      res.row ??= {};
      res.rows ??= [];
      pk = data.map((d, i) => d[pks[0]] ?? res.rows![i]?.[pks[0]]).map(d => [d]);
      res.insertId = res.insertId || res.row![pks[0]];
    }

    for (let i = 0; i < collections.length; i++) {
      await this.processManyToMany<T>(meta, pk[i], collections[i], false, options);
    }

    return res;
  }

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