engine

package

Go to main page

Versions in this module

v0

v0.5.3

Dec 19, 2025

v0.5.2

Dec 19, 2025

v0.5.1

Dec 18, 2025

Changes in this version

+ func RegisterTableFunc(fn TableFunction)

+ type AlterJob struct

+ Enable *bool

+ Name string

+ type CSVTableFunc struct

+ func (f *CSVTableFunc) Execute(ctx context.Context, args []Expr, env ExecEnv, row Row) (*ResultSet, error)

+ func (f *CSVTableFunc) Name() string

+ func (f *CSVTableFunc) ValidateArgs(args []Expr) error

type CTE

+ Recursive bool

+ type CreateJob struct

+ CatchUp bool

+ CronExpr string

+ Enabled bool

+ IntervalMs int64

+ MaxRuntimeMs int64

+ Name string

+ NoOverlap bool

+ RunAt *time.Time

+ SQLText string

+ ScheduleType string

+ Timezone string

+ type DropJob struct

+ Name string

type FromItem

+ TableFunc *TableFuncCall

+ type JSONLinesTableFunc struct

+ func (f *JSONLinesTableFunc) Execute(ctx context.Context, args []Expr, env ExecEnv, row Row) (*ResultSet, error)

+ func (f *JSONLinesTableFunc) Name() string

+ func (f *JSONLinesTableFunc) ValidateArgs(args []Expr) error

+ type JSONTableFunc struct

+ func (f *JSONTableFunc) Execute(ctx context.Context, args []Expr, env ExecEnv, row Row) (*ResultSet, error)

+ func (f *JSONTableFunc) Name() string

+ func (f *JSONTableFunc) ValidateArgs(args []Expr) error

type Select

+ DistinctOn []Expr

+ type TableFuncCall struct

+ Alias string

+ Args []Expr

+ Name string

+ type TableFunction interface

+ Execute func(ctx context.Context, args []Expr, env ExecEnv, row Row) (*ResultSet, error)

+ Name func() string

+ ValidateArgs func(args []Expr) error

+ func GetTableFunc(name string) (TableFunction, bool)

+ type XMLTableFunc struct

+ func (f *XMLTableFunc) Execute(ctx context.Context, args []Expr, env ExecEnv, row Row) (*ResultSet, error)

+ func (f *XMLTableFunc) Name() string

+ func (f *XMLTableFunc) ValidateArgs(args []Expr) error

v0.5.0

Dec 3, 2025

Changes in this version

type FromItem

+ Subquery *Select

type FuncCall

+ Over *OverClause

+ type OverClause struct

+ Frame *WindowFrame

+ OrderBy []OrderItem

+ PartitionBy []Expr

+ type WindowFrame struct

+ EndType string

+ EndValue int

+ Mode string

+ StartType string

+ StartValue int

v0.4.1

Nov 25, 2025

v0.4.0

Nov 25, 2025

Changes in this version

type Insert

+ Rows [][]Expr

v0.3.1

Oct 3, 2025

Changes in this version

+ type ColumnIndex struct

+ func NewColumnIndex(rows []Row, columns []string) *ColumnIndex

+ func (idx *ColumnIndex) GetRows(indices []int) []Row

+ func (idx *ColumnIndex) Lookup(column string, value any) []int

+ type ExpressionCache struct

+ func NewExpressionCache() *ExpressionCache

+ func (ec *ExpressionCache) Clear()

+ func (ec *ExpressionCache) Get(exprStr string, row Row) (any, bool)

+ func (ec *ExpressionCache) Set(exprStr string, row Row, result any)

+ func (ec *ExpressionCache) Stats() (hits, misses int, hitRate float64)

+ type HashJoinOptimizer struct

+ func (h *HashJoinOptimizer) ProcessOptimizedJoin(leftRows, rightRows []Row, condition Expr, joinType OptimizedJoinType) ([]Row, error)

+ type JoinCondition struct

+ IsEquiJoin bool

+ LeftColumn string

+ Operator string

+ RightColumn string

+ type OptimizedJoinType int

+ const OptimizedJoinTypeInner

+ const OptimizedJoinTypeLeft

+ const OptimizedJoinTypeRight

