operators

Oct 29, 2024 GO-2024-3306

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

Changes in this version

type Aggr

+ PushedDown bool

type Aggregator

+ Truncate bool

+ type Column struct

+ Name string

+ Table string

+ func (c *Column) UnmarshalJSON(data []byte) error

+ func (c Column) MarshalJSON() ([]byte, error)

+ func (c Column) String() string

+ type ColumnUse struct

+ Column Column

+ Uses sqlparser.ComparisonExprOperator

+ func (cu *ColumnUse) UnmarshalJSON(data []byte) error

+ func (cu ColumnUse) MarshalJSON() ([]byte, error)

+ func (cu ColumnUse) String() string

type Distinct

+ ResultColumns int

type Filter

+ ResultColumns int

type Horizon

+ Truncate bool

+ type PercentBasedMirror struct

+ Percent float32

+ func NewPercentBasedMirror(percent float32, operator, target Operator) *PercentBasedMirror

+ func (b *PercentBasedMirror) Inputs() []Operator

+ func (b *PercentBasedMirror) SetInputs(operators []Operator)

+ func (m *PercentBasedMirror) AddColumn(*plancontext.PlanningContext, bool, bool, *sqlparser.AliasedExpr) int

+ func (m *PercentBasedMirror) AddPredicate(*plancontext.PlanningContext, sqlparser.Expr) Operator

+ func (m *PercentBasedMirror) AddWSColumn(*plancontext.PlanningContext, int, bool) int

+ func (m *PercentBasedMirror) Clone(inputs []Operator) Operator

+ func (m *PercentBasedMirror) FindCol(ctx *plancontext.PlanningContext, expr sqlparser.Expr, underRoute bool) int

+ func (m *PercentBasedMirror) GetColumns(ctx *plancontext.PlanningContext) []*sqlparser.AliasedExpr

+ func (m *PercentBasedMirror) GetOrdering(ctx *plancontext.PlanningContext) []OrderBy

+ func (m *PercentBasedMirror) GetSelectExprs(ctx *plancontext.PlanningContext) sqlparser.SelectExprs

+ func (m *PercentBasedMirror) Operator() Operator

+ func (m *PercentBasedMirror) ShortDescription() string

+ func (m *PercentBasedMirror) Target() Operator

+ type RecurseCTE struct

+ Def *semantics.CTE

+ Distinct bool

+ Horizon *Horizon

+ LeftID semantics.TableSet

+ MyTableInfo *semantics.CTETable

+ OuterID semantics.TableSet

+ Predicates []*plancontext.RecurseExpression

+ Projections []*plancontext.RecurseExpression

+ Vars map[string]int

+ func (b *RecurseCTE) Inputs() []Operator

+ func (b *RecurseCTE) SetInputs(operators []Operator)

+ func (r *RecurseCTE) AddColumn(ctx *plancontext.PlanningContext, _, _ bool, expr *sqlparser.AliasedExpr) int

+ func (r *RecurseCTE) AddPredicate(_ *plancontext.PlanningContext, e sqlparser.Expr) Operator

+ func (r *RecurseCTE) AddWSColumn(ctx *plancontext.PlanningContext, offset int, underRoute bool) int

+ func (r *RecurseCTE) Clone(inputs []Operator) Operator

+ func (r *RecurseCTE) FindCol(ctx *plancontext.PlanningContext, expr sqlparser.Expr, underRoute bool) int

+ func (r *RecurseCTE) GetColumns(ctx *plancontext.PlanningContext) []*sqlparser.AliasedExpr

+ func (r *RecurseCTE) GetOrdering(*plancontext.PlanningContext) []OrderBy

+ func (r *RecurseCTE) GetSelectExprs(ctx *plancontext.PlanningContext) sqlparser.SelectExprs

+ func (r *RecurseCTE) Seed() Operator

+ func (r *RecurseCTE) ShortDescription() string

+ func (r *RecurseCTE) Term() Operator

+ type VExplainKeys struct

+ FilterColumns []ColumnUse

+ GroupingColumns []Column

+ JoinColumns []ColumnUse

+ SelectColumns []Column

+ StatementType string

+ TableName []string

+ func GetVExplainKeys(ctx *plancontext.PlanningContext, stmt sqlparser.Statement) (result VExplainKeys)

Nov 6, 2024 GO-2024-3306

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

Sep 11, 2024 GO-2024-3306

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

Jul 23, 2024 GO-2024-3306

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

Jun 27, 2024 GO-2024-3306

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

Changes in this version

+ func ContainsAggr(ctx *plancontext.PlanningContext, e sqlparser.SQLNode) (hasAggr bool)

+ func FromLeftOffset(i int) int

+ func FromRightOffset(i int) int

+ func IsAggr(ctx *plancontext.PlanningContext, e sqlparser.SQLNode) bool

+ func IsOuter(outer JoinOp) bool

+ func ToLeftOffset(i int) int

+ func ToRightOffset(i int) int

type Aggregator

+ WithRollup bool

+ func (a *Aggregator) AddWSColumn(ctx *plancontext.PlanningContext, offset int, underRoute bool) int

type ApplyJoin

+ JoinType sqlparser.JoinType

+ func (aj *ApplyJoin) AddWSColumn(ctx *plancontext.PlanningContext, offset int, underRoute bool) int

+ type DMLCommon struct

+ Ignore sqlparser.Ignore

+ OwnedVindexQuery *sqlparser.Select

+ Source Operator

+ Target TargetTable

+ type DMLWithInput struct

+ BvList []map[string]int

+ DML []Operator

+ Offsets [][]int

+ Source Operator

+ func (DMLWithInput) AddColumn(*plancontext.PlanningContext, bool, bool, *sqlparser.AliasedExpr) int

+ func (DMLWithInput) AddPredicate(*plancontext.PlanningContext, sqlparser.Expr) Operator

+ func (DMLWithInput) AddWSColumn(ctx *plancontext.PlanningContext, offset int, underRoute bool) int

+ func (DMLWithInput) FindCol(*plancontext.PlanningContext, sqlparser.Expr, bool) int

+ func (DMLWithInput) GetColumns(*plancontext.PlanningContext) []*sqlparser.AliasedExpr

+ func (DMLWithInput) GetSelectExprs(*plancontext.PlanningContext) sqlparser.SelectExprs

+ func (d *DMLWithInput) Clone(inputs []Operator) Operator

+ func (d *DMLWithInput) GetOrdering(ctx *plancontext.PlanningContext) []OrderBy

+ func (d *DMLWithInput) Inputs() []Operator

+ func (d *DMLWithInput) SetInputs(inputs []Operator)

+ func (d *DMLWithInput) ShortDescription() string

type Delete

+ func (Delete) AddWSColumn(ctx *plancontext.PlanningContext, offset int, underRoute bool) int

type Distinct

+ func (d *Distinct) AddWSColumn(ctx *plancontext.PlanningContext, offset int, underRoute bool) int

type Filter

+ func (f *Filter) AddWSColumn(ctx *plancontext.PlanningContext, offset int, underRoute bool) int

type FkCascade

+ func (FkCascade) AddWSColumn(ctx *plancontext.PlanningContext, offset int, underRoute bool) int

type FkChild

+ func (FkChild) AddWSColumn(ctx *plancontext.PlanningContext, offset int, underRoute bool) int

type FkVerify

+ func (FkVerify) AddWSColumn(ctx *plancontext.PlanningContext, offset int, underRoute bool) int

+ type FromStatement interface

+ GetFrom func() []sqlparser.TableExpr

+ GetWherePredicate func() sqlparser.Expr

+ SetFrom func([]sqlparser.TableExpr)

+ SetWherePredicate func(sqlparser.Expr)

type HashJoin

+ func (hj *HashJoin) AddWSColumn(ctx *plancontext.PlanningContext, offset int, underRoute bool) int

type Horizon

+ func (h *Horizon) AddWSColumn(ctx *plancontext.PlanningContext, offset int, underRoute bool) int

type Insert

+ func (Insert) AddWSColumn(ctx *plancontext.PlanningContext, offset int, underRoute bool) int

type InsertSelection

+ func (InsertSelection) AddWSColumn(ctx *plancontext.PlanningContext, offset int, underRoute bool) int

type Join

+ JoinType sqlparser.JoinType

+ func (Join) AddWSColumn(ctx *plancontext.PlanningContext, offset int, underRoute bool) int

type Limit

+ Top bool

+ func (l *Limit) AddWSColumn(ctx *plancontext.PlanningContext, offset int, underRoute bool) int

type LockAndComment

+ func (l *LockAndComment) AddWSColumn(ctx *plancontext.PlanningContext, offset int, underRoute bool) int

type Operator

+ AddWSColumn func(ctx *plancontext.PlanningContext, offset int, underRoute bool) int

type Ordering

+ func (o *Ordering) AddWSColumn(ctx *plancontext.PlanningContext, offset int, underRoute bool) int

type Projection

+ func (p *Projection) AddWSColumn(ctx *plancontext.PlanningContext, offset int, underRoute bool) int

type QueryGraph

+ func (QueryGraph) AddWSColumn(ctx *plancontext.PlanningContext, offset int, underRoute bool) int

type QueryProjection

+ WithRollup bool

type Route

+ func (r *Route) AddWSColumn(ctx *plancontext.PlanningContext, offset int, _ bool) int

type Sequential

+ func (Sequential) AddWSColumn(ctx *plancontext.PlanningContext, offset int, underRoute bool) int

type SubQuery

+ func (sq *SubQuery) AddWSColumn(ctx *plancontext.PlanningContext, offset int, underRoute bool) int

type SubQueryContainer

+ func (sqc *SubQueryContainer) AddWSColumn(ctx *plancontext.PlanningContext, offset int, underRoute bool) int

type Table

+ func (*Table) AddWSColumn(*plancontext.PlanningContext, int, bool) int

type Union

+ func (u *Union) AddWSColumn(ctx *plancontext.PlanningContext, offset int, underRoute bool) int

type Update

+ VerifyAll bool

+ func (Update) AddWSColumn(ctx *plancontext.PlanningContext, offset int, underRoute bool) int

type Upsert

+ func (Upsert) AddWSColumn(ctx *plancontext.PlanningContext, offset int, underRoute bool) int

type Vindex

+ func (*Vindex) AddWSColumn(*plancontext.PlanningContext, int, bool) int

Nov 6, 2024 GO-2024-3306

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

Sep 11, 2024 GO-2024-3306

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

Jul 23, 2024 GO-2024-3306

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

Changes in this version

type Aggregator

+ func (a *Aggregator) SplitAggregatorBelowOperators(ctx *plancontext.PlanningContext, input []Operator) *Aggregator

type SubQuery

+ IsArgument bool

May 8, 2024 GO-2024-3306

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

Apr 4, 2024 GO-2024-2826 +1 more

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

Apr 4, 2024 GO-2024-2826 +1 more

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

Mar 14, 2024 GO-2024-2826 +1 more

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

Mar 6, 2024 GO-2024-2826 +1 more

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

Changes in this version

+ const Left

+ const Right

+ const Unknown

+ var DebugOperatorTree = false

+ func EnableDebugPrinting() (reset func())

+ func PanicHandler(err *error)

+ func Swap(parent, child Operator, message string) (Operator, *ApplyResult)

+ func ToTree(op Operator) string

+ func Visit(root Operator, visitor func(Operator) error) error

+ type ApplyResult struct

+ Transformations []Rewrite

+ var NoRewrite *ApplyResult = nil

+ func Rewrote(message string) *ApplyResult

+ func (ar *ApplyResult) Changed() bool

+ func (ar *ApplyResult) Merge(other *ApplyResult) *ApplyResult

+ type Comparison struct

+ LHS sqlparser.Expr

+ RHS sqlparser.Expr

+ func (c Comparison) String() string

type Delete

+ Ignore bool

+ Source Operator

+ Target TargetTable

+ type DeleteWithInput struct

+ Delete Operator

+ Offsets []int

+ Source Operator

+ func (DeleteWithInput) AddColumn(*plancontext.PlanningContext, bool, bool, *sqlparser.AliasedExpr) int

+ func (DeleteWithInput) AddPredicate(*plancontext.PlanningContext, sqlparser.Expr) Operator

+ func (DeleteWithInput) FindCol(*plancontext.PlanningContext, sqlparser.Expr, bool) int

+ func (DeleteWithInput) GetColumns(*plancontext.PlanningContext) []*sqlparser.AliasedExpr

+ func (DeleteWithInput) GetSelectExprs(*plancontext.PlanningContext) sqlparser.SelectExprs

+ func (d *DeleteWithInput) Clone(inputs []Operator) Operator

+ func (d *DeleteWithInput) GetOrdering(ctx *plancontext.PlanningContext) []OrderBy

+ func (d *DeleteWithInput) Inputs() []Operator

+ func (d *DeleteWithInput) SetInputs(inputs []Operator)

+ func (d *DeleteWithInput) ShortDescription() string

type FkChild

+ NonLiteralInfo []engine.NonLiteralUpdateInfo

+ type HashJoin struct

+ ColumnOffsets []int

+ JoinComparisons []Comparison

+ LHS Operator

+ LHSKeys []int

+ LeftJoin bool

+ RHS Operator

+ RHSKeys []int

+ func NewHashJoin(lhs, rhs Operator, outerJoin bool) *HashJoin

+ func (hj *HashJoin) AddColumn(ctx *plancontext.PlanningContext, reuseExisting bool, addToGroupBy bool, ...) int

+ func (hj *HashJoin) AddJoinPredicate(ctx *plancontext.PlanningContext, expr sqlparser.Expr)

+ func (hj *HashJoin) AddPredicate(ctx *plancontext.PlanningContext, expr sqlparser.Expr) Operator

+ func (hj *HashJoin) Clone(inputs []Operator) Operator

+ func (hj *HashJoin) FindCol(ctx *plancontext.PlanningContext, expr sqlparser.Expr, _ bool) int

+ func (hj *HashJoin) GetColumns(*plancontext.PlanningContext) []*sqlparser.AliasedExpr

+ func (hj *HashJoin) GetLHS() Operator

+ func (hj *HashJoin) GetOrdering(ctx *plancontext.PlanningContext) []OrderBy

+ func (hj *HashJoin) GetRHS() Operator

+ func (hj *HashJoin) GetSelectExprs(ctx *plancontext.PlanningContext) sqlparser.SelectExprs

+ func (hj *HashJoin) Inputs() []Operator

+ func (hj *HashJoin) IsInner() bool

+ func (hj *HashJoin) JoinPredicate() sqlparser.Expr

+ func (hj *HashJoin) MakeInner()

+ func (hj *HashJoin) SetInputs(operators []Operator)

+ func (hj *HashJoin) SetLHS(op Operator)

+ func (hj *HashJoin) SetRHS(op Operator)

+ func (hj *HashJoin) ShortDescription() string

+ type InsertSelection struct

+ ForceNonStreaming bool

+ Insert Operator

+ Select Operator

+ func (InsertSelection) AddColumn(*plancontext.PlanningContext, bool, bool, *sqlparser.AliasedExpr) int

+ func (InsertSelection) AddPredicate(*plancontext.PlanningContext, sqlparser.Expr) Operator

+ func (InsertSelection) FindCol(*plancontext.PlanningContext, sqlparser.Expr, bool) int

+ func (InsertSelection) GetColumns(*plancontext.PlanningContext) []*sqlparser.AliasedExpr

+ func (InsertSelection) GetSelectExprs(*plancontext.PlanningContext) sqlparser.SelectExprs

+ func (is *InsertSelection) Clone(inputs []Operator) Operator

+ func (is *InsertSelection) GetOrdering(*plancontext.PlanningContext) []OrderBy

+ func (is *InsertSelection) Inputs() []Operator

+ func (is *InsertSelection) SetInputs(inputs []Operator)

+ func (is *InsertSelection) ShortDescription() string

+ type Operator interface

+ AddColumn func(ctx *plancontext.PlanningContext, reuseExisting bool, addToGroupBy bool, ...) int

+ AddPredicate func(ctx *plancontext.PlanningContext, expr sqlparser.Expr) Operator

+ Clone func(inputs []Operator) Operator

+ FindCol func(ctx *plancontext.PlanningContext, expr sqlparser.Expr, underRoute bool) int

+ GetColumns func(ctx *plancontext.PlanningContext) []*sqlparser.AliasedExpr

+ GetOrdering func(ctx *plancontext.PlanningContext) []OrderBy

+ GetSelectExprs func(ctx *plancontext.PlanningContext) sqlparser.SelectExprs

+ Inputs func() []Operator

+ SetInputs func([]Operator)

+ ShortDescription func() string

+ func BottomUp(root Operator, resolveID func(Operator) semantics.TableSet, visit VisitF, ...) Operator

+ func FixedPointBottomUp(root Operator, resolveID func(Operator) semantics.TableSet, visit VisitF, ...) (op Operator)

+ func TopDown(root Operator, resolveID func(Operator) semantics.TableSet, visit VisitF, ...) Operator

type OrderBy

+ SimplifiedExpr sqlparser.Expr

+ func (ob OrderBy) Map(mappingFunc func(sqlparser.Expr) sqlparser.Expr) OrderBy

+ type Rewrite struct

+ Message string

type Route

+ func (r *Route) IsSingleShardOrByDestination() bool

+ type Sequential struct

+ Sources []Operator

+ func (Sequential) AddColumn(*plancontext.PlanningContext, bool, bool, *sqlparser.AliasedExpr) int

+ func (Sequential) AddPredicate(*plancontext.PlanningContext, sqlparser.Expr) Operator

+ func (Sequential) FindCol(*plancontext.PlanningContext, sqlparser.Expr, bool) int

+ func (Sequential) GetColumns(*plancontext.PlanningContext) []*sqlparser.AliasedExpr

+ func (Sequential) GetSelectExprs(*plancontext.PlanningContext) sqlparser.SelectExprs

+ func (s *Sequential) Clone(inputs []Operator) Operator

+ func (s *Sequential) GetOrdering(*plancontext.PlanningContext) []OrderBy

+ func (s *Sequential) Inputs() []Operator

+ func (s *Sequential) SetInputs(ops []Operator)

+ func (s *Sequential) ShortDescription() string

+ type ShouldVisit func(Operator) VisitRule

+ type TargetTable struct

+ ID semantics.TableSet

+ Name sqlparser.TableName

+ VTable *vindexes.Table

+ type Upsert struct

+ Sources []UpsertSource

+ func (Upsert) AddColumn(*plancontext.PlanningContext, bool, bool, *sqlparser.AliasedExpr) int

+ func (Upsert) AddPredicate(*plancontext.PlanningContext, sqlparser.Expr) Operator

+ func (Upsert) FindCol(*plancontext.PlanningContext, sqlparser.Expr, bool) int

+ func (Upsert) GetColumns(*plancontext.PlanningContext) []*sqlparser.AliasedExpr

+ func (Upsert) GetSelectExprs(*plancontext.PlanningContext) sqlparser.SelectExprs

