Method getQueryBase

packages/sql/src/query/QueryBuilder.ts:3386–3457

(processVirtualEntity: boolean)

  }

  private getQueryBase(processVirtualEntity: boolean): NativeQueryBuilder {
    const qb = this.platform.createNativeQueryBuilder().setFlags(this.#state.flags);
    const { subQuery, aliasName, entityName, meta, rawTableName } = this.mainAlias;
    const requiresAlias =
      this.#state.finalized && (this.#state.explicitAlias || this.helper.isTableNameAliasRequired(this.type));
    const alias = requiresAlias ? aliasName : undefined;
    const schema = this.getSchema(this.mainAlias);
    const tableName = rawTableName
      ? rawTableName
      : subQuery instanceof NativeQueryBuilder
        ? subQuery.as(aliasName)
        : subQuery
          ? raw(`(${subQuery.sql}) as ${this.platform.quoteIdentifier(aliasName)}`, subQuery.params)
          : this.helper.getTableName(entityName);
    const joinSchema = this.#state.schema ?? this.em?.schema ?? schema;
    const schemaOverride = this.#state.schema ?? this.em?.schema;

    if (meta.virtual && processVirtualEntity) {
      qb.from(raw(this.fromVirtual(meta)), { indexHint: this.#state.indexHint });
    } else {
      qb.from(tableName, {
        schema: rawTableName ? undefined : schema,
        alias,
        indexHint: this.#state.indexHint,
      });
    }

    switch (this.type) {
      case QueryType.SELECT:
        qb.select(this.prepareFields(this.#state.fields!, 'where', schema));

        if (this.#state.distinctOn) {
          qb.distinctOn(this.prepareFields(this.#state.distinctOn, 'where', schema) as string[]);
        } else if (this.#state.flags.has(QueryFlag.DISTINCT)) {
          qb.distinct();
        }

        this.helper.processJoins(qb, this.#state.joins, joinSchema, schemaOverride);
        break;
      case QueryType.COUNT: {
        const fields = this.#state.fields!.map(f =>
          this.helper.mapper(f as string, this.type, undefined, undefined, schema),
        );
        qb.count(fields, this.#state.flags.has(QueryFlag.DISTINCT));
        this.helper.processJoins(qb, this.#state.joins, joinSchema, schemaOverride);
        break;
      }
      case QueryType.INSERT:
        if (this.#state.insertSubQuery) {
          const columns = this.resolveInsertFromColumns();
          const compiled = this.#state.insertSubQuery.toQuery();
          qb.insertSelect(columns, raw(compiled.sql, compiled.params));
        } else {
          qb.insert(this.#state.data!);
        }

        break;
      case QueryType.UPDATE: