Class Query

packages/db/src/clickhouse/query-builder.ts:45–643

}

export class Query<T = any> {
  private _select: (string | Expression)[] = [];
  private _except: string[] = [];
  private _from?: string | Expression;
  private _where: WhereCondition[] = [];
  private _groupBy: string[] = [];
  private _rollup = false;
  private _having: { condition: string; operator: 'AND' | 'OR' }[] = [];
  private _orderBy: {
    column: string;
    direction: 'ASC' | 'DESC';
  }[] = [];
  private _limit?: number;
  private _offset?: number;
  private _final = false;
  private _settings: Record<string, string> = {};
  private _ctes: CTE[] = [];
  private _joins: {
    type: JoinType;
    table: string | Expression | Query;
    condition: string;
    alias?: string;
  }[] = [];
  private _skipNext = false;
  private _rawJoins: string[] = [];
  private _fill?: {
    from: string | Date;
    to: string | Date;
    step: string;
  };
  private _transform?: Record<string, (item: T) => any>;
  private _union?: Query;
  private _dateRegex = /\d{4}-\d{2}-\d{2}([\s:\d.]+)?/g;
  private _dateValueRegex = /^(?:[a-zA-Z]\w*\()?\d{4}-\d{2}-\d{2}(?:[\s:\d.]+)?\)?$/;
  constructor(
    private client: ClickHouseClient,
    private timezone: string
  ) {}

  // Select methods
  select<U>(
    columns: (string | Expression | null | undefined | false)[],
    type: 'merge' | 'replace' = 'replace'
  ): Query<U> {
    if (this._skipNext) {
      return this as unknown as Query<U>;
    }
    if (type === 'merge') {
      this._select = [
        ...this._select,
        ...columns.filter((col): col is string | Expression => Boolean(col)),
      ];
    } else {
      this._select = columns.filter((col): col is string | Expression =>
        Boolean(col)
      );
    }
    return this as unknown as Query<U>;