+ func (u *Upsert) Clone(inputs []Operator) Operator

+ func (u *Upsert) GetOrdering(ctx *plancontext.PlanningContext) []OrderBy

+ func (u *Upsert) Inputs() []Operator

+ func (u *Upsert) SetInputs(inputs []Operator)

+ func (u *Upsert) ShortDescription() string

+ type UpsertSource struct

+ Insert Operator

+ Update Operator

+ type VisitF func(op Operator, lhsTables semantics.TableSet, isRoot bool) (Operator, *ApplyResult)

+ type VisitRule bool

+ const SkipChildren

+ const VisitChildren

Feb 7, 2024 GO-2024-3306

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

Nov 6, 2024 GO-2024-3306

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

Changes in this version

type FkCascade

+ SSemTable *semantics.SemTable

type FkChild

+ ST *semantics.SemTable

type JoinColumn

+ func (jc JoinColumn) String() string

type VerifyOp

+ ST *semantics.SemTable

Sep 11, 2024 GO-2024-3306

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

Jul 23, 2024 GO-2024-3306

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

May 8, 2024 GO-2024-3306

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

Apr 4, 2024 GO-2024-2826 +1 more

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

Mar 14, 2024 GO-2024-2826 +1 more

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

Changes in this version

type Aggr

+ SubQueryExpression []*SubQuery

Dec 20, 2023 GO-2024-2826 +1 more

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

Nov 22, 2023 GO-2024-2826 +1 more

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

Nov 6, 2023 GO-2024-2826 +1 more

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

Changes in this version

type Aggr

+ func (aggr Aggr) NeedsWeightString(ctx *plancontext.PlanningContext) bool

type Aggregator

+ DT *DerivedTable

+ DistinctExpr sqlparser.Expr

+ func (a *Aggregator) FindCol(ctx *plancontext.PlanningContext, in sqlparser.Expr, _ bool) (int, error)

+ func (a *Aggregator) GetSelectExprs(ctx *plancontext.PlanningContext) (sqlparser.SelectExprs, error)

+ func (a *Aggregator) SplitAggregatorBelowRoute(input []ops.Operator) *Aggregator

+ type AliasedProjections []*ProjExpr

+ func (ap AliasedProjections) AddColumn(col *sqlparser.AliasedExpr) (ProjCols, int, error)

+ func (ap AliasedProjections) GetColumns() ([]*sqlparser.AliasedExpr, error)

+ func (ap AliasedProjections) GetSelectExprs() sqlparser.SelectExprs

type ApplyJoin

+ ExtraLHSVars []BindVarExpr

+ JoinColumns []JoinColumn

+ func (a *ApplyJoin) LHSColumnsNeeded(ctx *plancontext.PlanningContext) (needed sqlparser.Exprs)

+ func (aj *ApplyJoin) FindCol(ctx *plancontext.PlanningContext, expr sqlparser.Expr, _ bool) (int, error)

+ func (aj *ApplyJoin) GetSelectExprs(ctx *plancontext.PlanningContext) (sqlparser.SelectExprs, error)

+ type BindVarExpr struct

+ Expr sqlparser.Expr

+ Name string

+ func (bve BindVarExpr) String() string

type Delete

+ func (Delete) FindCol(*plancontext.PlanningContext, sqlparser.Expr, bool) (int, error)

+ func (Delete) GetSelectExprs(*plancontext.PlanningContext) (sqlparser.SelectExprs, error)

+ func (d *Delete) Statement() sqlparser.Statement

+ type DerivedTable struct

+ Alias string

+ Columns sqlparser.Columns

+ TableID semantics.TableSet

+ func (dt *DerivedTable) RewriteExpression(ctx *plancontext.PlanningContext, expr sqlparser.Expr) (sqlparser.Expr, error)

+ func (dt *DerivedTable) String() string

type Distinct

+ PushedPerformance bool

+ Required bool

+ func (d *Distinct) FindCol(ctx *plancontext.PlanningContext, expr sqlparser.Expr, underRoute bool) (int, error)

+ func (d *Distinct) GetSelectExprs(ctx *plancontext.PlanningContext) (sqlparser.SelectExprs, error)

+ type EvalEngine struct

+ EExpr evalengine.Expr

+ type ExprInfo interface

type Filter

+ PredicateWithOffsets evalengine.Expr

+ Truncate int

+ func (f *Filter) FindCol(ctx *plancontext.PlanningContext, expr sqlparser.Expr, underRoute bool) (int, error)

+ func (f *Filter) GetSelectExprs(ctx *plancontext.PlanningContext) (sqlparser.SelectExprs, error)

+ type FkCascade struct

+ Children []*FkChild

+ Parent ops.Operator

+ Selection ops.Operator

+ func (FkCascade) AddColumn(*plancontext.PlanningContext, bool, bool, *sqlparser.AliasedExpr) (int, error)

+ func (FkCascade) AddPredicate(*plancontext.PlanningContext, sqlparser.Expr) (ops.Operator, error)

+ func (FkCascade) FindCol(*plancontext.PlanningContext, sqlparser.Expr, bool) (int, error)

+ func (FkCascade) GetColumns(*plancontext.PlanningContext) ([]*sqlparser.AliasedExpr, error)

+ func (FkCascade) GetSelectExprs(*plancontext.PlanningContext) (sqlparser.SelectExprs, error)

+ func (fkc *FkCascade) Clone(inputs []ops.Operator) ops.Operator

+ func (fkc *FkCascade) GetOrdering() ([]ops.OrderBy, error)

+ func (fkc *FkCascade) Inputs() []ops.Operator

+ func (fkc *FkCascade) SetInputs(operators []ops.Operator)

+ func (fkc *FkCascade) ShortDescription() string

+ type FkChild struct

+ BVName string

+ Cols []int

+ Op ops.Operator

+ func (FkChild) AddColumn(*plancontext.PlanningContext, bool, bool, *sqlparser.AliasedExpr) (int, error)

+ func (FkChild) AddPredicate(*plancontext.PlanningContext, sqlparser.Expr) (ops.Operator, error)

+ func (FkChild) FindCol(*plancontext.PlanningContext, sqlparser.Expr, bool) (int, error)

+ func (FkChild) GetColumns(*plancontext.PlanningContext) ([]*sqlparser.AliasedExpr, error)

+ func (FkChild) GetSelectExprs(*plancontext.PlanningContext) (sqlparser.SelectExprs, error)

+ type FkVerify struct

+ Input ops.Operator

+ Verify []*VerifyOp

+ func (FkVerify) AddColumn(*plancontext.PlanningContext, bool, bool, *sqlparser.AliasedExpr) (int, error)

+ func (FkVerify) AddPredicate(*plancontext.PlanningContext, sqlparser.Expr) (ops.Operator, error)

+ func (FkVerify) FindCol(*plancontext.PlanningContext, sqlparser.Expr, bool) (int, error)

+ func (FkVerify) GetColumns(*plancontext.PlanningContext) ([]*sqlparser.AliasedExpr, error)

+ func (FkVerify) GetSelectExprs(*plancontext.PlanningContext) (sqlparser.SelectExprs, error)

+ func (fkv *FkVerify) Clone(inputs []ops.Operator) ops.Operator

+ func (fkv *FkVerify) GetOrdering() ([]ops.OrderBy, error)

+ func (fkv *FkVerify) Inputs() []ops.Operator

+ func (fkv *FkVerify) SetInputs(operators []ops.Operator)

+ func (fkv *FkVerify) ShortDescription() string

type Horizon

+ Alias string

+ ColumnAliases sqlparser.Columns

+ Columns []*sqlparser.ColName

+ ColumnsOffset []int

+ Query sqlparser.SelectStatement

+ TableId *semantics.TableSet

+ func (h *Horizon) FindCol(ctx *plancontext.PlanningContext, expr sqlparser.Expr, _ bool) (int, error)

+ func (h *Horizon) GetSelectExprs(*plancontext.PlanningContext) (sqlparser.SelectExprs, error)

+ func (h *Horizon) IsDerived() bool

+ func (h *Horizon) IsMergeable(ctx *plancontext.PlanningContext) bool

type Insert

+ func (Insert) FindCol(*plancontext.PlanningContext, sqlparser.Expr, bool) (int, error)

+ func (Insert) GetSelectExprs(*plancontext.PlanningContext) (sqlparser.SelectExprs, error)

+ func (i *Insert) Statement() sqlparser.Statement

type Join

+ func (Join) FindCol(*plancontext.PlanningContext, sqlparser.Expr, bool) (int, error)

+ func (Join) GetSelectExprs(*plancontext.PlanningContext) (sqlparser.SelectExprs, error)

type Limit

+ func (l *Limit) FindCol(ctx *plancontext.PlanningContext, expr sqlparser.Expr, underRoute bool) (int, error)

+ func (l *Limit) GetSelectExprs(ctx *plancontext.PlanningContext) (sqlparser.SelectExprs, error)

+ type LockAndComment struct

+ Comments *sqlparser.ParsedComments

+ Lock sqlparser.Lock

+ Source ops.Operator

+ func (l *LockAndComment) AddColumn(ctx *plancontext.PlanningContext, reuseExisting bool, addToGroupBy bool, ...) (int, error)

+ func (l *LockAndComment) AddPredicate(ctx *plancontext.PlanningContext, expr sqlparser.Expr) (ops.Operator, error)

+ func (l *LockAndComment) Clone(inputs []ops.Operator) ops.Operator

+ func (l *LockAndComment) FindCol(ctx *plancontext.PlanningContext, expr sqlparser.Expr, underRoute bool) (int, error)

+ func (l *LockAndComment) GetColumns(ctx *plancontext.PlanningContext) ([]*sqlparser.AliasedExpr, error)

+ func (l *LockAndComment) GetOrdering() ([]ops.OrderBy, error)

+ func (l *LockAndComment) GetSelectExprs(ctx *plancontext.PlanningContext) (sqlparser.SelectExprs, error)

+ func (l *LockAndComment) Inputs() []ops.Operator

+ func (l *LockAndComment) SetInputs(operators []ops.Operator)

+ func (l *LockAndComment) ShortDescription() string

+ type OpWithAST interface

+ Statement func() sqlparser.Statement

type Ordering

+ func (o *Ordering) FindCol(ctx *plancontext.PlanningContext, expr sqlparser.Expr, underRoute bool) (int, error)

+ func (o *Ordering) GetSelectExprs(ctx *plancontext.PlanningContext) (sqlparser.SelectExprs, error)

+ type Phase int

+ const DONE

+ func (p Phase) String() string

+ type ProjCols interface

+ AddColumn func(*sqlparser.AliasedExpr) (ProjCols, int, error)

+ GetColumns func() ([]*sqlparser.AliasedExpr, error)

+ GetSelectExprs func() sqlparser.SelectExprs

type ProjExpr

+ ColExpr sqlparser.Expr

+ EvalExpr sqlparser.Expr

+ Info ExprInfo

+ Original *sqlparser.AliasedExpr

+ func (pe *ProjExpr) String() string

type Projection

+ DT *DerivedTable

+ func (p *Projection) FindCol(ctx *plancontext.PlanningContext, expr sqlparser.Expr, underRoute bool) (int, error)

+ func (p *Projection) GetAliasedProjections() (AliasedProjections, error)

+ func (p *Projection) GetSelectExprs(*plancontext.PlanningContext) (sqlparser.SelectExprs, error)

type QueryGraph

+ func (QueryGraph) FindCol(*plancontext.PlanningContext, sqlparser.Expr, bool) (int, error)

+ func (QueryGraph) GetSelectExprs(*plancontext.PlanningContext) (sqlparser.SelectExprs, error)

type QueryProjection

+ CanPushSorting bool

+ func CreateQPFromSelectStatement(ctx *plancontext.PlanningContext, stmt sqlparser.SelectStatement) (*QueryProjection, error)

type Route

+ Comments *sqlparser.ParsedComments

+ Lock sqlparser.Lock

+ func (r *Route) FindCol(ctx *plancontext.PlanningContext, expr sqlparser.Expr, _ bool) (int, error)

+ func (r *Route) GetSelectExprs(ctx *plancontext.PlanningContext) (sqlparser.SelectExprs, error)

+ type SetExpr struct

+ Expr *ProjExpr

+ Name *sqlparser.ColName

+ func (se SetExpr) String() string

+ type StarProjections sqlparser.SelectExprs

+ func (sp StarProjections) AddColumn(*sqlparser.AliasedExpr) (ProjCols, int, error)

+ func (sp StarProjections) GetColumns() ([]*sqlparser.AliasedExpr, error)

+ func (sp StarProjections) GetSelectExprs() sqlparser.SelectExprs

type SubQuery

+ ArgName string

+ FilterType opcode.PulloutOpcode

+ HasValuesName string

+ IsProjection bool

+ JoinColumns []JoinColumn

+ Original sqlparser.Expr

+ OuterPredicate sqlparser.Expr

+ Predicates sqlparser.Exprs

+ Subquery ops.Operator

+ SubqueryValueName string

+ TopLevel bool

+ Vars map[string]int

+ func (sq *SubQuery) FindCol(ctx *plancontext.PlanningContext, expr sqlparser.Expr, underRoute bool) (int, error)

+ func (sq *SubQuery) GetJoinColumns(ctx *plancontext.PlanningContext, outer ops.Operator) ([]JoinColumn, error)

+ func (sq *SubQuery) GetMergePredicates() []sqlparser.Expr

+ func (sq *SubQuery) GetSelectExprs(ctx *plancontext.PlanningContext) (sqlparser.SelectExprs, error)

+ func (sq *SubQuery) OuterExpressionsNeeded(ctx *plancontext.PlanningContext, outer ops.Operator) (result []*sqlparser.ColName, err error)

+ type SubQueryBuilder struct

+ Inner []*SubQuery

+ type SubQueryContainer struct

+ Inner []*SubQuery

+ Outer ops.Operator

+ func (sqc *SubQueryContainer) AddColumn(ctx *plancontext.PlanningContext, reuseExisting bool, addToGroupBy bool, ...) (int, error)

+ func (sqc *SubQueryContainer) AddPredicate(ctx *plancontext.PlanningContext, expr sqlparser.Expr) (ops.Operator, error)

+ func (sqc *SubQueryContainer) Clone(inputs []ops.Operator) ops.Operator

+ func (sqc *SubQueryContainer) FindCol(ctx *plancontext.PlanningContext, expr sqlparser.Expr, underRoute bool) (int, error)

+ func (sqc *SubQueryContainer) GetColumns(ctx *plancontext.PlanningContext) ([]*sqlparser.AliasedExpr, error)

+ func (sqc *SubQueryContainer) GetOrdering() ([]ops.OrderBy, error)

+ func (sqc *SubQueryContainer) GetSelectExprs(ctx *plancontext.PlanningContext) (sqlparser.SelectExprs, error)

+ func (sqc *SubQueryContainer) Inputs() []ops.Operator

+ func (sqc *SubQueryContainer) SetInputs(ops []ops.Operator)

+ func (sqc *SubQueryContainer) ShortDescription() string

+ type SubQueryExpression []*SubQuery

type Table

+ func (to *Table) FindCol(ctx *plancontext.PlanningContext, expr sqlparser.Expr, underRoute bool) (int, error)

+ func (to *Table) GetSelectExprs(ctx *plancontext.PlanningContext) (sqlparser.SelectExprs, error)

type Union

+ Selects []sqlparser.SelectExprs

+ func (u *Union) FindCol(ctx *plancontext.PlanningContext, expr sqlparser.Expr, underRoute bool) (int, error)

+ func (u *Union) GetSelectExprs(ctx *plancontext.PlanningContext) (sqlparser.SelectExprs, error)

type Update

+ Ignore sqlparser.Ignore

+ Limit *sqlparser.Limit

+ OrderBy sqlparser.OrderBy

+ SubQueriesArgOnChangedVindex []string

+ func (Update) FindCol(*plancontext.PlanningContext, sqlparser.Expr, bool) (int, error)

+ func (Update) GetSelectExprs(*plancontext.PlanningContext) (sqlparser.SelectExprs, error)

+ type VerifyOp struct

+ Op ops.Operator

+ Typ string

type Vindex

+ func (v *Vindex) FindCol(ctx *plancontext.PlanningContext, expr sqlparser.Expr, underRoute bool) (int, error)

+ func (v *Vindex) GetSelectExprs(ctx *plancontext.PlanningContext) (sqlparser.SelectExprs, error)

Oct 3, 2023 GO-2024-3306

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

May 8, 2024 GO-2024-3306

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

Mar 14, 2024 GO-2024-2826 +1 more

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

Dec 20, 2023 GO-2024-2826 +1 more

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

Nov 13, 2023 GO-2024-2826 +1 more

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

Oct 3, 2023 GO-2024-2826 +1 more

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

Aug 18, 2023 GO-2024-2826 +1 more

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

Changes in this version

type Aggr

+ func (aggr Aggr) GetTypeCollation(ctx *plancontext.PlanningContext) (sqltypes.Type, collations.ID)

Jul 28, 2023 GO-2024-2826 +1 more

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

Jun 27, 2023 GO-2024-2826 +1 more

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

Changes in this version

+ func IsTableSchemaOrName(e sqlparser.Expr) (col *sqlparser.ColName, isTableSchema bool, isTableName bool)

+ func Merge(ctx *plancontext.PlanningContext, lhs, rhs ops.Operator, ...) (ops.Operator, error)

+ func NotImplementedSchemaInfoResolver(*sqlparser.ColName) (int, error)

type Aggr

+ ColOffset int

+ OriginalOpCode opcode.AggregateOpcode

+ WSOffset int

+ func NewAggr(opCode opcode.AggregateOpcode, f sqlparser.AggrFunc, ...) Aggr

+ func (aggr Aggr) GetCollation(ctx *plancontext.PlanningContext) collations.ID

+ func (aggr Aggr) NeedWeightString(ctx *plancontext.PlanningContext) bool

+ type Aggregator struct

+ Aggregations []Aggr

+ Alias string

+ Columns []*sqlparser.AliasedExpr

+ Grouping []GroupBy

+ Original bool

+ Pushed bool

+ QP *QueryProjection

+ ResultColumns int

+ Source ops.Operator

+ TableID *semantics.TableSet

+ func (a *Aggregator) AddColumn(ctx *plancontext.PlanningContext, expr *sqlparser.AliasedExpr, ...) (ops.Operator, int, error)

+ func (a *Aggregator) AddPredicate(ctx *plancontext.PlanningContext, expr sqlparser.Expr) (ops.Operator, error)

+ func (a *Aggregator) Clone(inputs []ops.Operator) ops.Operator

+ func (a *Aggregator) Description() ops.OpDescription

+ func (a *Aggregator) GetColumns() (columns []*sqlparser.AliasedExpr, err error)

+ func (a *Aggregator) GetOrdering() ([]ops.OrderBy, error)

+ func (a *Aggregator) Inputs() []ops.Operator

+ func (a *Aggregator) SetInputs(operators []ops.Operator)

+ func (a *Aggregator) ShortDescription() string

+ type AnyShardRouting struct

+ Alternates map[*vindexes.Keyspace]*Route

+ func (rr *AnyShardRouting) AlternateInKeyspace(keyspace *vindexes.Keyspace) *Route

+ func (rr *AnyShardRouting) Clone() Routing

+ func (rr *AnyShardRouting) Cost() int

+ func (rr *AnyShardRouting) Keyspace() *vindexes.Keyspace

+ func (rr *AnyShardRouting) OpCode() engine.Opcode

+ func (rr *AnyShardRouting) UpdateRoutingParams(_ *plancontext.PlanningContext, rp *engine.RoutingParameters) error

type ApplyJoin

+ JoinPredicates []JoinColumn

+ func (a *ApplyJoin) Description() ops.OpDescription

+ func (a *ApplyJoin) GetColumns() ([]*sqlparser.AliasedExpr, error)

+ func (a *ApplyJoin) GetOrdering() ([]ops.OrderBy, error)

+ func (a *ApplyJoin) SetInputs(inputs []ops.Operator)

+ func (a *ApplyJoin) ShortDescription() string

type ColNameColumns

+ GetColNames func() []*sqlparser.ColName

type CorrelatedSubQueryOp

+ func (CorrelatedSubQueryOp) GetColumns() ([]*sqlparser.AliasedExpr, error)

+ func (c *CorrelatedSubQueryOp) Description() ops.OpDescription

+ func (c *CorrelatedSubQueryOp) GetOrdering() ([]ops.OrderBy, error)

+ func (c *CorrelatedSubQueryOp) SetInputs(ops []ops.Operator)

+ func (c *CorrelatedSubQueryOp) ShortDescription() string

type Delete

+ func (Delete) GetColumns() ([]*sqlparser.AliasedExpr, error)

+ func (Delete) SetInputs(ops []ops.Operator)

+ func (d *Delete) Description() ops.OpDescription

+ func (d *Delete) GetOrdering() ([]ops.OrderBy, error)

+ func (d *Delete) ShortDescription() string

type Derived

+ QP *QueryProjection

+ TableId semantics.TableSet

+ func (d *Derived) Description() ops.OpDescription

+ func (d *Derived) GetColumns() (exprs []*sqlparser.AliasedExpr, err error)

+ func (d *Derived) GetOrdering() ([]ops.OrderBy, error)

+ func (d *Derived) SetInputs(ops []ops.Operator)

+ func (d *Derived) ShortDescription() string

+ type Distinct struct

+ Columns []engine.CheckCol

+ Pushed bool

+ QP *QueryProjection

+ Source ops.Operator

+ Truncate int

+ func (d *Distinct) AddColumn(ctx *plancontext.PlanningContext, expr *sqlparser.AliasedExpr, ...) (ops.Operator, int, error)

+ func (d *Distinct) AddPredicate(ctx *plancontext.PlanningContext, expr sqlparser.Expr) (ops.Operator, error)

+ func (d *Distinct) Clone(inputs []ops.Operator) ops.Operator

+ func (d *Distinct) Description() ops.OpDescription

+ func (d *Distinct) GetColumns() ([]*sqlparser.AliasedExpr, error)

+ func (d *Distinct) GetOrdering() ([]ops.OrderBy, error)

+ func (d *Distinct) Inputs() []ops.Operator

+ func (d *Distinct) SetInputs(operators []ops.Operator)

+ func (d *Distinct) ShortDescription() string

+ type DualRouting struct

+ func (dr *DualRouting) Clone() Routing

+ func (dr *DualRouting) Cost() int

+ func (dr *DualRouting) Keyspace() *vindexes.Keyspace

+ func (dr *DualRouting) OpCode() engine.Opcode

+ func (dr *DualRouting) UpdateRoutingParams(*plancontext.PlanningContext, *engine.RoutingParameters) error

+ type Eval struct

+ EExpr evalengine.Expr

+ Expr sqlparser.Expr

+ func (po Eval) GetExpr() sqlparser.Expr

type Filter

+ FinalPredicate evalengine.Expr

+ func (f *Filter) Description() ops.OpDescription

+ func (f *Filter) GetColumns() ([]*sqlparser.AliasedExpr, error)

+ func (f *Filter) GetOrdering() ([]ops.OrderBy, error)

+ func (f *Filter) SetInputs(ops []ops.Operator)

+ func (f *Filter) ShortDescription() string

+ type Generate struct

+ Keyspace *vindexes.Keyspace

+ Offset int

+ TableName sqlparser.TableName

+ Values evalengine.Expr

type GroupBy

+ ColOffset int

+ SimplifiedExpr sqlparser.Expr

+ WSOffset int

+ func NewGroupBy(inner, simplified sqlparser.Expr, aliasedExpr *sqlparser.AliasedExpr) GroupBy

type Horizon

+ QP *QueryProjection

+ func (h *Horizon) Description() ops.OpDescription

+ func (h *Horizon) GetColumns() (exprs []*sqlparser.AliasedExpr, err error)

+ func (h *Horizon) GetOrdering() ([]ops.OrderBy, error)

+ func (h *Horizon) SetInputs(ops []ops.Operator)

+ func (h *Horizon) ShortDescription() string

+ type InfoSchemaRouting struct

+ SysTableTableName map[string]sqlparser.Expr

+ SysTableTableSchema []sqlparser.Expr

+ Table *QueryTable

+ func (isr *InfoSchemaRouting) Clone() Routing

+ func (isr *InfoSchemaRouting) Cost() int

+ func (isr *InfoSchemaRouting) Keyspace() *vindexes.Keyspace

+ func (isr *InfoSchemaRouting) OpCode() engine.Opcode

+ func (isr *InfoSchemaRouting) UpdateRoutingParams(_ *plancontext.PlanningContext, rp *engine.RoutingParameters) error

+ type Insert struct

+ AST *sqlparser.Insert

+ AutoIncrement *Generate

+ ColVindexes []*vindexes.ColumnVindex

+ ForceNonStreaming bool

+ Ignore bool

+ Input ops.Operator

+ VTable *vindexes.Table

+ VindexValueOffset [][]int

+ VindexValues [][][]evalengine.Expr

+ func (Insert) AddColumn(*plancontext.PlanningContext, *sqlparser.AliasedExpr, bool, bool) (ops.Operator, int, error)

+ func (Insert) AddPredicate(*plancontext.PlanningContext, sqlparser.Expr) (ops.Operator, error)

+ func (Insert) GetColumns() ([]*sqlparser.AliasedExpr, error)

+ func (i *Insert) Clone(inputs []ops.Operator) ops.Operator

+ func (i *Insert) Description() ops.OpDescription

+ func (i *Insert) GetOrdering() ([]ops.OrderBy, error)

+ func (i *Insert) Inputs() []ops.Operator

+ func (i *Insert) SetInputs(inputs []ops.Operator)

+ func (i *Insert) ShortDescription() string

+ func (i *Insert) TablesUsed() []string

type Join

+ func (Join) GetColumns() ([]*sqlparser.AliasedExpr, error)

+ func (j *Join) Description() ops.OpDescription

+ func (j *Join) GetOrdering() ([]ops.OrderBy, error)

+ func (j *Join) SetInputs(ops []ops.Operator)

+ func (j *Join) ShortDescription() string

+ type JoinColumn struct

+ BvNames []string

+ GroupBy bool

+ LHSExprs []sqlparser.Expr

+ Original *sqlparser.AliasedExpr

+ RHSExpr sqlparser.Expr

+ func (jc JoinColumn) IsMixedLeftAndRight() bool

+ func (jc JoinColumn) IsPureLeft() bool

+ func (jc JoinColumn) IsPureRight() bool

+ type Limit struct

+ AST *sqlparser.Limit

+ Pushed bool

+ Source ops.Operator

+ func (l *Limit) AddColumn(ctx *plancontext.PlanningContext, expr *sqlparser.AliasedExpr, ...) (ops.Operator, int, error)

+ func (l *Limit) AddPredicate(ctx *plancontext.PlanningContext, expr sqlparser.Expr) (ops.Operator, error)

+ func (l *Limit) Clone(inputs []ops.Operator) ops.Operator

+ func (l *Limit) Description() ops.OpDescription

+ func (l *Limit) GetColumns() ([]*sqlparser.AliasedExpr, error)

+ func (l *Limit) GetOrdering() ([]ops.OrderBy, error)

+ func (l *Limit) Inputs() []ops.Operator

+ func (l *Limit) SetInputs(operators []ops.Operator)

+ func (l *Limit) ShortDescription() string

+ type NoneRouting struct

+ func (n *NoneRouting) Clone() Routing

+ func (n *NoneRouting) Cost() int

+ func (n *NoneRouting) Keyspace() *vindexes.Keyspace

+ func (n *NoneRouting) OpCode() engine.Opcode

+ func (n *NoneRouting) UpdateRoutingParams(_ *plancontext.PlanningContext, rp *engine.RoutingParameters) error

+ type Offset struct

+ Expr sqlparser.Expr

+ Offset int

+ func (po Offset) GetExpr() sqlparser.Expr

+ type Ordering struct

+ Offset []int

+ Order []ops.OrderBy

+ ResultColumns int

+ Source ops.Operator

+ WOffset []int

+ func (o *Ordering) AddColumn(ctx *plancontext.PlanningContext, expr *sqlparser.AliasedExpr, ...) (ops.Operator, int, error)

+ func (o *Ordering) AddPredicate(ctx *plancontext.PlanningContext, expr sqlparser.Expr) (ops.Operator, error)

+ func (o *Ordering) Clone(inputs []ops.Operator) ops.Operator

+ func (o *Ordering) Description() ops.OpDescription

+ func (o *Ordering) GetColumns() ([]*sqlparser.AliasedExpr, error)

+ func (o *Ordering) GetOrdering() ([]ops.OrderBy, error)

+ func (o *Ordering) Inputs() []ops.Operator

+ func (o *Ordering) SetInputs(operators []ops.Operator)

+ func (o *Ordering) ShortDescription() string

+ type ProjExpr interface

+ GetExpr func() sqlparser.Expr

+ type Projection struct

+ Alias string

+ Columns []*sqlparser.AliasedExpr

+ FromAggr bool

+ Projections []ProjExpr

+ Source ops.Operator

+ TableID *semantics.TableSet

+ func (p *Projection) AddColumn(ctx *plancontext.PlanningContext, expr *sqlparser.AliasedExpr, ...) (ops.Operator, int, error)

+ func (p *Projection) AddPredicate(ctx *plancontext.PlanningContext, expr sqlparser.Expr) (ops.Operator, error)

+ func (p *Projection) AllOffsets() (cols []int)

+ func (p *Projection) Clone(inputs []ops.Operator) ops.Operator

+ func (p *Projection) Compact(ctx *plancontext.PlanningContext) (ops.Operator, *rewrite.ApplyResult, error)

+ func (p *Projection) Description() ops.OpDescription

+ func (p *Projection) GetColumns() ([]*sqlparser.AliasedExpr, error)

+ func (p *Projection) GetOrdering() ([]ops.OrderBy, error)

+ func (p *Projection) Inputs() []ops.Operator

+ func (p *Projection) SetInputs(operators []ops.Operator)

+ func (p *Projection) ShortDescription() string

type QueryGraph

+ func (QueryGraph) GetColumns() ([]*sqlparser.AliasedExpr, error)

+ func (QueryGraph) SetInputs(ops []ops.Operator)

+ func (qg *QueryGraph) Description() ops.OpDescription

+ func (qg *QueryGraph) GetOrdering() ([]ops.OrderBy, error)

+ func (qg *QueryGraph) ShortDescription() string

type QueryProjection

+ func (qp *QueryProjection) OldAlignGroupByAndOrderBy(ctx *plancontext.PlanningContext)

type Route

+ Ordering []RouteOrdering

+ ResultColumns int

+ Routing Routing

+ func (r *Route) Description() ops.OpDescription

+ func (r *Route) GetColumns() ([]*sqlparser.AliasedExpr, error)

+ func (r *Route) GetOrdering() ([]ops.OrderBy, error)

+ func (r *Route) SetInputs(ops []ops.Operator)

+ func (r *Route) ShortDescription() string

+ type RouteOrdering struct

+ AST sqlparser.Expr

+ Direction sqlparser.OrderDirection

+ Offset int

+ WOffset int

+ type Routing interface

+ Clone func() Routing

+ Cost func() int

+ Keyspace func() *vindexes.Keyspace

+ OpCode func() engine.Opcode

+ UpdateRoutingParams func(ctx *plancontext.PlanningContext, rp *engine.RoutingParameters) error

+ func UpdateRoutingLogic(ctx *plancontext.PlanningContext, expr sqlparser.Expr, r Routing) (Routing, error)

+ type SequenceRouting struct

+ func (sr *SequenceRouting) Clone() Routing

+ func (sr *SequenceRouting) Cost() int

+ func (sr *SequenceRouting) Keyspace() *vindexes.Keyspace

+ func (sr *SequenceRouting) OpCode() engine.Opcode

+ func (sr *SequenceRouting) UpdateRoutingParams(_ *plancontext.PlanningContext, rp *engine.RoutingParameters) error

+ type ShardedRouting struct

+ RouteOpCode engine.Opcode

+ SeenPredicates []sqlparser.Expr

+ Selected *VindexOption

+ VindexPreds []*VindexPlusPredicates

+ func (tr *ShardedRouting) Clone() Routing

+ func (tr *ShardedRouting) Cost() int

+ func (tr *ShardedRouting) Keyspace() *vindexes.Keyspace

+ func (tr *ShardedRouting) OpCode() engine.Opcode

+ func (tr *ShardedRouting) PickBestAvailableVindex()

+ func (tr *ShardedRouting) ResetRoutingLogic(ctx *plancontext.PlanningContext) (Routing, error)

+ func (tr *ShardedRouting) SelectedVindex() vindexes.Vindex

+ func (tr *ShardedRouting) UpdateRoutingParams(_ *plancontext.PlanningContext, rp *engine.RoutingParameters) error

+ func (tr *ShardedRouting) VindexExpressions() []sqlparser.Expr

type SubQuery

+ func (SubQuery) GetColumns() ([]*sqlparser.AliasedExpr, error)

+ func (s *SubQuery) Description() ops.OpDescription

+ func (s *SubQuery) GetOrdering() ([]ops.OrderBy, error)

+ func (s *SubQuery) SetInputs(ops []ops.Operator)

+ func (s *SubQuery) ShortDescription() string

type SubQueryInner

+ func (SubQueryInner) GetColumns() ([]*sqlparser.AliasedExpr, error)

+ func (s *SubQueryInner) Description() ops.OpDescription

+ func (s *SubQueryInner) GetOrdering() ([]ops.OrderBy, error)

+ func (s *SubQueryInner) SetInputs(ops []ops.Operator)

+ func (s *SubQueryInner) ShortDescription() string

type SubQueryOp

+ func (SubQueryOp) GetColumns() ([]*sqlparser.AliasedExpr, error)

+ func (s *SubQueryOp) Description() ops.OpDescription

+ func (s *SubQueryOp) GetOrdering() ([]ops.OrderBy, error)

+ func (s *SubQueryOp) SetInputs(ops []ops.Operator)

+ func (s *SubQueryOp) ShortDescription() string

type Table

+ func (Table) SetInputs(ops []ops.Operator)

+ func (to *Table) Description() ops.OpDescription

+ func (to *Table) GetColNames() []*sqlparser.ColName

+ func (to *Table) GetOrdering() ([]ops.OrderBy, error)

+ func (to *Table) ShortDescription() string

+ type TargetedRouting struct

+ TargetDestination key.Destination

+ func (tr *TargetedRouting) Clone() Routing

+ func (tr *TargetedRouting) Cost() int

+ func (tr *TargetedRouting) Keyspace() *vindexes.Keyspace

+ func (tr *TargetedRouting) OpCode() engine.Opcode

+ func (tr *TargetedRouting) UpdateRoutingParams(_ *plancontext.PlanningContext, rp *engine.RoutingParameters) error

+ type UnexploredExpression struct

+ E sqlparser.Expr

+ func (po UnexploredExpression) GetExpr() sqlparser.Expr

type Union

+ func (Union) GetColumns() ([]*sqlparser.AliasedExpr, error)

+ func (u *Union) Description() ops.OpDescription

+ func (u *Union) GetOrdering() ([]ops.OrderBy, error)

+ func (u *Union) NoLHSTableSet()

+ func (u *Union) SetInputs(ops []ops.Operator)

+ func (u *Union) ShortDescription() string

type Update

+ func (Update) GetColumns() ([]*sqlparser.AliasedExpr, error)

+ func (Update) SetInputs(ops []ops.Operator)

+ func (u *Update) Description() ops.OpDescription

+ func (u *Update) GetOrdering() ([]ops.OrderBy, error)

+ func (u *Update) ShortDescription() string

type Vindex

+ func (Vindex) SetInputs(ops []ops.Operator)

+ func (v *Vindex) Description() ops.OpDescription

+ func (v *Vindex) GetColNames() []*sqlparser.ColName

+ func (v *Vindex) GetOrdering() ([]ops.OrderBy, error)

+ func (v *Vindex) ShortDescription() string

Jun 13, 2023 GO-2024-2826 +1 more

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

Jun 6, 2023 GO-2024-2826 +1 more

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

Dec 20, 2023 GO-2024-2826 +1 more

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

Nov 13, 2023 GO-2024-2826 +1 more

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

Oct 3, 2023 GO-2024-2826 +1 more

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

Aug 18, 2023 GO-2024-2826 +1 more

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

Jul 28, 2023 GO-2024-2826 +1 more

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

May 9, 2023 GO-2024-2826 +1 more

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

Mar 30, 2023 GO-2024-2826 +1 more

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

Changes in this version

type QueryProjection

+ func (qp *QueryProjection) NeedsProjecting(ctx *plancontext.PlanningContext, ...) (needsVtGateEval bool, expressions []sqlparser.Expr, colNames []string, ...)

Feb 28, 2023 GO-2023-1717 +2 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

Changes in this version

+ const VindexUnsupported

+ func AddPredicate(join JoinOp, ctx *plancontext.PlanningContext, expr sqlparser.Expr, ...) (ops.Operator, error)

+ func BreakExpressionInLHSandRHS(ctx *plancontext.PlanningContext, expr sqlparser.Expr, lhs semantics.TableSet) (bvNames []string, columns []*sqlparser.ColName, rewrittenExpr sqlparser.Expr, ...)

+ func CheckValid(op ops.Operator) error

+ func Clone(op ops.Operator) ops.Operator

+ func Compact(ctx *plancontext.PlanningContext, op ops.Operator) (ops.Operator, error)

+ func CompareRefInt(a *int, b *int) bool

+ func CostOf(op ops.Operator) (cost int)

+ func PlanQuery(ctx *plancontext.PlanningContext, selStmt sqlparser.Statement) (ops.Operator, error)

+ func QualifiedIdentifier(ks *vindexes.Keyspace, i sqlparser.IdentifierCS) string

+ func QualifiedString(ks *vindexes.Keyspace, s string) string

+ func QualifiedStrings(ks *vindexes.Keyspace, ss []string) []string

+ func QualifiedTableName(ks *vindexes.Keyspace, t sqlparser.TableName) string

+ func QualifiedTableNames(ks *vindexes.Keyspace, ts []sqlparser.TableName) []string

+ func QualifiedTables(ks *vindexes.Keyspace, vts []*vindexes.Table) []string

+ func RemovePredicate(ctx *plancontext.PlanningContext, expr sqlparser.Expr, op ops.Operator) (ops.Operator, error)

+ func SingleQualifiedIdentifier(ks *vindexes.Keyspace, i sqlparser.IdentifierCS) []string

+ func SingleQualifiedString(ks *vindexes.Keyspace, s string) []string

+ func SingleQualifiedTableName(ks *vindexes.Keyspace, t sqlparser.TableName) []string

+ func SortAggregations(a []Aggr)

+ func SortGrouping(a []GroupBy)

+ func TableID(op ops.Operator) (result semantics.TableSet)

+ func TablesUsed(op ops.Operator) []string

+ func ToSQL(ctx *plancontext.PlanningContext, op ops.Operator) (sqlparser.SelectStatement, error)

+ func UnresolvedPredicates(op ops.Operator, st *semantics.SemTable) (result []sqlparser.Expr)

+ type Aggr struct

+ Alias string

+ Distinct bool

+ Func sqlparser.AggrFunc

+ Index *int

+ OpCode engine.AggregateOpcode

+ Original *sqlparser.AliasedExpr

+ type AggrRewriter struct

+ Err error

+ func (ar *AggrRewriter) RewriteDown() func(sqlparser.SQLNode, sqlparser.SQLNode) bool

+ func (ar *AggrRewriter) RewriteUp() func(*sqlparser.Cursor) bool

+ type ApplyJoin struct

+ Columns []int

+ ColumnsAST []sqlparser.Expr

+ LHS ops.Operator

+ LHSColumns []*sqlparser.ColName

+ LeftJoin bool

+ Predicate sqlparser.Expr

+ RHS ops.Operator

+ Vars map[string]int

+ func NewApplyJoin(lhs, rhs ops.Operator, predicate sqlparser.Expr, leftOuterJoin bool) *ApplyJoin

+ func (a *ApplyJoin) AddColumn(ctx *plancontext.PlanningContext, expr sqlparser.Expr) (int, error)

+ func (a *ApplyJoin) AddJoinPredicate(ctx *plancontext.PlanningContext, expr sqlparser.Expr) error

+ func (a *ApplyJoin) AddPredicate(ctx *plancontext.PlanningContext, expr sqlparser.Expr) (ops.Operator, error)

+ func (a *ApplyJoin) Clone(inputs []ops.Operator) ops.Operator

+ func (a *ApplyJoin) GetLHS() ops.Operator

+ func (a *ApplyJoin) GetRHS() ops.Operator

+ func (a *ApplyJoin) IPhysical()

+ func (a *ApplyJoin) Inputs() []ops.Operator

+ func (a *ApplyJoin) IsInner() bool

+ func (a *ApplyJoin) MakeInner()

+ func (a *ApplyJoin) SetLHS(operator ops.Operator)

+ func (a *ApplyJoin) SetRHS(operator ops.Operator)

+ type ColNameColumns interface

+ AddCol func(*sqlparser.ColName)

+ GetColumns func() []*sqlparser.ColName

+ type CorrelatedSubQueryOp struct

+ Extracted *sqlparser.ExtractedSubquery

+ Inner ops.Operator

+ LHSColumns []*sqlparser.ColName

+ Outer ops.Operator

+ Vars map[string]int

+ func (CorrelatedSubQueryOp) AddColumn(*plancontext.PlanningContext, sqlparser.Expr) (int, error)

+ func (CorrelatedSubQueryOp) AddPredicate(*plancontext.PlanningContext, sqlparser.Expr) (ops.Operator, error)

+ func (c *CorrelatedSubQueryOp) Clone(inputs []ops.Operator) ops.Operator

+ func (c *CorrelatedSubQueryOp) IPhysical()

+ func (c *CorrelatedSubQueryOp) Inputs() []ops.Operator

+ type Cost struct

+ IsUnique bool

+ OpCode engine.Opcode

+ VindexCost int

+ type Delete struct

+ AST *sqlparser.Delete

+ OwnedVindexQuery string

+ QTable *QueryTable

+ VTable *vindexes.Table

+ func (Delete) AddColumn(*plancontext.PlanningContext, sqlparser.Expr) (int, error)

+ func (Delete) AddPredicate(*plancontext.PlanningContext, sqlparser.Expr) (ops.Operator, error)

+ func (Delete) Inputs() []ops.Operator

+ func (d *Delete) Clone(inputs []ops.Operator) ops.Operator

+ func (d *Delete) IPhysical()

+ func (d *Delete) Introduces() semantics.TableSet

+ func (d *Delete) TablesUsed() []string

+ type Derived struct

+ Alias string

+ ColumnAliases sqlparser.Columns

+ Columns []*sqlparser.ColName

+ ColumnsOffset []int

+ Query sqlparser.SelectStatement

+ Source ops.Operator

+ func (d *Derived) AddColumn(ctx *plancontext.PlanningContext, expr sqlparser.Expr) (int, error)

+ func (d *Derived) AddPredicate(ctx *plancontext.PlanningContext, expr sqlparser.Expr) (ops.Operator, error)

+ func (d *Derived) Clone(inputs []ops.Operator) ops.Operator

+ func (d *Derived) IPhysical()

+ func (d *Derived) Inputs() []ops.Operator

+ func (d *Derived) IsMergeable(ctx *plancontext.PlanningContext) bool

+ type Filter struct

+ Predicates []sqlparser.Expr

+ Source ops.Operator

+ func (f *Filter) AddColumn(ctx *plancontext.PlanningContext, expr sqlparser.Expr) (int, error)

+ func (f *Filter) AddPredicate(ctx *plancontext.PlanningContext, expr sqlparser.Expr) (ops.Operator, error)

+ func (f *Filter) Clone(inputs []ops.Operator) ops.Operator

+ func (f *Filter) Compact(*plancontext.PlanningContext) (ops.Operator, rewrite.TreeIdentity, error)

+ func (f *Filter) IPhysical()

+ func (f *Filter) Inputs() []ops.Operator

+ func (f *Filter) UnsolvedPredicates(st *semantics.SemTable) []sqlparser.Expr

+ type GroupBy struct

+ Inner sqlparser.Expr

+ InnerIndex *int

+ WeightStrExpr sqlparser.Expr

+ func (b GroupBy) AsAliasedExpr() *sqlparser.AliasedExpr

+ func (b GroupBy) AsOrderBy() OrderBy

+ type Horizon struct

+ Select sqlparser.SelectStatement

+ Source ops.Operator

+ func (Horizon) AddColumn(*plancontext.PlanningContext, sqlparser.Expr) (int, error)

+ func (h *Horizon) AddPredicate(ctx *plancontext.PlanningContext, expr sqlparser.Expr) (ops.Operator, error)

+ func (h *Horizon) Clone(inputs []ops.Operator) ops.Operator

+ func (h *Horizon) IPhysical()

+ func (h *Horizon) Inputs() []ops.Operator

+ type Join struct

+ LHS ops.Operator

+ LeftJoin bool

+ Predicate sqlparser.Expr

+ RHS ops.Operator

+ func (Join) AddColumn(*plancontext.PlanningContext, sqlparser.Expr) (int, error)

+ func (j *Join) AddJoinPredicate(ctx *plancontext.PlanningContext, expr sqlparser.Expr) error

+ func (j *Join) AddPredicate(ctx *plancontext.PlanningContext, expr sqlparser.Expr) (ops.Operator, error)

+ func (j *Join) Clone(inputs []ops.Operator) ops.Operator

+ func (j *Join) Compact(ctx *plancontext.PlanningContext) (ops.Operator, rewrite.TreeIdentity, error)

+ func (j *Join) GetLHS() ops.Operator

+ func (j *Join) GetRHS() ops.Operator

+ func (j *Join) Inputs() []ops.Operator

+ func (j *Join) IsInner() bool

+ func (j *Join) MakeInner()

+ func (j *Join) SetLHS(operator ops.Operator)

+ func (j *Join) SetRHS(operator ops.Operator)

+ type JoinOp interface

+ AddJoinPredicate func(ctx *plancontext.PlanningContext, expr sqlparser.Expr) error

+ GetLHS func() ops.Operator

+ GetRHS func() ops.Operator

+ IsInner func() bool

+ MakeInner func()

+ SetLHS func(ops.Operator)

+ SetRHS func(ops.Operator)

+ type OrderBy struct

+ Inner *sqlparser.Order

+ WeightStrExpr sqlparser.Expr

+ type QueryGraph struct

+ NoDeps sqlparser.Expr

+ Tables []*QueryTable

+ func (QueryGraph) AddColumn(*plancontext.PlanningContext, sqlparser.Expr) (int, error)

+ func (QueryGraph) Inputs() []ops.Operator

+ func (qg *QueryGraph) AddPredicate(ctx *plancontext.PlanningContext, expr sqlparser.Expr) (ops.Operator, error)

+ func (qg *QueryGraph) Clone(inputs []ops.Operator) ops.Operator

+ func (qg *QueryGraph) GetPredicates(lhs, rhs semantics.TableSet) []sqlparser.Expr

+ func (qg *QueryGraph) Introduces() semantics.TableSet

+ func (qg *QueryGraph) UnsolvedPredicates(_ *semantics.SemTable) []sqlparser.Expr

+ type QueryProjection struct

+ AddedColumn int

+ CanPushDownSorting bool

+ Distinct bool

+ HasAggr bool

+ HasStar bool

+ OrderExprs []OrderBy

+ SelectExprs []SelectExpr

+ func CreateQPFromSelect(ctx *plancontext.PlanningContext, sel *sqlparser.Select) (*QueryProjection, error)

+ func CreateQPFromUnion(union *sqlparser.Union) (*QueryProjection, error)

+ func (qp *QueryProjection) AddGroupBy(by GroupBy)

+ func (qp *QueryProjection) AggrRewriter(ctx *plancontext.PlanningContext) *AggrRewriter

+ func (qp *QueryProjection) AggregationExpressions(ctx *plancontext.PlanningContext) (out []Aggr, err error)

+ func (qp *QueryProjection) AlignGroupByAndOrderBy(ctx *plancontext.PlanningContext)

+ func (qp *QueryProjection) FindSelectExprIndexForExpr(ctx *plancontext.PlanningContext, expr sqlparser.Expr) (*int, *sqlparser.AliasedExpr)

+ func (qp *QueryProjection) GetColumnCount() int

+ func (qp *QueryProjection) GetGrouping() []GroupBy

+ func (qp *QueryProjection) GetSimplifiedExpr(e sqlparser.Expr) (expr sqlparser.Expr, weightStrExpr sqlparser.Expr, err error)

+ func (qp *QueryProjection) NeedsAggregation() bool

+ func (qp *QueryProjection) NeedsDistinct() bool

+ type QueryTable struct

+ Alias *sqlparser.AliasedTableExpr

+ ID semantics.TableSet

+ IsInfSchema bool

+ Predicates []sqlparser.Expr

+ Table sqlparser.TableName

+ func (qt *QueryTable) Clone() *QueryTable

+ type Route struct

+ Alternates map[*vindexes.Keyspace]*Route

+ Keyspace *vindexes.Keyspace

+ MergedWith []*Route

+ RouteOpCode engine.Opcode

+ SeenPredicates []sqlparser.Expr

+ Selected *VindexOption

+ Source ops.Operator

+ SysTableTableName map[string]evalengine.Expr

+ SysTableTableSchema []evalengine.Expr

+ TargetDestination key.Destination

+ VindexPreds []*VindexPlusPredicates

+ func (*Route) IPhysical()

+ func (r *Route) AddColumn(ctx *plancontext.PlanningContext, e sqlparser.Expr) (int, error)

+ func (r *Route) AddPredicate(ctx *plancontext.PlanningContext, expr sqlparser.Expr) (ops.Operator, error)

+ func (r *Route) AlternateInKeyspace(keyspace *vindexes.Keyspace) *Route

+ func (r *Route) Clone(inputs []ops.Operator) ops.Operator

+ func (r *Route) Cost() int

+ func (r *Route) Inputs() []ops.Operator

+ func (r *Route) IsSingleShard() bool

+ func (r *Route) PickBestAvailableVindex()

+ func (r *Route) SelectedVindex() vindexes.Vindex

+ func (r *Route) TablesUsed() []string

+ func (r *Route) UpdateRoutingLogic(ctx *plancontext.PlanningContext, expr sqlparser.Expr) error

+ func (r *Route) VindexExpressions() []sqlparser.Expr

+ type SelectExpr struct

+ Aggr bool

+ Col sqlparser.SelectExpr

+ func (s SelectExpr) GetAliasedExpr() (*sqlparser.AliasedExpr, error)

+ func (s SelectExpr) GetExpr() (sqlparser.Expr, error)

+ type SubQuery struct

+ Inner []*SubQueryInner

+ Outer ops.Operator

+ func (SubQuery) AddColumn(*plancontext.PlanningContext, sqlparser.Expr) (int, error)

+ func (SubQuery) AddPredicate(*plancontext.PlanningContext, sqlparser.Expr) (ops.Operator, error)

+ func (s *SubQuery) Clone(inputs []ops.Operator) ops.Operator

+ func (s *SubQuery) Inputs() []ops.Operator

+ type SubQueryInner struct

+ ExtractedSubquery *sqlparser.ExtractedSubquery

+ Inner ops.Operator

+ func (SubQueryInner) AddColumn(*plancontext.PlanningContext, sqlparser.Expr) (int, error)

+ func (SubQueryInner) AddPredicate(*plancontext.PlanningContext, sqlparser.Expr) (ops.Operator, error)

+ func (s *SubQueryInner) Clone(inputs []ops.Operator) ops.Operator

+ func (s *SubQueryInner) Inputs() []ops.Operator

+ type SubQueryOp struct

+ Extracted *sqlparser.ExtractedSubquery

+ Inner ops.Operator

+ Outer ops.Operator

+ func (SubQueryOp) AddColumn(*plancontext.PlanningContext, sqlparser.Expr) (int, error)

+ func (SubQueryOp) AddPredicate(*plancontext.PlanningContext, sqlparser.Expr) (ops.Operator, error)

+ func (s *SubQueryOp) Clone(inputs []ops.Operator) ops.Operator

+ func (s *SubQueryOp) IPhysical()

+ func (s *SubQueryOp) Inputs() []ops.Operator

+ type Table struct

+ Columns []*sqlparser.ColName

+ QTable *QueryTable

+ VTable *vindexes.Table

+ func (Table) Inputs() []ops.Operator

+ func (to *Table) AddCol(col *sqlparser.ColName)

+ func (to *Table) AddColumn(_ *plancontext.PlanningContext, e sqlparser.Expr) (int, error)

+ func (to *Table) AddPredicate(_ *plancontext.PlanningContext, expr sqlparser.Expr) (ops.Operator, error)

+ func (to *Table) Clone([]ops.Operator) ops.Operator

+ func (to *Table) GetColumns() []*sqlparser.ColName

+ func (to *Table) IPhysical()

+ func (to *Table) Introduces() semantics.TableSet

+ func (to *Table) TablesUsed() []string

+ type TableIDIntroducer interface

+ Introduces func() semantics.TableSet

+ type TableUser interface

+ TablesUsed func() []string

+ type Union struct

+ Distinct bool

+ Ordering sqlparser.OrderBy

+ Sources []ops.Operator

+ func (Union) AddColumn(*plancontext.PlanningContext, sqlparser.Expr) (int, error)

+ func (u *Union) AddPredicate(ctx *plancontext.PlanningContext, expr sqlparser.Expr) (ops.Operator, error)

+ func (u *Union) Clone(inputs []ops.Operator) ops.Operator

+ func (u *Union) Compact(*plancontext.PlanningContext) (ops.Operator, rewrite.TreeIdentity, error)

+ func (u *Union) GetSelectFor(source int) (*sqlparser.Select, error)

+ func (u *Union) IPhysical()

+ func (u *Union) Inputs() []ops.Operator

+ type Update struct

+ AST *sqlparser.Update

+ Assignments map[string]sqlparser.Expr

+ ChangedVindexValues map[string]*engine.VindexValues

+ OwnedVindexQuery string

+ QTable *QueryTable

+ VTable *vindexes.Table

+ func (Update) AddColumn(*plancontext.PlanningContext, sqlparser.Expr) (int, error)

+ func (Update) AddPredicate(*plancontext.PlanningContext, sqlparser.Expr) (ops.Operator, error)

+ func (Update) Inputs() []ops.Operator

+ func (u *Update) Clone(inputs []ops.Operator) ops.Operator

+ func (u *Update) IPhysical()

+ func (u *Update) Introduces() semantics.TableSet

+ func (u *Update) TablesUsed() []string

+ type Vindex struct

+ Columns []*sqlparser.ColName

+ OpCode engine.VindexOpcode

+ Solved semantics.TableSet

+ Table VindexTable

+ Value sqlparser.Expr

+ Vindex vindexes.Vindex

+ func (Vindex) Inputs() []ops.Operator

+ func (v *Vindex) AddCol(col *sqlparser.ColName)

+ func (v *Vindex) AddColumn(_ *plancontext.PlanningContext, expr sqlparser.Expr) (int, error)

+ func (v *Vindex) AddPredicate(ctx *plancontext.PlanningContext, expr sqlparser.Expr) (ops.Operator, error)

+ func (v *Vindex) CheckValid() error

+ func (v *Vindex) Clone([]ops.Operator) ops.Operator

+ func (v *Vindex) GetColumns() []*sqlparser.ColName

+ func (v *Vindex) IPhysical()

+ func (v *Vindex) Introduces() semantics.TableSet

+ func (v *Vindex) TablesUsed() []string

+ type VindexOption struct

+ ColsSeen map[string]any

+ Cost Cost

+ FoundVindex vindexes.Vindex

+ OpCode engine.Opcode

+ Predicates []sqlparser.Expr

+ Ready bool

+ ValueExprs []sqlparser.Expr

+ Values []evalengine.Expr

+ type VindexPlusPredicates struct

+ ColVindex *vindexes.ColumnVindex

+ Options []*VindexOption

+ TableID semantics.TableSet

+ type VindexTable struct

+ Alias *sqlparser.AliasedTableExpr

+ Predicates []sqlparser.Expr

+ Table sqlparser.TableName

+ TableID semantics.TableSet

+ VTable *vindexes.Table

Feb 8, 2023 GO-2023-1717 +2 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess