analyzer

package

Go to main page

Versions in this module

v0

v0.18.1

Apr 9, 2024

Changes in this version

type Catalog

+ BinlogPrimaryController binlogreplication.BinlogPrimaryController

+ func (c *Catalog) GetBinlogPrimaryController() binlogreplication.BinlogPrimaryController

+ func (c *Catalog) HasBinlogPrimaryController() bool

+ func (c *Catalog) HasBinlogReplicaController() bool

v0.18.0

Feb 28, 2024

Changes in this version

+ func Schemas(nodes []sql.Node) sql.Schema

type Analyzer

+ EventScheduler sql.EventScheduler

type Catalog

+ BinlogReplicaController binlogreplication.BinlogReplicaController

+ DbProvider sql.DatabaseProvider

+ StatsProvider sql.StatsProvider

+ func (c *Catalog) DataLength(ctx *sql.Context, db, table string) (uint64, error)

+ func (c *Catalog) DropDbStats(ctx *sql.Context, db string, flush bool) error

+ func (c *Catalog) DropStats(ctx *sql.Context, qual sql.StatQualifier, cols []string) error

+ func (c *Catalog) GetBinlogReplicaController() binlogreplication.BinlogReplicaController

+ func (c *Catalog) GetStats(ctx *sql.Context, qual sql.StatQualifier, cols []string) (sql.Statistic, bool)

+ func (c *Catalog) GetTableStats(ctx *sql.Context, db, table string) ([]sql.Statistic, error)

+ func (c *Catalog) IsBinlogReplicaCatalog() bool

+ func (c *Catalog) RefreshTableStats(ctx *sql.Context, table sql.Table, db string) error

+ func (c *Catalog) RowCount(ctx *sql.Context, db, table string) (uint64, error)

+ func (c *Catalog) SetStats(ctx *sql.Context, stats sql.Statistic) error

+ func (c *Catalog) WithTableFunctions(fns ...sql.TableFunction) (sql.TableFunctionProvider, error)

v0.17.0

Aug 23, 2023

v0.16.0

Jun 29, 2023

Changes in this version

+ var DefaultRules_Exp = []Rule

+ var OnceAfterAll_Experimental = []Rule

+ var OnceAfterDefault_Experimental = []Rule

+ var OnceBeforeDefault_Exp = []Rule

type Analyzer

+ Batches_Exp []*Batch

+ func NewDefaultWithVersion(provider sql.DatabaseProvider, version sql.AnalyzerVersion) *Analyzer

+ func (a *Analyzer) LogFn() func(string, ...any)

type Catalog

+ func (c *Catalog) DatabaseTable(ctx *sql.Context, db sql.Database, tableName string) (sql.Table, sql.Database, error)

+ func (c *Catalog) DatabaseTableAsOf(ctx *sql.Context, db sql.Database, tableName string, asOf interface{}) (sql.Table, sql.Database, error)

+ func (c *Catalog) HasDatabase(ctx *sql.Context, db string) bool

v0.15.0

Apr 18, 2023

Changes in this version

+ const MaxBytePrefix

+ func FixFieldIndexesForNode(a *Analyzer, scope *Scope, n sql.Node) (sql.Node, transform.TreeIdentity, error)

type Analyzer

+ BinlogReplicaController binlogreplication.BinlogReplicaController

+ Carder Carder

+ Coster Coster

+ ExecBuilder sql.NodeExecBuilder

+ type Carder interface

+ EstimateCard func(*sql.Context, relExpr, sql.StatsReader) (float64, error)

+ func NewDefaultCarder() Carder

type Catalog

+ InfoSchema sql.Database

+ Provider sql.DatabaseProvider

+ func (c *Catalog) Statistics(ctx *sql.Context) (sql.StatsReadWriter, error)

+ type Coster interface

+ EstimateCost func(*sql.Context, relExpr, sql.StatsReader) (float64, error)

+ func NewDefaultCoster() Coster

+ func NewHashBiasedCoster() Coster

+ func NewInnerBiasedCoster() Coster

+ func NewLookupBiasedCoster() Coster

+ func NewMergeBiasedCoster() Coster

+ type Hint struct

