Method buildQuery

packages/db/src/clickhouse/query-builder.ts:387–512

()

  }

  private buildQuery(): string {
    const parts: string[] = [];

    // Add WITH clause if CTEs exist
    if (this._ctes.length > 0) {
      const cteStatements = this._ctes.map((cte) => {
        const queryStr =
          typeof cte.query === 'string' ? cte.query : cte.query.toSQL();
        return `${cte.name} AS (${queryStr})`;
      });
      parts.push(`WITH ${cteStatements.join(', ')}`);
    }

    // SELECT
    if (this._select.length > 0) {
      parts.push(
        'SELECT',
        this._select
          // Important: Expressions are treated as raw SQL; do not run escapeDate()
          // on them, otherwise any embedded date strings get double-escaped
          // (e.g. ''2025-12-16 23:59:59'') which ClickHouse rejects.
          .map((col) =>
            col instanceof Expression ? col.toString() : this.escapeDate(col)
          )
          .join(', ')
      );
    } else {
      parts.push('SELECT *');
    }

    if (this._except.length > 0) {
      parts.push('EXCEPT', `(${this._except.map(this.escapeDate).join(', ')})`);
    }

    // FROM
    if (this._from) {
      if (this._from instanceof Expression) {
        parts.push(`FROM (${this._from.toString()})`);
      } else {
        parts.push(`FROM ${this._from}${this._final ? ' FINAL' : ''}`);
      }

      // Add joins
      this._joins.forEach((join) => {
        const aliasClause = join.alias ? ` ${join.alias} ` : ' ';
        const conditionStr = join.condition ? `ON ${join.condition}` : '';
        parts.push(
          `${join.type} JOIN ${join.table instanceof Query ? `(${join.table.toSQL()})` : join.table instanceof Expression ? `(${join.table.toString()})` : join.table}${aliasClause}${conditionStr}`
        );
      });
      // Add raw joins (e.g. ARRAY JOIN)
      this._rawJoins.forEach((join) => {
        parts.push(join);
      });
    }

    // WHERE
    if (this._where.length > 0) {