engine

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 AggregateParams

+ Func sqlparser.AggrFunc

type Primitive

+ func NewPercentBasedMirror(percentage float32, primitive Primitive, target Primitive) Primitive

type PrimitiveDescription

+ RowsReceived RowsReceived

+ ShardsQueried *ShardsQueried

+ type RecurseCTE struct

+ Seed Primitive

+ Term Primitive

+ Vars map[string]int

+ func (cached *RecurseCTE) CachedSize(alloc bool) int64

+ func (r *RecurseCTE) GetFields(ctx context.Context, vcursor VCursor, ...) (*sqltypes.Result, error)

+ func (r *RecurseCTE) GetKeyspaceName() string

+ func (r *RecurseCTE) GetTableName() string

+ func (r *RecurseCTE) Inputs() ([]Primitive, []map[string]any)

+ func (r *RecurseCTE) NeedsTransaction() bool

+ func (r *RecurseCTE) RouteType() string

+ func (r *RecurseCTE) TryExecute(ctx context.Context, vcursor VCursor, ...) (*sqltypes.Result, error)

+ func (r *RecurseCTE) TryStreamExecute(ctx context.Context, vcursor VCursor, ...) error

+ type RowsReceived []int

type Send

+ IsDDL bool

type SessionActions

+ SetExecQueryTimeout func(timeout *int)

+ type ShardsQueried int

+ type Stats struct

+ InterOpStats map[Primitive]RowsReceived

+ ShardsStats map[Primitive]ShardsQueried

+ type TransactionStatus struct

+ Keyspace string

+ TransactionID string

+ func (TransactionStatus) Inputs() ([]Primitive, []map[string]any)

+ func (TransactionStatus) NeedsTransaction() bool

+ func (cached *TransactionStatus) CachedSize(alloc bool) int64

+ func (t *TransactionStatus) GetFields(ctx context.Context, vcursor VCursor, ...) (*sqltypes.Result, error)

+ func (t *TransactionStatus) GetKeyspaceName() string

+ func (t *TransactionStatus) GetTableName() string

+ func (t *TransactionStatus) RouteType() string

+ func (t *TransactionStatus) TryExecute(ctx context.Context, vcursor VCursor, ...) (*sqltypes.Result, error)

+ func (t *TransactionStatus) TryStreamExecute(ctx context.Context, vcursor VCursor, ...) error

type VCursor

+ CloneForMirroring func(ctx context.Context) VCursor

+ ReadTransaction func(ctx context.Context, transactionID string) (*querypb.TransactionMetadata, error)

+ RecordMirrorStats func(time.Duration, time.Duration, error)

+ StartPrimitiveTrace func() func() Stats

+ UnresolvedTransactions func(ctx context.Context, keyspace string) ([]*querypb.TransactionMetadata, error)

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

+ const DmlVals

+ var UpperLimitStr = "__upper_limit"

+ type DMLWithInput struct

+ BVList []map[string]int

+ DMLs []Primitive

+ Input Primitive

+ OutputCols [][]int

+ func (DMLWithInput) NeedsTransaction() bool

+ func (cached *DMLWithInput) CachedSize(alloc bool) int64

+ func (dml *DMLWithInput) GetFields(context.Context, VCursor, map[string]*querypb.BindVariable) (*sqltypes.Result, error)

+ func (dml *DMLWithInput) GetKeyspaceName() string

+ func (dml *DMLWithInput) GetTableName() string

+ func (dml *DMLWithInput) Inputs() ([]Primitive, []map[string]any)

+ func (dml *DMLWithInput) RouteType() string

+ func (dml *DMLWithInput) TryExecute(ctx context.Context, vcursor VCursor, ...) (*sqltypes.Result, error)

+ func (dml *DMLWithInput) TryStreamExecute(ctx context.Context, vcursor VCursor, ...) error

type HashJoin

+ Values *evalengine.EnumSetValues

type Insert

+ Alias string

type Send

+ QueryTimeout int

type SimpleProjection

+ ColNames []string

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

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 DmVals

type AggregateParams

+ CollationEnv *collations.Environment

type CheckCol

+ CollationEnv *collations.Environment

type DML

+ PreventAutoCommit bool

+ type DeleteWithInput struct

+ Delete Primitive

+ Input Primitive

+ OutputCols []int

+ func (DeleteWithInput) NeedsTransaction() bool

+ func (cached *DeleteWithInput) CachedSize(alloc bool) int64

+ func (del *DeleteWithInput) GetFields(context.Context, VCursor, map[string]*querypb.BindVariable) (*sqltypes.Result, error)

+ func (del *DeleteWithInput) GetKeyspaceName() string

+ func (del *DeleteWithInput) GetTableName() string

+ func (del *DeleteWithInput) Inputs() ([]Primitive, []map[string]any)

+ func (del *DeleteWithInput) RouteType() string

+ func (del *DeleteWithInput) TryExecute(ctx context.Context, vcursor VCursor, ...) (*sqltypes.Result, error)

+ func (del *DeleteWithInput) TryStreamExecute(ctx context.Context, vcursor VCursor, ...) error

type FkChild

+ NonLiteralInfo []NonLiteralUpdateInfo

type GroupByParams

+ CollationEnv *collations.Environment

type HashJoin

+ CollationEnv *collations.Environment

+ type InsertCommon struct

+ ColVindexes []*vindexes.ColumnVindex

+ ForceNonStreaming bool

+ Generate *Generate

+ Ignore bool

+ Keyspace *vindexes.Keyspace

+ MultiShardAutocommit bool

+ Opcode InsertOpcode

+ Prefix string

+ PreventAutoCommit bool

+ QueryTimeout int

+ Suffix sqlparser.OnDup

+ TableName string

+ func (InsertCommon) NeedsTransaction() bool

+ func (cached *InsertCommon) CachedSize(alloc bool) int64

+ func (ic *InsertCommon) GetFields(context.Context, VCursor, map[string]*querypb.BindVariable) (*sqltypes.Result, error)

+ func (ic *InsertCommon) GetKeyspaceName() string

+ func (ic *InsertCommon) GetTableName() string

type InsertSelect

+ Input Primitive

+ VindexValueOffset [][]int

+ func (InsertSelect) NeedsTransaction() bool

+ func (cached *InsertSelect) CachedSize(alloc bool) int64

+ func (ins *InsertSelect) Inputs() ([]Primitive, []map[string]any)

+ func (ins *InsertSelect) RouteType() string

+ func (ins *InsertSelect) TryExecute(ctx context.Context, vcursor VCursor, ...) (*sqltypes.Result, error)

+ func (ins *InsertSelect) TryStreamExecute(ctx context.Context, vcursor VCursor, ...) error

+ type NonLiteralUpdateInfo struct

+ CompExprCol int

+ UpdateExprBvName string

+ UpdateExprCol int

+ func (cached *NonLiteralUpdateInfo) CachedSize(alloc bool) int64

type OrderedAggregate

+ CollationEnv *collations.Environment

type Send

+ ReservedConnectionNeeded bool

+ type Sequential struct

+ Sources []Primitive

+ func NewSequential(Sources []Primitive) *Sequential

+ func (Sequential) NeedsTransaction() bool

+ func (cached *Sequential) CachedSize(alloc bool) int64

+ func (s *Sequential) GetFields(context.Context, VCursor, map[string]*querypb.BindVariable) (*sqltypes.Result, error)

+ func (s *Sequential) GetKeyspaceName() string

+ func (s *Sequential) GetTableName() string

+ func (s *Sequential) Inputs() ([]Primitive, []map[string]any)

+ func (s *Sequential) RouteType() string

+ func (s *Sequential) TryExecute(ctx context.Context, vcursor VCursor, ...) (*sqltypes.Result, error)

+ func (s *Sequential) TryStreamExecute(ctx context.Context, vcursor VCursor, ...) error

+ type Unlock struct

+ func (Unlock) Inputs() ([]Primitive, []map[string]any)

+ func (Unlock) NeedsTransaction() bool

+ func (u *Unlock) GetFields(ctx context.Context, vcursor VCursor, ...) (*sqltypes.Result, error)

+ func (u *Unlock) GetKeyspaceName() string

+ func (u *Unlock) GetTableName() string

+ func (u *Unlock) RouteType() string

+ func (u *Unlock) TryExecute(ctx context.Context, vcursor VCursor, ...) (*sqltypes.Result, error)

+ func (u *Unlock) TryStreamExecute(ctx context.Context, vcursor VCursor, ...) error

+ type Upsert struct

+ Upserts []upsert

+ func (Upsert) NeedsTransaction() bool

+ func (cached *Upsert) CachedSize(alloc bool) int64

+ func (u *Upsert) AddUpsert(ins, upd Primitive)

+ func (u *Upsert) GetFields(ctx context.Context, vcursor VCursor, ...) (*sqltypes.Result, error)

+ func (u *Upsert) GetKeyspaceName() string

+ func (u *Upsert) GetTableName() string

+ func (u *Upsert) Inputs() ([]Primitive, []map[string]any)

+ func (u *Upsert) RouteType() string

+ func (u *Upsert) TryExecute(ctx context.Context, vcursor VCursor, ...) (*sqltypes.Result, error)

+ func (u *Upsert) TryStreamExecute(ctx context.Context, vcursor VCursor, ...) error

type VCursor

+ CloneForReplicaWarming func(ctx context.Context) VCursor

+ Environment func() *vtenv.Environment

+ GetWarmingReadsChannel func() chan bool

+ GetWarmingReadsPercent func() int

+ SQLMode func() string

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

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

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

+ const ChildVerify

+ const ParentVerify

type AggregateParams

+ func NewAggregateParam(opcode AggregateOpcode, col int, alias string) *AggregateParams

type DML

+ TableNames []string

+ Vindexes []*vindexes.ColumnVindex

type Filter

+ Truncate int

+ type FkCascade struct

+ Children []*FkChild

+ Parent Primitive

+ Selection Primitive

+ func (FkCascade) NeedsTransaction() bool

+ func (cached *FkCascade) CachedSize(alloc bool) int64

+ func (fkc *FkCascade) GetFields(_ context.Context, _ VCursor, _ map[string]*querypb.BindVariable) (*sqltypes.Result, error)

+ func (fkc *FkCascade) GetKeyspaceName() string

+ func (fkc *FkCascade) GetTableName() string

+ func (fkc *FkCascade) Inputs() ([]Primitive, []map[string]any)

+ func (fkc *FkCascade) RouteType() string

+ func (fkc *FkCascade) TryExecute(ctx context.Context, vcursor VCursor, ...) (*sqltypes.Result, error)

+ func (fkc *FkCascade) TryStreamExecute(ctx context.Context, vcursor VCursor, ...) error

+ type FkChild struct

+ BVName string

+ Cols []int

+ Exec Primitive

+ func (cached *FkChild) CachedSize(alloc bool) int64

+ type FkVerify struct

+ Exec Primitive

+ Verify []*Verify

+ func (FkVerify) NeedsTransaction() bool

+ func (cached *FkVerify) CachedSize(alloc bool) int64

+ func (f *FkVerify) GetFields(ctx context.Context, vcursor VCursor, ...) (*sqltypes.Result, error)

+ func (f *FkVerify) GetKeyspaceName() string

+ func (f *FkVerify) GetTableName() string

+ func (f *FkVerify) Inputs() ([]Primitive, []map[string]any)

+ func (f *FkVerify) RouteType() string

+ func (f *FkVerify) TryExecute(ctx context.Context, vcursor VCursor, ...) (*sqltypes.Result, error)

+ func (f *FkVerify) TryStreamExecute(ctx context.Context, vcursor VCursor, ...) error

type Insert

+ TableName string

type PrimitiveDescription

+ InputName string

type SessionActions

+ Commit func(ctx context.Context) error

+ GetMigrationContext func() string

+ SetMigrationContext func(string)

+ type ThrottleApp struct

+ Keyspace *vindexes.Keyspace

+ ThrottledAppRule *topodatapb.ThrottledAppRule

+ func (ThrottleApp) Inputs() ([]Primitive, []map[string]any)

+ func (ThrottleApp) NeedsTransaction() bool

+ func (cached *ThrottleApp) CachedSize(alloc bool) int64

+ func (v *ThrottleApp) GetFields(ctx context.Context, vcursor VCursor, ...) (*sqltypes.Result, error)

+ func (v *ThrottleApp) GetKeyspaceName() string

+ func (v *ThrottleApp) GetTableName() string

+ func (v *ThrottleApp) RouteType() string

+ func (v *ThrottleApp) TryExecute(ctx context.Context, vcursor VCursor, ...) (result *sqltypes.Result, err error)

+ func (v *ThrottleApp) TryStreamExecute(ctx context.Context, vcursor VCursor, ...) error

+ type UncorrelatedSubquery struct

+ HasValues string

+ Opcode PulloutOpcode

+ Outer Primitive

+ Subquery Primitive

+ SubqueryResult string

+ func (cached *UncorrelatedSubquery) CachedSize(alloc bool) int64

+ func (ps *UncorrelatedSubquery) GetFields(ctx context.Context, vcursor VCursor, ...) (*sqltypes.Result, error)

+ func (ps *UncorrelatedSubquery) GetKeyspaceName() string

+ func (ps *UncorrelatedSubquery) GetTableName() string

+ func (ps *UncorrelatedSubquery) Inputs() ([]Primitive, []map[string]any)

+ func (ps *UncorrelatedSubquery) NeedsTransaction() bool

+ func (ps *UncorrelatedSubquery) RouteType() string

+ func (ps *UncorrelatedSubquery) TryExecute(ctx context.Context, vcursor VCursor, ...) (*sqltypes.Result, error)

+ func (ps *UncorrelatedSubquery) TryStreamExecute(ctx context.Context, vcursor VCursor, ...) error

type VCursor

+ ThrottleApp func(ctx context.Context, throttleAppRule *topodatapb.ThrottledAppRule) error

+ type Verify struct

+ Exec Primitive

+ Typ string

+ func (cached *Verify) CachedSize(alloc bool) int64

type VindexValues

+ EvalExprMap map[string]evalengine.Expr

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 AggregateParams

+ Type sqltypes.Type

type CheckCol

+ Type sqltypes.Type

type GroupByParams

+ Type sqltypes.Type

type OrderByParams

+ Type querypb.Type

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

+ type ExecStmt struct

+ Input Primitive

+ Params []*sqlparser.Variable

+ func (ExecStmt) NeedsTransaction() bool

+ func (cached *ExecStmt) CachedSize(alloc bool) int64

+ func (e *ExecStmt) GetFields(ctx context.Context, vcursor VCursor, ...) (*sqltypes.Result, error)

+ func (e *ExecStmt) GetKeyspaceName() string

+ func (e *ExecStmt) GetTableName() string

+ func (e *ExecStmt) Inputs() []Primitive

+ func (e *ExecStmt) RouteType() string

+ func (e *ExecStmt) TryExecute(ctx context.Context, vcursor VCursor, ...) (*sqltypes.Result, error)

+ func (e *ExecStmt) TryStreamExecute(ctx context.Context, vcursor VCursor, ...) error

type SessionActions

+ GetUDV func(key string) *querypb.BindVariable

+ SetPriority func(string)

+ SetWorkloadName func(string)

type VCursor

+ TimeZone func() *time.Location

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

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

+ func CompareErrors(leftErr, rightErr error, leftName, rightName string) error

type ExecuteEntry

+ FiredFrom Primitive

+ Gateway srvtopo.Gateway

+ Target *querypb.Target

type SessionActions

+ GetQueryTimeout func(queryTimeoutFromComment int) int

+ GetVExplainLogs func() []ExecuteEntry

+ SetConsolidator func(querypb.ExecuteOptions_Consolidator)

+ SetQueryTimeout func(queryTimeout int64)

+ VExplainLogging func()

+ type VExplain struct

+ Input Primitive

+ Type sqlparser.VExplainType

+ func (cached *VExplain) CachedSize(alloc bool) int64

+ func (v *VExplain) GetFields(ctx context.Context, vcursor VCursor, ...) (*sqltypes.Result, error)

+ func (v *VExplain) GetKeyspaceName() string

+ func (v *VExplain) GetTableName() string

+ func (v *VExplain) Inputs() []Primitive

+ func (v *VExplain) NeedsTransaction() bool

+ func (v *VExplain) RouteType() string

+ func (v *VExplain) TryExecute(ctx context.Context, vcursor VCursor, ...) (*sqltypes.Result, error)

+ func (v *VExplain) TryStreamExecute(ctx context.Context, vcursor VCursor, ...) error

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

Oct 3, 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

Jul 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

Mar 30, 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

type VCursor

+ ExecutePrimitiveStandalone func(ctx context.Context, primitive Primitive, ...) (*sqltypes.Result, error)

Dec 14, 2022 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

Nov 29, 2022 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

Oct 25, 2022 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

+ func GraphViz(p Primitive) (*graphviz.Graph, error)

type DML

+ func (dml *DML) GetKeyspaceName() string

+ func (dml *DML) GetSingleTable() (*vindexes.Table, error)

+ func (dml *DML) GetTableName() string

+ func (dml *DML) RouteType() string

+ type ExecuteEntry struct

+ Cell string

+ ID int

+ Keyspace string

+ Query string

+ Shard string

+ TabletType topodatapb.TabletType

type Insert

+ ForceNonStreaming bool

type Plan

+ TablesUsed []string

type SessionActions

+ GetVTExplainLogs func() []ExecuteEntry

+ InTransaction func() bool

+ SetCommitOrder func(co vtgatepb.CommitOrder)

+ VtExplainLogging func()

type VCursor

+ StreamExecutePrimitiveStandalone func(ctx context.Context, primitive Primitive, ...) error

+ type VTExplain struct

+ Input Primitive

+ func (cached *VTExplain) CachedSize(alloc bool) int64

+ func (v *VTExplain) GetFields(ctx context.Context, vcursor VCursor, ...) (*sqltypes.Result, error)

+ func (v *VTExplain) GetKeyspaceName() string

+ func (v *VTExplain) GetTableName() string

+ func (v *VTExplain) Inputs() []Primitive

+ func (v *VTExplain) NeedsTransaction() bool

+ func (v *VTExplain) RouteType() string

+ func (v *VTExplain) TryExecute(ctx context.Context, vcursor VCursor, ...) (*sqltypes.Result, error)

+ func (v *VTExplain) TryStreamExecute(ctx context.Context, vcursor VCursor, ...) error

+ type VindexLookup struct

+ Arguments []string

+ Keyspace *vindexes.Keyspace

+ Lookup Primitive

+ Opcode Opcode

+ SendTo *Route

+ Values []evalengine.Expr

+ Vindex vindexes.LookupPlanable

+ func (cached *VindexLookup) CachedSize(alloc bool) int64

+ func (vr *VindexLookup) GetFields(ctx context.Context, vcursor VCursor, ...) (*sqltypes.Result, error)

+ func (vr *VindexLookup) GetKeyspaceName() string

+ func (vr *VindexLookup) GetTableName() string

+ func (vr *VindexLookup) Inputs() []Primitive

+ func (vr *VindexLookup) NeedsTransaction() bool

+ func (vr *VindexLookup) RouteType() string

+ func (vr *VindexLookup) TryExecute(ctx context.Context, vcursor VCursor, ...) (*sqltypes.Result, error)

+ func (vr *VindexLookup) TryStreamExecute(ctx context.Context, vcursor VCursor, ...) error

Mar 30, 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

Nov 29, 2022 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

Sep 1, 2022 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

Jul 26, 2022 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

Jun 28, 2022 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 AggregateCountStar

+ const AggregateRandom

+ const AggregateUnassigned

+ const InsertSelect

+ const SubShard

type AggregateParams

+ OrigOpcode AggregateOpcode

+ Original *sqlparser.AliasedExpr

+ type CheckCol struct

+ Col int

+ Collation collations.ID

+ WsCol *int

+ func (cached *CheckCol) CachedSize(alloc bool) int64

+ func (cc CheckCol) String() string

+ func (cc CheckCol) SwitchToWeightString() CheckCol

type Concatenate

+ NoNeedToTypeCheck map[int]any

+ func NewConcatenate(Sources []Primitive, ignoreCols []int) *Concatenate

type Distinct

+ CheckCols []CheckCol

+ Truncate bool

+ type DistinctV3 struct

+ Source Primitive

+ func (cached *DistinctV3) CachedSize(alloc bool) int64

+ func (d *DistinctV3) GetFields(vcursor VCursor, bindVars map[string]*querypb.BindVariable) (*sqltypes.Result, error)

+ func (d *DistinctV3) GetKeyspaceName() string

+ func (d *DistinctV3) GetTableName() string

+ func (d *DistinctV3) Inputs() []Primitive

+ func (d *DistinctV3) NeedsTransaction() bool

+ func (d *DistinctV3) RouteType() string

+ func (d *DistinctV3) TryExecute(vcursor VCursor, bindVars map[string]*querypb.BindVariable, wantfields bool) (*sqltypes.Result, error)

+ func (d *DistinctV3) TryStreamExecute(vcursor VCursor, bindVars map[string]*querypb.BindVariable, wantfields bool, ...) error

type Generate

+ Offset int

type Insert

+ Ignore bool

+ Input Primitive

+ VindexValueOffset [][]int

type Lock

+ LockFunctions []*LockFunc

+ type LockFunc struct

+ Name evalengine.Expr

+ Typ *sqlparser.LockingFunc

+ func (cached *LockFunc) CachedSize(alloc bool) int64

type OrderedAggregate

+ AggrOnEngine bool

+ type ScalarAggregate struct

+ AggrOnEngine bool

+ Aggregates []*AggregateParams

+ Collations map[int]collations.ID

+ Input Primitive

+ PreProcess bool

+ TruncateColumnCount int

+ func (cached *ScalarAggregate) CachedSize(alloc bool) int64

