Function nativeCloneTPT

packages/sql/src/AbstractSqlDriver.ts:1019–1094

(
    leafMeta: EntityMetadata<T>,
    where: FilterQuery<T>,
    overrides?: EntityData<T>,
    options: NativeInsertUpdateOptions<T> = {},
  )

  }

  private async nativeCloneTPT<T extends object>(
    leafMeta: EntityMetadata<T>,
    where: FilterQuery<T>,
    overrides?: EntityData<T>,
    options: NativeInsertUpdateOptions<T> = {},
  ): Promise<QueryResult<T>> {
    const hierarchy: EntityMetadata[] = [];
    let current: EntityMetadata | undefined = leafMeta;

    while (current) {
      hierarchy.unshift(current);
      current = current.tptParent;
    }

    const rootMeta = hierarchy[0];
    let newPk: any;
    let rootResult: QueryResult<T> | undefined;

    for (const tableMeta of hierarchy) {
      const props = this.getCloneableProps(tableMeta as EntityMetadata<T>, true);
      const mappedOverrides = this.mapCloneOverrides(overrides, tableMeta as EntityMetadata<T>, options);
      const { selectFields, insertColumns } = this.buildCloneFields(
        props,
        mappedOverrides,
        tableMeta as EntityMetadata<T>,
      );

      // For child tables, prepend the new PK value
      if (tableMeta !== rootMeta && newPk != null) {
        for (const pkName of tableMeta.primaryKeys) {
          const prop = tableMeta.properties[pkName as EntityKey<T>] as EntityProperty;

          for (const fieldName of prop.fieldNames) {
            insertColumns.unshift(fieldName);
            selectFields.unshift(raw('? as ??', [newPk, fieldName]));
          }
        }
      }

      const sourceWhere =
        tableMeta === rootMeta ? where : ((Utils.extractPK(where as any, tableMeta) as FilterQuery<T>) ?? where);

      const abort = pickAbortOptions(options);
      const selectQb = this.createQueryBuilder<T>(
        tableMeta.class as any,
        options.ctx,
        'read',
        options.convertCustomTypes,
        options.loggerContext,
      ).withSchema(this.getSchemaName(tableMeta as EntityMetadata<T>, options));
      selectQb.select(selectFields as any).where(sourceWhere as any);
      selectQb.setAbortOptions(abort);

      const insertQb = this.createQueryBuilder<T>(
        tableMeta.class as any,
        options.ctx,
        'write',
        options.convertCustomTypes,