+ Args []string

+ Typ HintType

+ func (h Hint) String() string

+ type HintType uint8

+ const HintTypeAntiJoin

+ const HintTypeHashJoin

+ const HintTypeInnerJoin

+ const HintTypeJoinFixedOrder

+ const HintTypeJoinOrder

+ const HintTypeLookupJoin

+ const HintTypeMergeJoin

+ const HintTypeNoIndexConditionPushDown

+ const HintTypeRightSemiLookupJoin

+ const HintTypeSemiJoin

+ const HintTypeUnknown

+ func (i HintType) String() string

type Memo

+ func (m *Memo) WithJoinOp(op HintType, left, right string)

type RuleSelector

+ func NewFinalizeSubquerySel(sel RuleSelector) RuleSelector

+ func NewFinalizeUnionSel(sel RuleSelector) RuleSelector

+ func NewProcRuleSelector(sel RuleSelector) RuleSelector

type Scope

+ func (s *Scope) EnforcesReadOnly() bool

+ func (s *Scope) OuterRelUnresolved() bool

v0.14.0

Nov 1, 2022

Changes in this version

+ var EmptyJoinOrder = JoinOrderHint

+ var ExprDefs support.GenDefs = []support.MemoDef

type Catalog

+ func (c *Catalog) ExternalStoredProcedure(ctx *sql.Context, name string, numOfParams int) (*sql.ExternalStoredProcedureDetails, error)

+ func (c *Catalog) ExternalStoredProcedures(ctx *sql.Context, name string) ([]sql.ExternalStoredProcedureDetails, error)

+ type ExecBuilder struct

+ func NewExecBuilder() *ExecBuilder

+ type GroupId uint16

+ type JoinOrderHint struct

+ func (j JoinOrderHint) HintType() string

+ func (j JoinOrderHint) IsEmpty() bool

+ func (j JoinOrderHint) String() string

+ type Memo struct

+ func NewMemo(ctx *sql.Context, s *Scope) *Memo

+ func (m *Memo) String() string

+ func (m *Memo) WithJoinOrder(hint JoinOrderHint)

type RuleSelector

+ func NewFinalizeNestedSubquerySel(sel RuleSelector) RuleSelector

+ func NewFinalizeSubqueryExprSelector(sel RuleSelector) RuleSelector

+ func NewResolveSubqueryExprSelector(sel RuleSelector) RuleSelector

+ func NewResolveSubquerySel(sel RuleSelector) RuleSelector

+ func NewSkipPruneRuleSelector(sel RuleSelector) RuleSelector

type Scope

+ func (s *Scope) IsEmpty() bool

+ func (s *Scope) RecursionDepth() int

+ type TableId uint16

v0.12.0

Jun 12, 2022

Changes in this version

+ var PreparedStmtDisabled bool

+ var SingleThreadFeatureFlag = false

+ func ConvertCheckDefToConstraint(ctx *sql.Context, check *sql.CheckDefinition) (*sql.CheckConstraint, error)

+ func DeepCopyNode(node sql.Node) (sql.Node, error)

+ func DefaultRuleSelector(id RuleId) bool

+ func GetTransactionDatabase(ctx *sql.Context, parsed sql.Node) string

+ func SelectAllBatches(string) bool

+ func SetPreparedStmts(v bool)

+ func StripPassthroughNodes(n sql.Node) sql.Node

type Analyzer

+ func (a *Analyzer) AnalyzePrepared(ctx *sql.Context, n sql.Node, scope *Scope) (sql.Node, transform.TreeIdentity, error)

+ func (a *Analyzer) PrepareQuery(ctx *sql.Context, n sql.Node, scope *Scope) (sql.Node, error)

type Batch

+ func (b *Batch) EvalWithSelector(ctx *sql.Context, a *Analyzer, n sql.Node, scope *Scope, sel RuleSelector) (sql.Node, transform.TreeIdentity, error)

+ type BatchSelector func(string) bool

type Catalog

+ MySQLDb *mysql_db.MySQLDb

+ func (c *Catalog) TableFunction(ctx *sql.Context, name string) (sql.TableFunction, error)

type Releaser

+ func (r *Releaser) CheckPrivileges(ctx *sql.Context, opChecker sql.PrivilegedOperationChecker) bool

+ type RoutineTable interface

+ AssignProcedures func(p map[string][]*plan.Procedure) sql.Table

type Rule

+ Id RuleId

+ type RuleId int

+ const AutocommitId

+ const TrackProcessId

+ func (i RuleId) String() string

+ type RuleSelector func(RuleId) bool

v0.11.0

Oct 20, 2021

Changes in this version

+ var ErrAggregationUnsupported = errors.NewKind(...)

+ var ErrReadOnlyDatabase = errors.NewKind("Database %s is read-only.")

+ func NewCatalog(provider sql.DatabaseProvider) sql.Catalog

+ func NewDatabaseProvider(dbs ...sql.Database) sql.DatabaseProvider

+ type Catalog struct

+ func (c *Catalog) AllDatabases() []sql.Database

+ func (c *Catalog) CreateDatabase(ctx *sql.Context, dbName string) error

+ func (c *Catalog) Database(db string) (sql.Database, error)

+ func (c *Catalog) Function(name string) (sql.Function, error)

+ func (c *Catalog) HasDB(db string) bool

+ func (c *Catalog) LockTable(ctx *sql.Context, table string)

+ func (c *Catalog) RegisterFunction(fns ...sql.Function)

+ func (c *Catalog) RemoveDatabase(ctx *sql.Context, dbName string) error

+ func (c *Catalog) Table(ctx *sql.Context, dbName, tableName string) (sql.Table, sql.Database, error)

+ func (c *Catalog) TableAsOf(ctx *sql.Context, dbName, tableName string, asOf interface{}) (sql.Table, sql.Database, error)

+ func (c *Catalog) UnlockTables(ctx *sql.Context, id uint32) error

+ type CatalogTable interface

+ AssignCatalog func(cat sql.Catalog) sql.Table

v0.10.0

Jun 2, 2021

v0.9.0

Apr 2, 2021

Changes in this version

type Analyzer

+ ProcedureCache *ProcedureCache

+ type JoinOrder struct

+ func (j JoinOrder) HintType() string

+ func (j JoinOrder) String() string

+ type ProcedureCache struct

+ IsPopulating bool

+ func NewProcedureCache() *ProcedureCache

+ func (pc *ProcedureCache) AllForDatabase(dbName string) []*plan.Procedure

+ func (pc *ProcedureCache) Get(dbName, procedureName string) *plan.Procedure

+ func (pc *ProcedureCache) Register(dbName string, procedure *plan.Procedure)

+ type QueryHint interface

+ HintType func() string

v0.8.0

Feb 1, 2021

Changes in this version

+ var DefaultRules = []Rule

+ var DefaultValidationRules = []Rule

+ var ErrCaseResultType = errors.NewKind(...)

+ var ErrExplodeInvalidUse = errors.NewKind("using EXPLODE is not supported outside a Project node")

+ var ErrFieldMissing = errors.NewKind("field %q is not on schema")

+ var ErrInAnalysis = errors.NewKind("error in analysis: %s")

+ var ErrIntervalInvalidUse = errors.NewKind(...)

+ var ErrInvalidNodeType = errors.NewKind("%s: invalid node of type: %T")

+ var ErrMaxAnalysisIters = errors.NewKind("exceeded max analysis iterations (%d)")

+ var ErrOrderByColumnIndex = errors.NewKind("unknown column %d in order by clause")

+ var ErrProjectTuple = errors.NewKind("selected field %d should have 1 column, but has %d")

+ var ErrSubqueryFieldIndex = errors.NewKind(...)

+ var ErrSubqueryMultipleColumns = errors.NewKind("subquery expressions can only return a single column")

+ var ErrUnionSchemasDifferentLength = errors.NewKind(...)

+ var ErrUnionSchemasMatch = errors.NewKind(...)

+ var ErrUnknownIndexColumns = errors.NewKind("unknown columns to index for table %q: %s")

+ var ErrValidationGroupBy = errors.NewKind("GroupBy aggregate expression '%v' doesn't appear in the grouping columns")

+ var ErrValidationOrderBy = errors.NewKind("OrderBy does not support aggregation expressions")

+ var ErrValidationResolved = errors.NewKind("plan is not resolved because of node '%T'")

+ var ErrValidationSchemaSource = errors.NewKind("one or more schema sources are empty")

+ var OnceAfterAll = []Rule

+ var OnceAfterDefault = []Rule

+ var OnceBeforeDefault = []Rule

+ var ParallelQueryCounter = discard.NewCounter()

+ func FixFieldIndexes(scope *Scope, schema sql.Schema, exp sql.Expression) (sql.Expression, error)

+ func FixFieldIndexesForExpressions(node sql.Node, scope *Scope) (sql.Node, error)

+ func FixFieldIndexesForTableNode(node sql.Node, scope *Scope) (sql.Node, error)

+ func FixFieldIndexesOnExpressions(scope *Scope, schema sql.Schema, expressions ...sql.Expression) ([]sql.Expression, error)

+ func OrderTriggers(triggers []*plan.CreateTrigger) (beforeTriggers []*plan.CreateTrigger, afterTriggers []*plan.CreateTrigger)

+ type Analyzer struct

+ Batches []*Batch

+ Catalog *sql.Catalog

+ Debug bool

+ Parallelism int

+ Verbose bool

+ func NewDefault(c *sql.Catalog) *Analyzer

+ func (a *Analyzer) Analyze(ctx *sql.Context, n sql.Node, scope *Scope) (sql.Node, error)

+ func (a *Analyzer) Log(msg string, args ...interface{})

+ func (a *Analyzer) LogDiff(prev, next sql.Node)

+ func (a *Analyzer) LogNode(n sql.Node)

+ func (a *Analyzer) PopDebugContext()

+ func (a *Analyzer) PushDebugContext(msg string)

+ type Batch struct

+ Desc string

+ Iterations int

+ Rules []Rule

+ func (b *Batch) Eval(ctx *sql.Context, a *Analyzer, n sql.Node, scope *Scope) (sql.Node, error)

+ type Builder struct

+ func NewBuilder(c *sql.Catalog) *Builder

+ func (ab *Builder) AddPostAnalyzeRule(name string, fn RuleFunc) *Builder

+ func (ab *Builder) AddPostValidationRule(name string, fn RuleFunc) *Builder

+ func (ab *Builder) AddPreAnalyzeRule(name string, fn RuleFunc) *Builder

+ func (ab *Builder) AddPreValidationRule(name string, fn RuleFunc) *Builder

+ func (ab *Builder) Build() *Analyzer

+ func (ab *Builder) RemoveAfterAllRule(name string) *Builder

+ func (ab *Builder) RemoveDefaultRule(name string) *Builder

+ func (ab *Builder) RemoveOnceAfterRule(name string) *Builder

+ func (ab *Builder) RemoveOnceBeforeRule(name string) *Builder

+ func (ab *Builder) RemoveValidationRule(name string) *Builder

+ func (ab *Builder) WithDebug() *Builder

+ func (ab *Builder) WithParallelism(parallelism int) *Builder

+ type ExprAliases map[string]sql.Expression

+ type NameableNode interface

+ type Releaser struct

+ Child sql.Node

+ Release func()

+ func (r *Releaser) Children() []sql.Node

+ func (r *Releaser) Equal(n sql.Node) bool

+ func (r *Releaser) Resolved() bool

+ func (r *Releaser) RowIter(ctx *sql.Context, row sql.Row) (sql.RowIter, error)

+ func (r *Releaser) Schema() sql.Schema

+ func (r *Releaser) String() string

+ func (r *Releaser) WithChildren(children ...sql.Node) (sql.Node, error)

+ type Rule struct

+ Apply RuleFunc

+ Name string

+ type RuleFunc func(*sql.Context, *Analyzer, sql.Node, *Scope) (sql.Node, error)

+ type Scope struct

+ func (s *Scope) InnerToOuter() []sql.Node

+ func (s *Scope) MemoNodes() []sql.Node

+ func (s *Scope) OuterToInner() []sql.Node

+ func (s *Scope) Schema() sql.Schema

+ type TableAliases map[string]sql.Nameable

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