+ func (sa *ScalarAggregate) GetFields(vcursor VCursor, bindVars map[string]*querypb.BindVariable) (*sqltypes.Result, error)

+ func (sa *ScalarAggregate) GetKeyspaceName() string

+ func (sa *ScalarAggregate) GetTableName() string

+ func (sa *ScalarAggregate) Inputs() []Primitive

+ func (sa *ScalarAggregate) NeedsTransaction() bool

+ func (sa *ScalarAggregate) RouteType() string

+ func (sa *ScalarAggregate) TryExecute(vcursor VCursor, bindVars map[string]*querypb.BindVariable, wantfields bool) (*sqltypes.Result, error)

+ func (sa *ScalarAggregate) TryStreamExecute(vcursor VCursor, bindVars map[string]*querypb.BindVariable, wantfields bool, ...) error

type SessionActions

+ AddAdvisoryLock func(name string)

+ AnyAdvisoryLockTaken func() bool

+ GetSystemVariables func(func(k string, v string))

+ HasSystemVariables func() bool

+ RemoveAdvisoryLock func(name string)

+ type ShowExec struct

+ Command sqlparser.ShowCommandType

+ ShowFilter *sqlparser.ShowFilter

+ func (ShowExec) Inputs() []Primitive

+ func (ShowExec) NeedsTransaction() bool

+ func (cached *ShowExec) CachedSize(alloc bool) int64

+ func (s *ShowExec) GetFields(vcursor VCursor, bindVars map[string]*query.BindVariable) (*sqltypes.Result, error)

+ func (s *ShowExec) GetKeyspaceName() string

+ func (s *ShowExec) GetTableName() string

+ func (s *ShowExec) RouteType() string

+ func (s *ShowExec) TryExecute(vcursor VCursor, _ map[string]*query.BindVariable, _ bool) (*sqltypes.Result, error)

+ func (s *ShowExec) TryStreamExecute(vcursor VCursor, bindVars map[string]*query.BindVariable, wantfields bool, ...) error

type SysVarReservedConn

+ SupportSetVar bool

type VCursor

+ CanUseSetVar func() bool

+ ReleaseLock func() error

+ SetExec func(name string, value string) error

+ ShowExec func(command sqlparser.ShowCommandType, filter *sqlparser.ShowFilter) (*sqltypes.Result, error)

+ type VitessMetadata struct

+ Name string

+ Value string

+ func (cached *VitessMetadata) CachedSize(alloc bool) int64

+ func (v *VitessMetadata) Execute(vcursor VCursor, env *evalengine.ExpressionEnv) error

+ func (v *VitessMetadata) VariableName() string

Sep 1, 2022 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

Jul 26, 2022 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

type Opcode

+ func (code Opcode) IsSingleShard() bool

type Route

+ NoRoutesSpecialHandling bool

Apr 14, 2022 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 IgnoreReserveTxn

type VCursor

+ SetContextWithValue func(key, value interface{}) func()

Feb 22, 2022 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 DBA

+ const EqualUnique

+ const IN

+ const MultiEqual

+ const Next

+ const None

+ const NumOpcodes

+ const Reference

+ const RowChangeDelete

+ const RowChangeInsert

+ const RowChangeUpdate

type AggregateParams

+ CollationID collations.ID

type DML

+ KsidLength int

+ func NewDML() *DML

type Distinct

+ ColCollations []collations.ID

+ type Filter struct

+ ASTPredicate sqlparser.Expr

+ Input Primitive

+ Predicate evalengine.Expr

+ func (Filter) NeedsTransaction() bool

+ func (cached *Filter) CachedSize(alloc bool) int64

+ func (f *Filter) GetFields(vcursor VCursor, bindVars map[string]*querypb.BindVariable) (*sqltypes.Result, error)

+ func (f *Filter) GetKeyspaceName() string

+ func (f *Filter) GetTableName() string

+ func (f *Filter) Inputs() []Primitive

+ func (f *Filter) RouteType() string

+ func (f *Filter) TryExecute(vcursor VCursor, bindVars map[string]*querypb.BindVariable, wantfields bool) (*sqltypes.Result, error)

+ func (f *Filter) TryStreamExecute(vcursor VCursor, bindVars map[string]*querypb.BindVariable, wantfields bool, ...) error

type GroupByParams

+ CollationID collations.ID

+ type HashJoin struct

+ ASTPred sqlparser.Expr

+ Collation collations.ID

+ Cols []int

+ ComparisonType querypb.Type

+ LHSKey int

+ Left Primitive

+ Opcode JoinOpcode

+ RHSKey int

+ Right Primitive

+ func (cached *HashJoin) CachedSize(alloc bool) int64

+ func (hj *HashJoin) GetFields(vcursor VCursor, bindVars map[string]*querypb.BindVariable) (*sqltypes.Result, error)

+ func (hj *HashJoin) GetKeyspaceName() string

+ func (hj *HashJoin) GetTableName() string

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

+ func (hj *HashJoin) NeedsTransaction() bool

+ func (hj *HashJoin) RouteType() string

+ func (hj *HashJoin) TryExecute(vcursor VCursor, bindVars map[string]*querypb.BindVariable, wantfields bool) (*sqltypes.Result, error)

+ func (hj *HashJoin) TryStreamExecute(vcursor VCursor, bindVars map[string]*querypb.BindVariable, wantfields bool, ...) error

type Insert

+ ColVindexes []*vindexes.ColumnVindex

type Lock

+ FieldQuery string

+ type Opcode int

+ func (code Opcode) MarshalJSON() ([]byte, error)

+ func (code Opcode) String() string

type OrderByParams

+ CollationID collations.ID

type OrderedAggregate

+ Collations map[int]collations.ID

+ type RoutingParameters struct

+ Keyspace *vindexes.Keyspace

+ Opcode Opcode

+ SysTableTableName map[string]evalengine.Expr

+ SysTableTableSchema []evalengine.Expr

+ TargetDestination key.Destination

+ Values []evalengine.Expr

+ Vindex vindexes.Vindex

+ func (cached *RoutingParameters) CachedSize(alloc bool) int64

+ type SemiJoin struct

+ Cols []int

+ Left Primitive

+ Right Primitive

+ Vars map[string]int

+ func (cached *SemiJoin) CachedSize(alloc bool) int64

+ func (jn *SemiJoin) GetFields(vcursor VCursor, bindVars map[string]*querypb.BindVariable) (*sqltypes.Result, error)

+ func (jn *SemiJoin) GetKeyspaceName() string

+ func (jn *SemiJoin) GetTableName() string

+ func (jn *SemiJoin) Inputs() []Primitive

+ func (jn *SemiJoin) NeedsTransaction() bool

+ func (jn *SemiJoin) RouteType() string

+ func (jn *SemiJoin) TryExecute(vcursor VCursor, bindVars map[string]*querypb.BindVariable, wantfields bool) (*sqltypes.Result, error)

+ func (jn *SemiJoin) TryStreamExecute(vcursor VCursor, bindVars map[string]*querypb.BindVariable, wantfields bool, ...) error

type VCursor

+ ConnCollation func() collations.ID

+ ResolveDestinationsMultiCol func(keyspace string, ids [][]sqltypes.Value, destinations []key.Destination) ([]*srvtopo.ResolvedShard, [][][]sqltypes.Value, error)

Sep 1, 2022 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

Jul 27, 2022 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

May 20, 2022 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

type VCursor

+ CancelContext func()

Jan 10, 2022 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

Dec 17, 2021 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

Dec 14, 2021 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

Oct 26, 2021 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

+ var ErrWrongNumberOfColumnsInSelect = vterrors.NewErrorf(vtrpcpb.Code_FAILED_PRECONDITION, vterrors.WrongNumberOfColumnsInSelect, ...)

+ var OpcodeType = map[AggregateOpcode]querypb.Type

+ func CompareV3AndGen4Errors(v3Err, gen4Err error) error

type AggregateParams

+ Expr sqlparser.Expr

+ KeyCol int

+ WAssigned bool

+ WCol int

type AlterVSchema

+ func (v *AlterVSchema) TryExecute(vcursor VCursor, bindVars map[string]*query.BindVariable, wantfields bool) (*sqltypes.Result, error)

+ func (v *AlterVSchema) TryStreamExecute(vcursor VCursor, bindVars map[string]*query.BindVariable, wantields bool, ...) error

type Concatenate

+ func (c *Concatenate) TryExecute(vcursor VCursor, bindVars map[string]*querypb.BindVariable, wantfields bool) (*sqltypes.Result, error)

+ func (c *Concatenate) TryStreamExecute(vcursor VCursor, bindVars map[string]*querypb.BindVariable, wantfields bool, ...) error

type DBDDL

+ func (c *DBDDL) TryExecute(vcursor VCursor, _ map[string]*querypb.BindVariable, _ bool) (*sqltypes.Result, error)

+ func (c *DBDDL) TryStreamExecute(vcursor VCursor, bindVars map[string]*querypb.BindVariable, wantfields bool, ...) error

type DDL

+ func (ddl *DDL) TryExecute(vcursor VCursor, bindVars map[string]*query.BindVariable, wantfields bool) (result *sqltypes.Result, err error)

+ func (ddl *DDL) TryStreamExecute(vcursor VCursor, bindVars map[string]*query.BindVariable, wantfields bool, ...) error

type Delete

+ func (del *Delete) TryExecute(vcursor VCursor, bindVars map[string]*querypb.BindVariable, _ bool) (*sqltypes.Result, error)

+ func (del *Delete) TryStreamExecute(VCursor, map[string]*querypb.BindVariable, bool, func(*sqltypes.Result) error) error

type Distinct

+ func (d *Distinct) TryExecute(vcursor VCursor, bindVars map[string]*querypb.BindVariable, wantfields bool) (*sqltypes.Result, error)

+ func (d *Distinct) TryStreamExecute(vcursor VCursor, bindVars map[string]*querypb.BindVariable, wantfields bool, ...) error

+ type Gen4CompareV3 struct

+ Gen4 Primitive

+ HasOrderBy bool

+ V3 Primitive

+ func (cached *Gen4CompareV3) CachedSize(alloc bool) int64

+ func (gc *Gen4CompareV3) GetFields(vcursor VCursor, bindVars map[string]*querypb.BindVariable) (*sqltypes.Result, error)

+ func (gc *Gen4CompareV3) GetGen4Primitive() Primitive

+ func (gc *Gen4CompareV3) GetKeyspaceName() string

+ func (gc *Gen4CompareV3) GetTableName() string

+ func (gc *Gen4CompareV3) Inputs() []Primitive

+ func (gc *Gen4CompareV3) NeedsTransaction() bool

+ func (gc *Gen4CompareV3) RouteType() string

+ func (gc *Gen4CompareV3) TryExecute(vcursor VCursor, bindVars map[string]*querypb.BindVariable, wantfields bool) (*sqltypes.Result, error)

+ func (gc *Gen4CompareV3) TryStreamExecute(vcursor VCursor, bindVars map[string]*querypb.BindVariable, wantfields bool, ...) error

+ type Gen4Comparer interface