v0.3.0

Oct 1, 2025

Changes in this version

+ type AlterTable struct

+ AddColumn *storage.Column

+ Table string

+ type CaseExpr struct

+ Else Expr

+ Operand Expr

+ Whens []CaseWhen

+ type CaseWhen struct

+ Then Expr

+ When Expr

+ type CreateIndex struct

+ Columns []string

+ IfNotExists bool

+ Name string

+ Table string

+ Unique bool

type CreateTable

+ IfNotExists bool

+ type CreateView struct

+ IfNotExists bool

+ Name string

+ OrReplace bool

+ Select *Select

+ type DropIndex struct

+ IfExists bool

+ Name string

+ Table string

type DropTable

+ IfExists bool

+ type DropView struct

+ IfExists bool

+ Name string

type FuncCall

+ Distinct bool

+ type InExpr struct

+ Expr Expr

+ Negate bool

+ Values []Expr

+ type LikeExpr struct

+ Escape Expr

+ Expr Expr

+ Negate bool

+ Pattern Expr

+ type SubqueryExpr struct

+ Select *Select

v0.2.1

Oct 1, 2025

v0.2.0

Oct 1, 2025

Changes in this version

+ type Binary struct

+ Left Expr

+ Op string

+ Right Expr

+ type CTE struct

+ Name string

+ Select *Select

+ type CompiledQuery struct

+ ParsedAt time.Time

+ SQL string

+ Statement Statement

+ func (cq *CompiledQuery) Execute(ctx context.Context, db *storage.DB, tenant string) (*ResultSet, error)

+ type CreateTable struct

+ AsSelect *Select

+ Cols []storage.Column

+ IsTemp bool

+ Name string

+ type Delete struct

+ Table string

+ Where Expr

+ type DropTable struct

+ Name string

+ type ExecEnv struct

+ type Expr interface

+ type FromItem struct

+ Alias string

+ Table string

+ type FuncCall struct

+ Args []Expr

+ Name string

+ Star bool

+ type Insert struct

+ Cols []string

+ Table string

+ Vals []Expr

+ type IsNull struct

+ Expr Expr

+ Negate bool

+ type JoinClause struct

+ On Expr

+ Right FromItem

+ Type JoinType

+ type JoinType int

+ const JoinInner

+ const JoinLeft

+ const JoinRight

+ type Literal struct

+ Val any

+ type OrderItem struct

+ Col string

+ Desc bool

+ type Parser struct

+ func NewParser(sql string) *Parser

+ func (p *Parser) ParseStatement() (Statement, error)

+ type QueryCache struct

+ func NewQueryCache(maxSize int) *QueryCache

+ func (qc *QueryCache) Clear()

+ func (qc *QueryCache) Compile(sql string) (*CompiledQuery, error)

+ func (qc *QueryCache) MustCompile(sql string) *CompiledQuery

+ func (qc *QueryCache) Size() int

+ func (qc *QueryCache) Stats() map[string]interface{}

+ type ResultSet struct

+ Cols []string

+ Rows []Row

+ func Execute(ctx context.Context, db *storage.DB, tenant string, stmt Statement) (*ResultSet, error)

+ type Row map[string]any

+ type Select struct

+ CTEs []CTE

+ Distinct bool

+ From FromItem

+ GroupBy []VarRef

+ Having Expr

+ Joins []JoinClause

+ Limit *int

+ Offset *int

+ OrderBy []OrderItem

+ Projs []SelectItem

+ Union *UnionClause

+ Where Expr

+ type SelectItem struct

+ Alias string

+ Expr Expr

+ Star bool

+ type Statement interface

+ type Unary struct

+ Expr Expr

+ Op string

+ type UnionClause struct

+ Next *UnionClause

+ Right *Select

+ Type UnionType

+ type UnionType int

+ const Except

+ const Intersect

+ const UnionAll

+ const UnionDistinct

+ type Update struct

+ Sets map[string]Expr

+ Table string

+ Where Expr

+ type VarRef struct

+ Name string

v0.1.3

Sep 29, 2025

v0.1.2

Sep 27, 2025

v0.1.1

Sep 27, 2025

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL