QueryIR

Defined in: packages/db/src/query/ir.ts:16

Properties#

distinct?#

optional distinct: true;

Defined in: packages/db/src/query/ir.ts:28

fnHaving?#

optional fnHaving: (row) => any[];

Defined in: packages/db/src/query/ir.ts:34

Parameters#

row#

NamespacedRow

Returns#

any

fnSelect()?#

optional fnSelect: (row) => any;

Defined in: packages/db/src/query/ir.ts:32

Parameters#

row#

NamespacedRow

Returns#

any

fnWhere?#

optional fnWhere: (row) => any[];

Defined in: packages/db/src/query/ir.ts:33

Parameters#

row#

NamespacedRow

Returns#

any

from#

from: From;

Defined in: packages/db/src/query/ir.ts:17

groupBy?#

optional groupBy: GroupBy;

Defined in: packages/db/src/query/ir.ts:21

grouping?#

optional grouping: object;

Defined in: packages/db/src/query/ir.ts:23

processGroupBy()#

processGroupBy: (pipeline, groupByClause, valueIdentity, isSourceRef, havingClauses?, selectClause?, fnHavingClauses?, aggregateCollectionId?, mainSource?, sanitizeCallbackRows) => NamespacedAndKeyedStream;

Processes the GROUP BY clause with optional HAVING and SELECT Works with the new $selected structure from early SELECT processing

Parameters#

pipeline#

NamespacedAndKeyedStream

groupByClause#

GroupBy

valueIdentity#

ValueIdentity

isSourceRef#

(ref) => boolean

Whether a ref reads a field of the query's own rows.

havingClauses?#

Where[]

selectClause?#

Select

fnHavingClauses?#

(row) => any[]

aggregateCollectionId?#

string

mainSource?#

string

sanitizeCallbackRows?#

boolean = false

Returns#

NamespacedAndKeyedStream

replaceAggregatesByRefs()#

replaceAggregatesByRefs: (havingExpr, selectClause, resultAlias) => BasicExpression;

Transforms expressions to replace aggregate functions with references to computed values.

For aggregate expressions, finds matching aggregates in the SELECT clause and replaces them with PropRef([resultAlias, alias]) to reference the computed aggregate value.

Ref expressions (table columns and $selected fields) and value expressions are passed through unchanged. Function expressions are recursively transformed.

Parameters#

havingExpr#

The expression to transform (can be aggregate, ref, func, or val)

Aggregate<any> | BasicExpression

selectClause#

Select

The SELECT clause containing aliases and aggregate definitions

resultAlias#

string = ...

The namespace alias for SELECT results (default: '$selected')

Returns#

BasicExpression

A transformed BasicExpression that references computed values instead of raw expressions

having?#

optional having: Where[];

Defined in: packages/db/src/query/ir.ts:24

join?#

optional join: Join;

Defined in: packages/db/src/query/ir.ts:19

limit?#

optional limit: number;

Defined in: packages/db/src/query/ir.ts:26

offset?#

optional offset: number;

Defined in: packages/db/src/query/ir.ts:27

orderBy?#

optional orderBy: OrderBy;

Defined in: packages/db/src/query/ir.ts:25

select?#

optional select: Select;

Defined in: packages/db/src/query/ir.ts:18

singleResult?#

optional singleResult: true;

Defined in: packages/db/src/query/ir.ts:29

where?#

optional where: Where[];

Defined in: packages/db/src/query/ir.ts:20