+ GetGen4Primitive func() Primitive

+ type GroupByParams struct

+ Expr sqlparser.Expr

+ FromGroupBy bool

+ KeyCol int

+ WeightStringCol int

+ func (cached *GroupByParams) CachedSize(alloc bool) int64

+ func (gbp GroupByParams) String() string

type Insert

+ func (ins *Insert) TryExecute(vcursor VCursor, bindVars map[string]*querypb.BindVariable, _ bool) (*sqltypes.Result, error)

+ func (ins *Insert) TryStreamExecute(VCursor, map[string]*querypb.BindVariable, bool, func(*sqltypes.Result) error) error

type Join

+ func (jn *Join) TryExecute(vcursor VCursor, bindVars map[string]*querypb.BindVariable, wantfields bool) (*sqltypes.Result, error)

+ func (jn *Join) TryStreamExecute(vcursor VCursor, bindVars map[string]*querypb.BindVariable, wantfields bool, ...) error

type Limit

+ func (l *Limit) TryExecute(vcursor VCursor, bindVars map[string]*querypb.BindVariable, wantfields bool) (*sqltypes.Result, error)

+ func (l *Limit) TryStreamExecute(vcursor VCursor, bindVars map[string]*querypb.BindVariable, wantfields bool, ...) error

type Lock

+ func (l *Lock) TryExecute(vcursor VCursor, bindVars map[string]*querypb.BindVariable, _ bool) (*sqltypes.Result, error)

+ func (l *Lock) TryStreamExecute(vcursor VCursor, bindVars map[string]*querypb.BindVariable, wantfields bool, ...) error

type MStream

+ func (m *MStream) TryExecute(vcursor VCursor, bindVars map[string]*querypb.BindVariable, wantfields bool) (*sqltypes.Result, error)

+ func (m *MStream) TryStreamExecute(vcursor VCursor, bindVars map[string]*querypb.BindVariable, wantfields bool, ...) error

type MemorySort

+ func (ms *MemorySort) TryExecute(vcursor VCursor, bindVars map[string]*querypb.BindVariable, wantfields bool) (*sqltypes.Result, error)

+ func (ms *MemorySort) TryStreamExecute(vcursor VCursor, bindVars map[string]*querypb.BindVariable, wantfields bool, ...) error

type MergeSort

+ func (ms *MergeSort) TryExecute(vcursor VCursor, bindVars map[string]*querypb.BindVariable, wantfields bool) (*sqltypes.Result, error)

+ func (ms *MergeSort) TryStreamExecute(vcursor VCursor, bindVars map[string]*querypb.BindVariable, wantfields bool, ...) error

type OnlineDDL

+ func (v *OnlineDDL) TryExecute(vcursor VCursor, bindVars map[string]*query.BindVariable, wantfields bool) (result *sqltypes.Result, err error)

+ func (v *OnlineDDL) TryStreamExecute(vcursor VCursor, bindVars map[string]*query.BindVariable, wantfields bool, ...) error

+ type OrderByParams struct

+ Col int

+ Desc bool

+ FromGroupBy bool

+ StarColFixedIndex int

+ WeightStringCol int

+ func (obp OrderByParams) String() string

type OrderedAggregate

+ GroupByKeys []*GroupByParams

+ func (oa *OrderedAggregate) TryExecute(vcursor VCursor, bindVars map[string]*querypb.BindVariable, wantfields bool) (*sqltypes.Result, error)

+ func (oa *OrderedAggregate) TryStreamExecute(vcursor VCursor, bindVars map[string]*querypb.BindVariable, wantfields bool, ...) error

type Primitive

+ TryExecute func(vcursor VCursor, bindVars map[string]*querypb.BindVariable, wantfields bool) (*sqltypes.Result, error)

+ TryStreamExecute func(vcursor VCursor, bindVars map[string]*querypb.BindVariable, wantfields bool, ...) error

type Projection

+ func (p *Projection) TryExecute(vcursor VCursor, bindVars map[string]*querypb.BindVariable, wantfields bool) (*sqltypes.Result, error)

+ func (p *Projection) TryStreamExecute(vcursor VCursor, bindVars map[string]*querypb.BindVariable, wantields bool, ...) error

type PulloutSubquery

+ func (ps *PulloutSubquery) TryExecute(vcursor VCursor, bindVars map[string]*querypb.BindVariable, wantfields bool) (*sqltypes.Result, error)

+ func (ps *PulloutSubquery) TryStreamExecute(vcursor VCursor, bindVars map[string]*querypb.BindVariable, wantfields bool, ...) error

type RenameFields

+ func (r *RenameFields) TryExecute(vcursor VCursor, bindVars map[string]*querypb.BindVariable, wantfields bool) (*sqltypes.Result, error)

+ func (r *RenameFields) TryStreamExecute(vcursor VCursor, bindVars map[string]*querypb.BindVariable, wantfields bool, ...) error

type ReplaceVariables

+ func (r *ReplaceVariables) TryExecute(vcursor VCursor, bindVars map[string]*querypb.BindVariable, wantfields bool) (*sqltypes.Result, error)

+ func (r *ReplaceVariables) TryStreamExecute(vcursor VCursor, bindVars map[string]*querypb.BindVariable, wantfields bool, ...) error

type RevertMigration

+ func (v *RevertMigration) TryExecute(vcursor VCursor, bindVars map[string]*query.BindVariable, wantfields bool) (result *sqltypes.Result, err error)

+ func (v *RevertMigration) TryStreamExecute(vcursor VCursor, bindVars map[string]*query.BindVariable, wantfields bool, ...) error

type Route

+ func (route *Route) TryExecute(vcursor VCursor, bindVars map[string]*querypb.BindVariable, wantfields bool) (*sqltypes.Result, error)

+ func (route *Route) TryStreamExecute(vcursor VCursor, bindVars map[string]*querypb.BindVariable, wantfields bool, ...) error

type RouteOpcode

+ func (code RouteOpcode) String() string

type Rows

+ func (r *Rows) TryExecute(VCursor, map[string]*querypb.BindVariable, bool) (*sqltypes.Result, error)

+ func (r *Rows) TryStreamExecute(vcursor VCursor, bindVars map[string]*querypb.BindVariable, wantields bool, ...) error

type SQLCalcFoundRows

+ func (s SQLCalcFoundRows) TryExecute(vcursor VCursor, bindVars map[string]*querypb.BindVariable, wantfields bool) (*sqltypes.Result, error)

+ func (s SQLCalcFoundRows) TryStreamExecute(vcursor VCursor, bindVars map[string]*querypb.BindVariable, wantfields bool, ...) error

type Send

+ MultishardAutocommit bool

+ func (s *Send) TryExecute(vcursor VCursor, bindVars map[string]*querypb.BindVariable, wantfields bool) (*sqltypes.Result, error)

+ func (s *Send) TryStreamExecute(vcursor VCursor, bindVars map[string]*querypb.BindVariable, wantfields bool, ...) error

type SessionPrimitive

+ func (s *SessionPrimitive) TryExecute(vcursor VCursor, _ map[string]*querypb.BindVariable, _ bool) (*sqltypes.Result, error)

+ func (s *SessionPrimitive) TryStreamExecute(vcursor VCursor, _ map[string]*querypb.BindVariable, _ bool, ...) error

type Set

+ func (s *Set) TryExecute(vcursor VCursor, bindVars map[string]*querypb.BindVariable, _ bool) (*sqltypes.Result, error)

+ func (s *Set) TryStreamExecute(vcursor VCursor, bindVars map[string]*querypb.BindVariable, wantields bool, ...) error

+ type SimpleProjection struct

+ Cols []int

+ Input Primitive

+ func (cached *SimpleProjection) CachedSize(alloc bool) int64

+ func (sc *SimpleProjection) GetFields(vcursor VCursor, bindVars map[string]*querypb.BindVariable) (*sqltypes.Result, error)

+ func (sc *SimpleProjection) GetKeyspaceName() string

+ func (sc *SimpleProjection) GetTableName() string

+ func (sc *SimpleProjection) Inputs() []Primitive

+ func (sc *SimpleProjection) NeedsTransaction() bool

+ func (sc *SimpleProjection) RouteType() string

+ func (sc *SimpleProjection) TryExecute(vcursor VCursor, bindVars map[string]*querypb.BindVariable, wantfields bool) (*sqltypes.Result, error)

+ func (sc *SimpleProjection) TryStreamExecute(vcursor VCursor, bindVars map[string]*querypb.BindVariable, wantfields bool, ...) error

type SingleRow

+ func (s *SingleRow) TryExecute(VCursor, map[string]*query.BindVariable, bool) (*sqltypes.Result, error)

+ func (s *SingleRow) TryStreamExecute(_ VCursor, _ map[string]*query.BindVariable, _ bool, ...) error

type Update

+ func (upd *Update) TryExecute(vcursor VCursor, bindVars map[string]*querypb.BindVariable, wantfields bool) (*sqltypes.Result, error)

+ func (upd *Update) TryStreamExecute(vcursor VCursor, bindVars map[string]*querypb.BindVariable, wantfields bool, ...) error

type UpdateTarget

+ func (updTarget *UpdateTarget) TryExecute(vcursor VCursor, bindVars map[string]*query.BindVariable, wantfields bool) (*sqltypes.Result, error)

+ func (updTarget *UpdateTarget) TryStreamExecute(vcursor VCursor, bindVars map[string]*query.BindVariable, wantfields bool, ...) error

type VCursor

+ ExecutePrimitive func(primitive Primitive, bindVars map[string]*querypb.BindVariable, ...) (*sqltypes.Result, error)

+ StreamExecutePrimitive func(primitive Primitive, bindVars map[string]*querypb.BindVariable, ...) error

type VStream

+ func (v *VStream) TryExecute(_ VCursor, _ map[string]*querypb.BindVariable, wantfields bool) (*sqltypes.Result, error)

+ func (v *VStream) TryStreamExecute(vcursor VCursor, bindVars map[string]*querypb.BindVariable, wantfields bool, ...) error

type VindexFunc

+ func (vf *VindexFunc) TryExecute(vcursor VCursor, bindVars map[string]*querypb.BindVariable, wantfields bool) (*sqltypes.Result, error)

+ func (vf *VindexFunc) TryStreamExecute(vcursor VCursor, bindVars map[string]*querypb.BindVariable, wantfields bool, ...) error

Jan 10, 2022 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

Dec 17, 2021 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

Dec 14, 2021 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

Sep 9, 2021 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

Jul 27, 2021 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 AggregateGtid

+ const InnerJoin

+ const ShardName

type DDL

+ DirectDDLEnabled bool

+ type MStream struct

+ Keyspace *vindexes.Keyspace

+ TableName string

+ TargetDestination key.Destination

+ func (MStream) Inputs() []Primitive

+ func (MStream) NeedsTransaction() bool

+ func (cached *MStream) CachedSize(alloc bool) int64

+ func (m *MStream) Execute(vcursor VCursor, bindVars map[string]*querypb.BindVariable, wantfields bool) (*sqltypes.Result, error)

+ func (m *MStream) GetFields(vcursor VCursor, bindVars map[string]*querypb.BindVariable) (*sqltypes.Result, error)

+ func (m *MStream) GetKeyspaceName() string

+ func (m *MStream) GetTableName() string

+ func (m *MStream) RouteType() string

+ func (m *MStream) StreamExecute(vcursor VCursor, bindVars map[string]*querypb.BindVariable, wantfields bool, ...) error

type MergeSort

+ ScatterErrorsAsWarnings bool

type OnlineDDL

+ DDLStrategySetting *schema.DDLStrategySetting

+ TargetDestination key.Destination

type OrderbyParams

+ StarColFixedIndex int

type OrderedAggregate

+ PreProcess bool

type RevertMigration

+ TargetDestination key.Destination

type Send

+ ShardNameNeeded bool

type SessionActions

+ GetWarnings func() []*querypb.QueryWarning

+ type SessionPrimitive struct

+ func NewSessionPrimitive(name string, action func(sa SessionActions) (*sqltypes.Result, error)) *SessionPrimitive

+ func (SessionPrimitive) Inputs() []Primitive

+ func (SessionPrimitive) NeedsTransaction() bool

+ func (cached *SessionPrimitive) CachedSize(alloc bool) int64

+ func (s *SessionPrimitive) Execute(vcursor VCursor, _ map[string]*querypb.BindVariable, _ bool) (*sqltypes.Result, error)

+ func (s *SessionPrimitive) GetFields(_ VCursor, _ map[string]*querypb.BindVariable) (*sqltypes.Result, error)

+ func (s *SessionPrimitive) GetKeyspaceName() string

+ func (s *SessionPrimitive) GetTableName() string

+ func (s *SessionPrimitive) RouteType() string

+ func (s *SessionPrimitive) StreamExecute(vcursor VCursor, _ map[string]*querypb.BindVariable, _ bool, ...) error

type VCursor

+ MessageStream func(rss []*srvtopo.ResolvedShard, tableName string, ...) error

+ VStream func(rss []*srvtopo.ResolvedShard, filter *binlogdatapb.Filter, gtid string, ...) error

+ type VStream struct

+ Keyspace *vindexes.Keyspace

+ Limit int

+ Position string

+ TableName string

+ TargetDestination key.Destination

+ func (VStream) Inputs() []Primitive

+ func (VStream) NeedsTransaction() bool

+ func (cached *VStream) CachedSize(alloc bool) int64

+ func (v *VStream) Execute(_ VCursor, _ map[string]*querypb.BindVariable, wantfields bool) (*sqltypes.Result, error)

+ func (v *VStream) GetFields(_ VCursor, _ map[string]*querypb.BindVariable) (*sqltypes.Result, error)

+ func (v *VStream) GetKeyspaceName() string

+ func (v *VStream) GetTableName() string

+ func (v *VStream) RouteType() string

+ func (v *VStream) StreamExecute(vcursor VCursor, bindVars map[string]*querypb.BindVariable, wantfields bool, ...) error

Jan 10, 2022 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

Dec 17, 2021 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

Dec 14, 2021 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

type OrderbyParams

+ FromGroupBy bool

type OrderedAggregate

+ FromGroupBy []bool

May 27, 2021 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

May 4, 2021 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

Apr 27, 2021 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

+ func DBDDLRegister(name string, plugin DBDDLPlugin)

type AggregateParams

+ func (cached *AggregateParams) CachedSize(alloc bool) int64

type AlterVSchema

+ func (cached *AlterVSchema) CachedSize(alloc bool) int64

type Concatenate

+ func (cached *Concatenate) CachedSize(alloc bool) int64

+ type DBDDL struct

+ func NewDBDDL(dbName string, create bool, timeout int) *DBDDL

+ func (DBDDL) Inputs() []Primitive

+ func (DBDDL) NeedsTransaction() bool

+ func (c *DBDDL) Execute(vcursor VCursor, _ map[string]*querypb.BindVariable, _ bool) (*sqltypes.Result, error)

+ func (c *DBDDL) GetFields(VCursor, map[string]*querypb.BindVariable) (*sqltypes.Result, error)

+ func (c *DBDDL) GetKeyspaceName() string

+ func (c *DBDDL) GetTableName() string

+ func (c *DBDDL) RouteType() string

+ func (c *DBDDL) StreamExecute(vcursor VCursor, bindVars map[string]*querypb.BindVariable, wantfields bool, ...) error

+ func (cached *DBDDL) CachedSize(alloc bool) int64

+ type DBDDLPlugin interface

+ CreateDatabase func(ctx context.Context, name string) error

+ DropDatabase func(ctx context.Context, name string) error

type DDL

+ CreateTempTable bool

+ OnlineDDLEnabled bool

+ func (cached *DDL) CachedSize(alloc bool) int64

type DML

+ func (cached *DML) CachedSize(alloc bool) int64

type Delete

+ func (cached *Delete) CachedSize(alloc bool) int64

type Distinct

+ func (cached *Distinct) CachedSize(alloc bool) int64

type Generate

+ func (cached *Generate) CachedSize(alloc bool) int64

type Insert

+ func (cached *Insert) CachedSize(alloc bool) int64

type Join

+ func (cached *Join) CachedSize(alloc bool) int64

type Limit

+ func (cached *Limit) CachedSize(alloc bool) int64

type Lock

+ func (cached *Lock) CachedSize(alloc bool) int64

type MemorySort

+ func (cached *MemorySort) CachedSize(alloc bool) int64

type MergeSort

+ func (cached *MergeSort) CachedSize(alloc bool) int64

type OnlineDDL

+ func (cached *OnlineDDL) CachedSize(alloc bool) int64

type OrderbyParams

+ WeightStringCol int

type OrderedAggregate

+ func (cached *OrderedAggregate) CachedSize(alloc bool) int64

type Plan

+ RowsAffected uint64

+ RowsReturned uint64

+ Warnings []*querypb.QueryWarning

+ func (cached *Plan) CachedSize(alloc bool) int64

type Projection

+ func (cached *Projection) CachedSize(alloc bool) int64

type PulloutSubquery

+ func (cached *PulloutSubquery) CachedSize(alloc bool) int64

+ type RenameFields struct

+ Cols []string

+ Indices []int

+ Input Primitive

+ func NewRenameField(cols []string, indices []int, input Primitive) (*RenameFields, error)

+ func (RenameFields) NeedsTransaction() bool

+ func (cached *RenameFields) CachedSize(alloc bool) int64

+ func (r *RenameFields) Execute(vcursor VCursor, bindVars map[string]*querypb.BindVariable, wantfields bool) (*sqltypes.Result, error)

+ func (r *RenameFields) GetFields(vcursor VCursor, bindVars map[string]*querypb.BindVariable) (*sqltypes.Result, error)

+ func (r *RenameFields) GetKeyspaceName() string

+ func (r *RenameFields) GetTableName() string

+ func (r *RenameFields) Inputs() []Primitive

+ func (r *RenameFields) RouteType() string

+ func (r *RenameFields) StreamExecute(vcursor VCursor, bindVars map[string]*querypb.BindVariable, wantfields bool, ...) error

+ type ReplaceVariables struct

+ Input Primitive

+ func NewReplaceVariables(input Primitive) *ReplaceVariables

+ func (ReplaceVariables) NeedsTransaction() bool

+ func (cached *ReplaceVariables) CachedSize(alloc bool) int64

+ func (r *ReplaceVariables) Execute(vcursor VCursor, bindVars map[string]*querypb.BindVariable, wantfields bool) (*sqltypes.Result, error)

+ func (r *ReplaceVariables) GetFields(vcursor VCursor, bindVars map[string]*querypb.BindVariable) (*sqltypes.Result, error)

+ func (r *ReplaceVariables) GetKeyspaceName() string

+ func (r *ReplaceVariables) GetTableName() string

+ func (r *ReplaceVariables) Inputs() []Primitive

+ func (r *ReplaceVariables) RouteType() string

+ func (r *ReplaceVariables) StreamExecute(vcursor VCursor, bindVars map[string]*querypb.BindVariable, wantfields bool, ...) error

+ type RevertMigration struct

+ Keyspace *vindexes.Keyspace

+ Query string

+ Stmt *sqlparser.RevertMigration

+ func (RevertMigration) Inputs() []Primitive

+ func (RevertMigration) NeedsTransaction() bool

+ func (cached *RevertMigration) CachedSize(alloc bool) int64

+ func (v *RevertMigration) Execute(vcursor VCursor, bindVars map[string]*query.BindVariable, wantfields bool) (result *sqltypes.Result, err error)

+ func (v *RevertMigration) GetFields(vcursor VCursor, bindVars map[string]*query.BindVariable) (*sqltypes.Result, error)

+ func (v *RevertMigration) GetKeyspaceName() string

+ func (v *RevertMigration) GetTableName() string

+ func (v *RevertMigration) RouteType() string

+ func (v *RevertMigration) StreamExecute(vcursor VCursor, bindVars map[string]*query.BindVariable, wantfields bool, ...) error

type Route

+ func (cached *Route) CachedSize(alloc bool) int64

type Rows

+ func (cached *Rows) CachedSize(alloc bool) int64

type SQLCalcFoundRows

+ func (cached *SQLCalcFoundRows) CachedSize(alloc bool) int64

type Send

+ func (cached *Send) CachedSize(alloc bool) int64

type SessionActions

+ GetSessionEnableSystemSettings func() bool

+ HasCreatedTempTable func()

+ SetPlannerVersion func(querypb.ExecuteOptions_PlannerVersion)

+ SetSessionEnableSystemSettings func(bool) error

type Set

+ func (cached *Set) CachedSize(alloc bool) int64

type Subquery

+ func (cached *Subquery) CachedSize(alloc bool) int64

type SysVarCheckAndIgnore

+ func (cached *SysVarCheckAndIgnore) CachedSize(alloc bool) int64

type SysVarIgnore

+ func (cached *SysVarIgnore) CachedSize(alloc bool) int64

type SysVarReservedConn

+ func (cached *SysVarReservedConn) CachedSize(alloc bool) int64

type SysVarSetAware

+ func (cached *SysVarSetAware) CachedSize(alloc bool) int64

type Update

+ func (cached *Update) CachedSize(alloc bool) int64

type UpdateTarget

+ func (cached *UpdateTarget) CachedSize(alloc bool) int64

type UserDefinedVariable

+ func (cached *UserDefinedVariable) CachedSize(alloc bool) int64

type VCursor

+ GetDBDDLPluginName func() string

+ KeyspaceAvailable func(ks string) bool

type VindexFunc

+ func (cached *VindexFunc) CachedSize(alloc bool) int64

type VindexValues

+ func (cached *VindexValues) CachedSize(alloc bool) int64

May 25, 2021 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

May 6, 2021 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

Jan 25, 2021 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 BvTableName

+ const SelectMultiEqual

type AlterVSchema

+ AlterVschemaDDL *sqlparser.AlterVschema

+ type DDL struct

+ DDL sqlparser.DDLStatement

