Function nativeInsertMany

packages/sql/src/AbstractSqlDriver.ts:1155–1364

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

  }

  async nativeInsertMany<T extends object>(
    entityName: EntityName<T>,
    data: EntityDictionary<T>[],
    options: NativeInsertUpdateManyOptions<T> = {},
    transform?: (sql: string) => string,
  ): Promise<QueryResult<T>> {
    options.processCollections ??= true;
    options.convertCustomTypes ??= true;
    const entityMeta = this.metadata.get(entityName);
    const meta = entityMeta.inheritanceType === 'tpt' ? entityMeta : entityMeta.root;
    const collections = options.processCollections ? data.map(d => this.extractManyToMany(meta, d)) : [];
    const pks = this.getPrimaryKeyFields(meta);
    const set = new Set<EntityKey<T>>();
    data.forEach(row => Utils.keys(row).forEach(k => set.add(k)));
    const props = [...set].map(name => meta.properties[name] ?? { name, fieldNames: [name] }) as EntityProperty<T>[];
    // For STI with conflicting fieldNames, include all alternative columns
    let fields = Utils.flatten(props.map(prop => prop.stiFieldNames ?? prop.fieldNames));
    const duplicates = Utils.findDuplicates(fields);
    const params: unknown[] = [];

    if (duplicates.length) {
      fields = Utils.unique(fields);
    }

    const tableName = this.getTableName(meta, options);
    let sql = `insert into ${tableName} `;
    sql +=
      fields.length > 0
        ? '(' + fields.map(k => this.platform.quoteIdentifier(k)).join(', ') + ')'
        : `(${this.platform.quoteIdentifier(pks[0])})`;

    if (this.platform.usesOutputStatement()) {
      const returningProps = this.getTableProps(meta)
        .filter(prop => (prop.persist !== false && prop.defaultRaw) || prop.autoincrement || prop.generated)
        .filter(prop => !(prop.name in data[0]) || isRaw(data[0][prop.name]));
      const returningFields = Utils.flatten(returningProps.map(prop => prop.fieldNames));
      sql +=
        returningFields.length > 0
          ? ` output ${returningFields.map(field => 'inserted.' + this.platform.quoteIdentifier(field)).join(', ')}`
          : '';
    }

    if (fields.length > 0 || this.platform.usesDefaultKeyword()) {
      sql += ' values ';
    } else {
      sql += ' ' + data.map(() => `select null as ${this.platform.quoteIdentifier(pks[0])}`).join(' union all ');
    }

    const addParams = (prop: EntityProperty<T>, row: Dictionary) => {
      const rowValue = row[prop.name];

      if (prop.nullable && rowValue === null) {
        params.push(null);
        return;
      }

      let value = rowValue ?? prop.default;