+ Keyspace *vindexes.Keyspace

+ NormalDDL *Send

+ OnlineDDL *OnlineDDL

+ SQL string

+ func (DDL) Inputs() []Primitive

+ func (DDL) NeedsTransaction() bool

+ func (v *DDL) Execute(vcursor VCursor, bindVars map[string]*query.BindVariable, wantfields bool) (result *sqltypes.Result, err error)

+ func (v *DDL) GetFields(vcursor VCursor, bindVars map[string]*query.BindVariable) (*sqltypes.Result, error)

+ func (v *DDL) GetKeyspaceName() string

+ func (v *DDL) GetTableName() string

+ func (v *DDL) RouteType() string

+ func (v *DDL) StreamExecute(vcursor VCursor, bindVars map[string]*query.BindVariable, wantfields bool, ...) error

+ type Distinct struct

+ Source Primitive

+ func (d *Distinct) Execute(vcursor VCursor, bindVars map[string]*querypb.BindVariable, wantfields bool) (*sqltypes.Result, error)

+ func (d *Distinct) GetFields(vcursor VCursor, bindVars map[string]*querypb.BindVariable) (*sqltypes.Result, error)

+ func (d *Distinct) GetKeyspaceName() string

+ func (d *Distinct) GetTableName() string

+ func (d *Distinct) Inputs() []Primitive

+ func (d *Distinct) NeedsTransaction() bool

+ func (d *Distinct) RouteType() string

+ func (d *Distinct) StreamExecute(vcursor VCursor, bindVars map[string]*querypb.BindVariable, wantfields bool, ...) error

type Route

+ SysTableTableName evalengine.Expr

+ SysTableTableSchema evalengine.Expr

type SessionActions

+ GetDDLStrategy func() string

+ GetSessionUUID func() string

+ SetDDLStrategy func(string)

+ SetReadAfterWriteGTID func(string)

+ SetReadAfterWriteTimeout func(float64)

+ SetSessionTrackGTIDs func(bool)

type VCursor

+ FindRoutedTable func(tablename sqlparser.TableName) (*vindexes.Table, error)

+ GetKeyspace func() string

Oct 27, 2020 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 NumRouteOpcodes

+ type Lock struct

+ Keyspace *vindexes.Keyspace

+ Query string

+ TargetDestination key.Destination

+ func (Lock) Inputs() []Primitive

+ func (Lock) NeedsTransaction() bool

+ func (l *Lock) Execute(vcursor VCursor, bindVars map[string]*querypb.BindVariable, _ bool) (*sqltypes.Result, error)

+ func (l *Lock) GetFields(vcursor VCursor, bindVars map[string]*querypb.BindVariable) (*sqltypes.Result, error)

+ func (l *Lock) GetKeyspaceName() string

+ func (l *Lock) GetTableName() string

+ func (l *Lock) RouteType() string

+ func (l *Lock) StreamExecute(vcursor VCursor, bindVars map[string]*querypb.BindVariable, wantfields bool, ...) error

+ type OnlineDDL struct

+ DDL *sqlparser.DDL

+ Keyspace *vindexes.Keyspace

+ Options string

+ SQL string

+ Strategy sqlparser.DDLStrategy

+ func (OnlineDDL) Inputs() []Primitive

+ func (OnlineDDL) NeedsTransaction() bool

+ func (v *OnlineDDL) Execute(vcursor VCursor, bindVars map[string]*query.BindVariable, wantfields bool) (result *sqltypes.Result, err error)

+ func (v *OnlineDDL) GetFields(vcursor VCursor, bindVars map[string]*query.BindVariable) (*sqltypes.Result, error)

+ func (v *OnlineDDL) GetKeyspaceName() string

+ func (v *OnlineDDL) GetTableName() string

+ func (v *OnlineDDL) RouteType() string

+ func (v *OnlineDDL) StreamExecute(vcursor VCursor, bindVars map[string]*query.BindVariable, wantields bool, ...) error

type Plan

+ BindVarNeeds *sqlparser.BindVarNeeds

type Route

+ SysTableKeyspaceExpr []evalengine.Expr

+ type SQLCalcFoundRows struct

+ CountPrimitive Primitive

+ LimitPrimitive Primitive

+ func (s SQLCalcFoundRows) Execute(vcursor VCursor, bindVars map[string]*querypb.BindVariable, wantfields bool) (*sqltypes.Result, error)

+ func (s SQLCalcFoundRows) GetFields(vcursor VCursor, bindVars map[string]*querypb.BindVariable) (*sqltypes.Result, error)

+ func (s SQLCalcFoundRows) GetKeyspaceName() string

+ func (s SQLCalcFoundRows) GetTableName() string

+ func (s SQLCalcFoundRows) Inputs() []Primitive

+ func (s SQLCalcFoundRows) NeedsTransaction() bool

+ func (s SQLCalcFoundRows) RouteType() string

+ func (s SQLCalcFoundRows) StreamExecute(vcursor VCursor, bindVars map[string]*querypb.BindVariable, wantfields bool, ...) error

type SessionActions

+ SetAutocommit func(bool) error

+ SetClientFoundRows func(bool) error

+ SetFoundRows func(uint64)

+ SetSQLSelectLimit func(int64) error

+ SetSkipQueryPlanCache func(bool) error

+ SetTransactionMode func(vtgatepb.TransactionMode)

+ SetWorkload func(querypb.ExecuteOptions_Workload)

+ type SysVarReservedConn struct

+ Expr string

+ Keyspace *vindexes.Keyspace

+ Name string

+ TargetDestination key.Destination

+ func (svs *SysVarReservedConn) Execute(vcursor VCursor, env evalengine.ExpressionEnv) error

+ func (svs *SysVarReservedConn) MarshalJSON() ([]byte, error)

+ func (svs *SysVarReservedConn) VariableName() string

+ type SysVarSetAware struct

+ Expr evalengine.Expr

+ Name string

+ func (svss *SysVarSetAware) Execute(vcursor VCursor, env evalengine.ExpressionEnv) error

+ func (svss *SysVarSetAware) MarshalJSON() ([]byte, error)

+ func (svss *SysVarSetAware) VariableName() string

type VCursor

+ ExecuteLock func(rs *srvtopo.ResolvedShard, query *querypb.BoundQuery) (*sqltypes.Result, error)

+ InTransactionAndIsDML func() bool

+ LookupRowLockShardSession func() vtgatepb.CommitOrder

+ SubmitOnlineDDL func(onlineDDl *schema.OnlineDDL) error

type VindexValues

+ Offset int

+ PvMap map[string]sqltypes.PlanValue

Jul 28, 2020 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 AggregateCount

+ const AggregateCountDistinct

+ const AggregateMax

+ const AggregateMin

+ const AggregateSum

+ const AggregateSumDistinct

+ const ByDestination

+ const Equal

+ const In

+ const InsertSharded

+ const InsertShardedIgnore

+ const InsertUnsharded

+ const LeftJoin

+ const ListVarName

+ const NormalJoin

+ const NumVindexCodes

+ const PulloutExists

+ const PulloutIn

+ const PulloutNotIn

+ const PulloutValue

+ const Scatter

+ const SelectDBA

+ const SelectEqual

+ const SelectEqualUnique

+ const SelectIN

+ const SelectNext

+ const SelectNone

+ const SelectReference

+ const SelectScatter

+ const SelectUnsharded

+ const SeqVarName

+ const Unsharded

+ const VindexMap

+ const VindexNone

+ var SupportedAggregates = map[string]AggregateOpcode

+ func Exists(m Match, p Primitive) bool

+ func GenericJoin(input interface{}, f func(interface{}) string) string

+ func InsertVarName(col sqlparser.ColIdent, rowNum int) string

+ type AggregateOpcode int

+ func (code AggregateOpcode) MarshalJSON() ([]byte, error)

+ func (code AggregateOpcode) String() string

+ type AggregateParams struct

+ Alias string

+ Col int

+ Opcode AggregateOpcode

+ func (ap AggregateParams) String() string

+ type AlterVSchema struct

+ DDL *sqlparser.DDL

+ Keyspace *vindexes.Keyspace

+ func (AlterVSchema) Inputs() []Primitive

+ func (AlterVSchema) NeedsTransaction() bool

+ func (v *AlterVSchema) Execute(vcursor VCursor, bindVars map[string]*query.BindVariable, wantfields bool) (*sqltypes.Result, error)

+ func (v *AlterVSchema) GetFields(vcursor VCursor, bindVars map[string]*query.BindVariable) (*sqltypes.Result, error)

+ func (v *AlterVSchema) GetKeyspaceName() string

+ func (v *AlterVSchema) GetTableName() string

+ func (v *AlterVSchema) RouteType() string

+ func (v *AlterVSchema) StreamExecute(vcursor VCursor, bindVars map[string]*query.BindVariable, wantields bool, ...) error

+ type Concatenate struct

+ Sources []Primitive

+ func (c *Concatenate) Execute(vcursor VCursor, bindVars map[string]*querypb.BindVariable, wantfields bool) (*sqltypes.Result, error)

+ func (c *Concatenate) GetFields(vcursor VCursor, bindVars map[string]*querypb.BindVariable) (*sqltypes.Result, error)

+ func (c *Concatenate) GetKeyspaceName() string

+ func (c *Concatenate) GetTableName() string

+ func (c *Concatenate) Inputs() []Primitive

+ func (c *Concatenate) NeedsTransaction() bool

+ func (c *Concatenate) RouteType() string

+ func (c *Concatenate) StreamExecute(vcursor VCursor, bindVars map[string]*querypb.BindVariable, wantfields bool, ...) error

+ type DML struct

+ Keyspace *vindexes.Keyspace

+ KsidVindex vindexes.SingleColumn

+ MultiShardAutocommit bool

+ Opcode DMLOpcode

+ OwnedVindexQuery string

+ Query string

+ QueryTimeout int

+ Table *vindexes.Table

+ TargetDestination key.Destination

+ Values []sqltypes.PlanValue

+ Vindex vindexes.SingleColumn

+ func (DML) NeedsTransaction() bool

+ type DMLOpcode int

+ func (op DMLOpcode) String() string

+ type Delete struct

+ func (Delete) Inputs() []Primitive

+ func (Delete) NeedsTransaction() bool

+ func (del *Delete) Execute(vcursor VCursor, bindVars map[string]*querypb.BindVariable, _ bool) (*sqltypes.Result, error)

+ func (del *Delete) GetFields(VCursor, map[string]*querypb.BindVariable) (*sqltypes.Result, error)

+ func (del *Delete) GetKeyspaceName() string

+ func (del *Delete) GetTableName() string

+ func (del *Delete) RouteType() string

+ func (del *Delete) StreamExecute(VCursor, map[string]*querypb.BindVariable, bool, func(*sqltypes.Result) error) error

+ type Generate struct

+ Keyspace *vindexes.Keyspace

+ Query string

+ Values sqltypes.PlanValue

+ type Insert struct

+ Generate *Generate

+ Keyspace *vindexes.Keyspace

+ Mid []string

+ MultiShardAutocommit bool

+ Opcode InsertOpcode

+ Prefix string

+ Query string

+ QueryTimeout int

+ Suffix string

+ Table *vindexes.Table

+ VindexValues []sqltypes.PlanValue

+ func NewInsert(opcode InsertOpcode, keyspace *vindexes.Keyspace, ...) *Insert

+ func NewQueryInsert(opcode InsertOpcode, keyspace *vindexes.Keyspace, query string) *Insert

+ func NewSimpleInsert(opcode InsertOpcode, table *vindexes.Table, keyspace *vindexes.Keyspace) *Insert

+ func (Insert) Inputs() []Primitive

+ func (Insert) NeedsTransaction() bool

+ func (ins *Insert) Execute(vcursor VCursor, bindVars map[string]*querypb.BindVariable, wantfields bool) (*sqltypes.Result, error)

+ func (ins *Insert) GetFields(vcursor VCursor, bindVars map[string]*querypb.BindVariable) (*sqltypes.Result, error)

+ func (ins *Insert) GetKeyspaceName() string

+ func (ins *Insert) GetTableName() string

+ func (ins *Insert) RouteType() string

+ func (ins *Insert) StreamExecute(vcursor VCursor, bindVars map[string]*querypb.BindVariable, wantfields bool, ...) error

+ type InsertOpcode int

+ func (code InsertOpcode) MarshalJSON() ([]byte, error)

+ func (code InsertOpcode) String() string

+ type Join struct

+ Cols []int

+ Left Primitive

+ Opcode JoinOpcode

+ Right Primitive

+ Vars map[string]int

+ func (jn *Join) Execute(vcursor VCursor, bindVars map[string]*querypb.BindVariable, wantfields bool) (*sqltypes.Result, error)

+ func (jn *Join) GetFields(vcursor VCursor, bindVars map[string]*querypb.BindVariable) (*sqltypes.Result, error)

+ func (jn *Join) GetKeyspaceName() string

+ func (jn *Join) GetTableName() string

+ func (jn *Join) Inputs() []Primitive

+ func (jn *Join) NeedsTransaction() bool

+ func (jn *Join) RouteType() string

+ func (jn *Join) StreamExecute(vcursor VCursor, bindVars map[string]*querypb.BindVariable, wantfields bool, ...) error

+ type JoinOpcode int

+ func (code JoinOpcode) MarshalJSON() ([]byte, error)

+ func (code JoinOpcode) String() string

+ type Limit struct

+ Count sqltypes.PlanValue

+ Input Primitive

+ Offset sqltypes.PlanValue

+ func (l *Limit) Execute(vcursor VCursor, bindVars map[string]*querypb.BindVariable, wantfields bool) (*sqltypes.Result, error)

+ func (l *Limit) GetFields(vcursor VCursor, bindVars map[string]*querypb.BindVariable) (*sqltypes.Result, error)

+ func (l *Limit) GetKeyspaceName() string

+ func (l *Limit) GetTableName() string

+ func (l *Limit) Inputs() []Primitive

+ func (l *Limit) NeedsTransaction() bool

+ func (l *Limit) RouteType() string

+ func (l *Limit) StreamExecute(vcursor VCursor, bindVars map[string]*querypb.BindVariable, wantfields bool, ...) error

+ type Match func(node Primitive) bool

+ type MemorySort struct

+ Input Primitive

+ OrderBy []OrderbyParams

+ TruncateColumnCount int

+ UpperLimit sqltypes.PlanValue

+ func (ms *MemorySort) Execute(vcursor VCursor, bindVars map[string]*querypb.BindVariable, wantfields bool) (*sqltypes.Result, error)

+ func (ms *MemorySort) GetFields(vcursor VCursor, bindVars map[string]*querypb.BindVariable) (*sqltypes.Result, error)

+ func (ms *MemorySort) GetKeyspaceName() string

+ func (ms *MemorySort) GetTableName() string

+ func (ms *MemorySort) Inputs() []Primitive

+ func (ms *MemorySort) NeedsTransaction() bool

+ func (ms *MemorySort) RouteType() string

+ func (ms *MemorySort) SetTruncateColumnCount(count int)

+ func (ms *MemorySort) StreamExecute(vcursor VCursor, bindVars map[string]*querypb.BindVariable, wantfields bool, ...) error

+ type MergeSort struct

+ OrderBy []OrderbyParams

+ Primitives []StreamExecutor

+ func (MergeSort) Inputs() []Primitive

+ func (MergeSort) NeedsTransaction() bool

+ func (ms *MergeSort) Execute(vcursor VCursor, bindVars map[string]*querypb.BindVariable, wantfields bool) (*sqltypes.Result, error)

+ func (ms *MergeSort) GetFields(vcursor VCursor, bindVars map[string]*querypb.BindVariable) (*sqltypes.Result, error)

+ func (ms *MergeSort) GetKeyspaceName() string

+ func (ms *MergeSort) GetTableName() string

+ func (ms *MergeSort) RouteType() string

+ func (ms *MergeSort) StreamExecute(vcursor VCursor, bindVars map[string]*querypb.BindVariable, wantfields bool, ...) error

+ type OrderbyParams struct

+ Col int

+ Desc bool

+ func (obp OrderbyParams) String() string

+ type OrderedAggregate struct

+ Aggregates []AggregateParams

+ HasDistinct bool

+ Input Primitive

+ Keys []int

+ TruncateColumnCount int

+ func (oa *OrderedAggregate) Execute(vcursor VCursor, bindVars map[string]*querypb.BindVariable, wantfields bool) (*sqltypes.Result, error)

+ func (oa *OrderedAggregate) GetFields(vcursor VCursor, bindVars map[string]*querypb.BindVariable) (*sqltypes.Result, error)

+ func (oa *OrderedAggregate) GetKeyspaceName() string

+ func (oa *OrderedAggregate) GetTableName() string

+ func (oa *OrderedAggregate) Inputs() []Primitive

+ func (oa *OrderedAggregate) NeedsTransaction() bool

+ func (oa *OrderedAggregate) RouteType() string

+ func (oa *OrderedAggregate) SetTruncateColumnCount(count int)

+ func (oa *OrderedAggregate) StreamExecute(vcursor VCursor, bindVars map[string]*querypb.BindVariable, wantfields bool, ...) error

+ type Plan struct

+ Errors uint64

+ ExecCount uint64

+ ExecTime time.Duration

+ Instructions Primitive

+ Original string

+ Rows uint64

+ ShardQueries uint64

+ Type sqlparser.StatementType

+ func (p *Plan) AddStats(execCount uint64, execTime time.Duration, shardQueries, rows, errors uint64)

+ func (p *Plan) MarshalJSON() ([]byte, error)

+ func (p *Plan) Size() int

+ func (p *Plan) Stats() (execCount uint64, execTime time.Duration, shardQueries, rows, errors uint64)

+ type Primitive interface

+ Execute func(vcursor VCursor, bindVars map[string]*querypb.BindVariable, wantfields bool) (*sqltypes.Result, error)

+ GetFields func(vcursor VCursor, bindVars map[string]*querypb.BindVariable) (*sqltypes.Result, error)

+ GetKeyspaceName func() string

+ GetTableName func() string

+ Inputs func() []Primitive

+ NeedsTransaction func() bool

+ RouteType func() string

+ StreamExecute func(vcursor VCursor, bindVars map[string]*querypb.BindVariable, wantfields bool, ...) error

+ func Find(isMatch Match, start Primitive) Primitive

+ type PrimitiveDescription struct

+ Inputs []PrimitiveDescription

+ Keyspace *vindexes.Keyspace

+ OperatorType string

+ Other map[string]interface{}

+ TargetDestination key.Destination

+ TargetTabletType topodatapb.TabletType

+ Variant string

+ func PrimitiveToPlanDescription(in Primitive) PrimitiveDescription

+ func (pd PrimitiveDescription) MarshalJSON() ([]byte, error)

+ type Projection struct

+ Cols []string

+ Exprs []evalengine.Expr

+ Input Primitive

+ func (Projection) NeedsTransaction() bool

+ func (p *Projection) Execute(vcursor VCursor, bindVars map[string]*querypb.BindVariable, wantfields bool) (*sqltypes.Result, error)

+ func (p *Projection) GetFields(vcursor VCursor, bindVars map[string]*querypb.BindVariable) (*sqltypes.Result, error)

+ func (p *Projection) GetKeyspaceName() string

+ func (p *Projection) GetTableName() string

+ func (p *Projection) Inputs() []Primitive

+ func (p *Projection) RouteType() string

+ func (p *Projection) StreamExecute(vcursor VCursor, bindVars map[string]*querypb.BindVariable, wantields bool, ...) error

+ type PulloutOpcode int

+ func (code PulloutOpcode) MarshalJSON() ([]byte, error)

+ func (code PulloutOpcode) String() string

+ type PulloutSubquery struct

+ HasValues string

+ Opcode PulloutOpcode

+ Subquery Primitive

+ SubqueryResult string

+ Underlying Primitive

+ func (ps *PulloutSubquery) Execute(vcursor VCursor, bindVars map[string]*querypb.BindVariable, wantfields bool) (*sqltypes.Result, error)

+ func (ps *PulloutSubquery) GetFields(vcursor VCursor, bindVars map[string]*querypb.BindVariable) (*sqltypes.Result, error)

+ func (ps *PulloutSubquery) GetKeyspaceName() string

+ func (ps *PulloutSubquery) GetTableName() string

+ func (ps *PulloutSubquery) Inputs() []Primitive

+ func (ps *PulloutSubquery) NeedsTransaction() bool

+ func (ps *PulloutSubquery) RouteType() string

+ func (ps *PulloutSubquery) StreamExecute(vcursor VCursor, bindVars map[string]*querypb.BindVariable, wantfields bool, ...) error

+ type Reserve struct

+ Input Primitive

+ func (r *Reserve) Execute(vcursor VCursor, bindVars map[string]*querypb.BindVariable, wantfields bool) (*sqltypes.Result, error)

+ func (r *Reserve) GetFields(vcursor VCursor, bindVars map[string]*querypb.BindVariable) (*sqltypes.Result, error)

+ func (r *Reserve) GetKeyspaceName() string

+ func (r *Reserve) GetTableName() string

+ func (r *Reserve) Inputs() []Primitive

+ func (r *Reserve) NeedsTransaction() bool

+ func (r *Reserve) RouteType() string

+ func (r *Reserve) StreamExecute(vcursor VCursor, bindVars map[string]*querypb.BindVariable, wantfields bool, ...) error

+ type Route struct

+ FieldQuery string

+ Keyspace *vindexes.Keyspace

+ Opcode RouteOpcode

+ OrderBy []OrderbyParams

+ Query string

+ QueryTimeout int

+ ScatterErrorsAsWarnings bool

+ TableName string

+ TargetDestination key.Destination

+ TargetTabletType topodatapb.TabletType

+ TruncateColumnCount int

+ Values []sqltypes.PlanValue

+ Vindex vindexes.SingleColumn

+ func NewRoute(opcode RouteOpcode, keyspace *vindexes.Keyspace, query, fieldQuery string) *Route

+ func NewSimpleRoute(opcode RouteOpcode, keyspace *vindexes.Keyspace) *Route

+ func (Route) Inputs() []Primitive

+ func (Route) NeedsTransaction() bool

+ func (route *Route) Execute(vcursor VCursor, bindVars map[string]*querypb.BindVariable, wantfields bool) (*sqltypes.Result, error)

+ func (route *Route) GetFields(vcursor VCursor, bindVars map[string]*querypb.BindVariable) (*sqltypes.Result, error)

+ func (route *Route) GetKeyspaceName() string

+ func (route *Route) GetTableName() string

+ func (route *Route) RouteType() string

+ func (route *Route) SetTruncateColumnCount(count int)

+ func (route *Route) StreamExecute(vcursor VCursor, bindVars map[string]*querypb.BindVariable, wantfields bool, ...) error

+ type RouteOpcode int

+ func (code RouteOpcode) MarshalJSON() ([]byte, error)

+ type Rows struct

+ func NewRowsPrimitive(rows [][]sqltypes.Value, fields []*querypb.Field) *Rows

+ func (Rows) Inputs() []Primitive

+ func (Rows) NeedsTransaction() bool

+ func (r *Rows) Execute(VCursor, map[string]*querypb.BindVariable, bool) (*sqltypes.Result, error)

+ func (r *Rows) GetFields(VCursor, map[string]*querypb.BindVariable) (*sqltypes.Result, error)

+ func (r *Rows) GetKeyspaceName() string

+ func (r *Rows) GetTableName() string

+ func (r *Rows) RouteType() string

+ func (r *Rows) StreamExecute(vcursor VCursor, bindVars map[string]*querypb.BindVariable, wantields bool, ...) error

+ type Send struct

+ IsDML bool

+ Keyspace *vindexes.Keyspace

+ Query string

+ SingleShardOnly bool

+ TargetDestination key.Destination

+ func (Send) Inputs() []Primitive

+ func (s *Send) Execute(vcursor VCursor, bindVars map[string]*querypb.BindVariable, wantfields bool) (*sqltypes.Result, error)

+ func (s *Send) GetFields(vcursor VCursor, bindVars map[string]*querypb.BindVariable) (*sqltypes.Result, error)

+ func (s *Send) GetKeyspaceName() string

+ func (s *Send) GetTableName() string

+ func (s *Send) NeedsTransaction() bool

+ func (s *Send) RouteType() string

+ func (s *Send) StreamExecute(vcursor VCursor, bindVars map[string]*querypb.BindVariable, wantfields bool, ...) error

+ type SessionActions interface

+ InReservedConn func() bool

+ NeedsReservedConn func()

+ RecordWarning func(warning *querypb.QueryWarning)

+ SetSysVar func(name string, expr string)

+ SetTarget func(target string) error

+ SetUDV func(key string, value interface{}) error

+ ShardSession func() []*srvtopo.ResolvedShard

+ type Set struct

+ Input Primitive

+ Ops []SetOp

+ func (Set) NeedsTransaction() bool

+ func (s *Set) Execute(vcursor VCursor, bindVars map[string]*querypb.BindVariable, _ bool) (*sqltypes.Result, error)

+ func (s *Set) GetFields(VCursor, map[string]*querypb.BindVariable) (*sqltypes.Result, error)

+ func (s *Set) GetKeyspaceName() string

+ func (s *Set) GetTableName() string

+ func (s *Set) Inputs() []Primitive

+ func (s *Set) RouteType() string

+ func (s *Set) StreamExecute(vcursor VCursor, bindVars map[string]*querypb.BindVariable, wantields bool, ...) error

+ type SetOp interface

+ Execute func(vcursor VCursor, env evalengine.ExpressionEnv) error

+ VariableName func() string

+ type SingleRow struct

+ func (SingleRow) Inputs() []Primitive

+ func (SingleRow) NeedsTransaction() bool

+ func (s *SingleRow) Execute(vcursor VCursor, bindVars map[string]*query.BindVariable, wantfields bool) (*sqltypes.Result, error)

+ func (s *SingleRow) GetFields(vcursor VCursor, bindVars map[string]*query.BindVariable) (*sqltypes.Result, error)

+ func (s *SingleRow) GetKeyspaceName() string

+ func (s *SingleRow) GetTableName() string

+ func (s *SingleRow) RouteType() string

+ func (s *SingleRow) StreamExecute(vcursor VCursor, bindVars map[string]*query.BindVariable, wantields bool, ...) error

+ type StreamExecutor interface

+ StreamExecute func(vcursor VCursor, bindVars map[string]*querypb.BindVariable, wantields bool, ...) error

+ type Subquery struct

+ Cols []int

+ Subquery Primitive

+ func (sq *Subquery) Execute(vcursor VCursor, bindVars map[string]*querypb.BindVariable, wantfields bool) (*sqltypes.Result, error)

+ func (sq *Subquery) GetFields(vcursor VCursor, bindVars map[string]*querypb.BindVariable) (*sqltypes.Result, error)

+ func (sq *Subquery) GetKeyspaceName() string

+ func (sq *Subquery) GetTableName() string

+ func (sq *Subquery) Inputs() []Primitive

+ func (sq *Subquery) NeedsTransaction() bool

+ func (sq *Subquery) RouteType() string

+ func (sq *Subquery) StreamExecute(vcursor VCursor, bindVars map[string]*querypb.BindVariable, wantfields bool, ...) error

+ type SysVarCheckAndIgnore struct

+ Expr string

+ Keyspace *vindexes.Keyspace

+ Name string

+ TargetDestination key.Destination

+ func (svci *SysVarCheckAndIgnore) Execute(vcursor VCursor, env evalengine.ExpressionEnv) error

+ func (svci *SysVarCheckAndIgnore) MarshalJSON() ([]byte, error)

+ func (svci *SysVarCheckAndIgnore) VariableName() string

+ type SysVarIgnore struct

+ Expr string

+ Name string

+ func (svi *SysVarIgnore) Execute(VCursor, evalengine.ExpressionEnv) error

+ func (svi *SysVarIgnore) MarshalJSON() ([]byte, error)

+ func (svi *SysVarIgnore) VariableName() string

+ type SysVarSet struct

+ Expr string

+ Keyspace *vindexes.Keyspace

+ Name string

+ TargetDestination key.Destination

+ func (svs *SysVarSet) Execute(vcursor VCursor, env evalengine.ExpressionEnv) error

+ func (svs *SysVarSet) MarshalJSON() ([]byte, error)

+ func (svs *SysVarSet) VariableName() string

+ type SysVarSetSpecial struct

+ Expr string

+ Keyspace *vindexes.Keyspace

+ Name string

+ TargetDestination key.Destination

+ type Update struct

+ ChangedVindexValues map[string]VindexValues

+ func (Update) Inputs() []Primitive

+ func (Update) NeedsTransaction() bool

+ func (upd *Update) Execute(vcursor VCursor, bindVars map[string]*querypb.BindVariable, wantfields bool) (*sqltypes.Result, error)

+ func (upd *Update) GetFields(vcursor VCursor, bindVars map[string]*querypb.BindVariable) (*sqltypes.Result, error)

+ func (upd *Update) GetKeyspaceName() string

+ func (upd *Update) GetTableName() string

+ func (upd *Update) RouteType() string

+ func (upd *Update) StreamExecute(vcursor VCursor, bindVars map[string]*querypb.BindVariable, wantfields bool, ...) error

+ type UpdateTarget struct

+ Target string

+ func (UpdateTarget) Inputs() []Primitive

+ func (UpdateTarget) NeedsTransaction() bool

+ func (updTarget UpdateTarget) Execute(vcursor VCursor, bindVars map[string]*query.BindVariable, wantfields bool) (*sqltypes.Result, error)

+ func (updTarget UpdateTarget) GetFields(vcursor VCursor, bindVars map[string]*query.BindVariable) (*sqltypes.Result, error)

+ func (updTarget UpdateTarget) GetKeyspaceName() string

+ func (updTarget UpdateTarget) GetTableName() string

+ func (updTarget UpdateTarget) RouteType() string

+ func (updTarget UpdateTarget) StreamExecute(vcursor VCursor, bindVars map[string]*query.BindVariable, wantfields bool, ...) error

+ type UserDefinedVariable struct

+ Expr evalengine.Expr

+ Name string

+ func (u *UserDefinedVariable) Execute(vcursor VCursor, env evalengine.ExpressionEnv) error

+ func (u *UserDefinedVariable) MarshalJSON() ([]byte, error)

+ func (u *UserDefinedVariable) VariableName() string

+ type VCursor interface

+ AutocommitApproval func() bool

+ Context func() context.Context

+ ErrorGroupCancellableContext func() *errgroup.Group

+ ExceedsMaxMemoryRows func(numRows int) bool

+ Execute func(method string, query string, bindvars map[string]*querypb.BindVariable, ...) (*sqltypes.Result, error)

+ ExecuteKeyspaceID func(keyspace string, ksid []byte, query string, ...) (*sqltypes.Result, error)

+ ExecuteMultiShard func(rss []*srvtopo.ResolvedShard, queries []*querypb.BoundQuery, ...) (*sqltypes.Result, []error)

+ ExecuteStandalone func(query string, bindvars map[string]*querypb.BindVariable, ...) (*sqltypes.Result, error)

+ ExecuteVSchema func(keyspace string, vschemaDDL *sqlparser.DDL) error

+ MaxMemoryRows func() int

+ ResolveDestinations func(keyspace string, ids []*querypb.Value, destinations []key.Destination) ([]*srvtopo.ResolvedShard, [][]*querypb.Value, error)

+ Session func() SessionActions

+ SetContextTimeout func(timeout time.Duration) context.CancelFunc

+ StreamExecuteMulti func(query string, rss []*srvtopo.ResolvedShard, ...) error

+ type VindexFunc struct

+ Cols []int

+ Fields []*querypb.Field

+ Opcode VindexOpcode

+ Value sqltypes.PlanValue

+ Vindex vindexes.SingleColumn

+ func (VindexFunc) Inputs() []Primitive

+ func (VindexFunc) NeedsTransaction() bool

+ func (vf *VindexFunc) Execute(vcursor VCursor, bindVars map[string]*querypb.BindVariable, wantfields bool) (*sqltypes.Result, error)

+ func (vf *VindexFunc) GetFields(vcursor VCursor, bindVars map[string]*querypb.BindVariable) (*sqltypes.Result, error)

+ func (vf *VindexFunc) GetKeyspaceName() string

+ func (vf *VindexFunc) GetTableName() string

+ func (vf *VindexFunc) RouteType() string

+ func (vf *VindexFunc) StreamExecute(vcursor VCursor, bindVars map[string]*querypb.BindVariable, wantfields bool, ...) error

+ type VindexOpcode int

+ func (code VindexOpcode) MarshalJSON() ([]byte, error)

+ type VindexValues map[string]sqltypes.PlanValue