executor

type AggregateExec struct {
	Src          Executor
	ResultFields []*ast.ResultField

	AggFuncs []*ast.AggregateFuncExpr

	GroupByItems []*ast.ByItem
	// contains filtered or unexported fields
}

type AggregationExec struct {
	Src Executor

	ResultFields []*ast.ResultField

	AggFuncs []expression.AggregationFunction

	GroupByItems []expression.Expression
	// contains filtered or unexported fields
}

type ApplyExec struct {
	Src Executor
	// contains filtered or unexported fields
}

type CheckTableExec struct {
	// contains filtered or unexported fields
}

type Compiler struct {
}

type DDLExec struct {
	Statement ast.StmtNode
	// contains filtered or unexported fields
}

type DeallocateExec struct {
	Name string
	// contains filtered or unexported fields
}

type DeleteExec struct {
	SelectExec Executor

	Tables       []*ast.TableName
	IsMultiTable bool
	// contains filtered or unexported fields
}

type DistinctExec struct {
	Src Executor
	// contains filtered or unexported fields
}

type ExecuteExec struct {
	IS        infoschema.InfoSchema
	Ctx       context.Context
	Name      string
	UsingVars []ast.ExprNode
	ID        uint32
	StmtExec  Executor
	Stmt      ast.StmtNode
}

type Executor interface {
	Fields() []*ast.ResultField
	Next() (*Row, error)
	Close() error
	Schema() expression.Schema
}

type ExistsExec struct {
	Src Executor
	// contains filtered or unexported fields
}

type ExplainExec struct {
	StmtPlan plan.Plan
	// contains filtered or unexported fields
}

type FilterExec struct {
	Src       Executor
	Condition ast.ExprNode
	// contains filtered or unexported fields
}

type GrantExec struct {
	Privs      []*ast.PrivElem
	ObjectType ast.ObjectTypeType
	Level      *ast.GrantLevel
	Users      []*ast.UserSpec
	// contains filtered or unexported fields
}

type HashJoinExec struct {
	// contains filtered or unexported fields
}

type HashSemiJoinExec struct {
	// contains filtered or unexported fields
}

type IndexRangeExec struct {
	// contains filtered or unexported fields
}

type IndexScanExec struct {
	Ranges []*IndexRangeExec
	Desc   bool
	// contains filtered or unexported fields
}

type InsertExec struct {
	*InsertValues

	OnDuplicate []*ast.Assignment

	Priority int
	// contains filtered or unexported fields
}

type InsertValues struct {
	SelectExec Executor

	Table     table.Table
	Columns   []*ast.ColumnName
	Lists     [][]ast.ExprNode
	Setlist   []*ast.Assignment
	IsPrepare bool
	// contains filtered or unexported fields
}

type JoinInnerExec struct {
	InnerPlans []plan.Plan

	Condition ast.ExprNode
	// contains filtered or unexported fields
}

type JoinOuterExec struct {
	OuterExec Executor
	InnerPlan plan.Plan
	// contains filtered or unexported fields
}

type LimitExec struct {
	Src    Executor
	Offset uint64
	Count  uint64
	Idx    uint64
	// contains filtered or unexported fields
}

type MaxOneRowExec struct {
	Src Executor
	// contains filtered or unexported fields
}

type NewSortExec struct {
	Src     Executor
	ByItems []*plan.ByItems
	Rows    []*orderByRow

	Limit *plan.Limit
	Idx   int
	// contains filtered or unexported fields
}

type NewTableDualExec struct {
	// contains filtered or unexported fields
}

type NewTableScanExec struct {
	// contains filtered or unexported fields
}

type NewUnionExec struct {
	Srcs []Executor
	// contains filtered or unexported fields
}

type NewXSelectIndexExec struct {
	// contains filtered or unexported fields
}

type NewXSelectTableExec struct {
	Columns []*model.ColumnInfo
	// contains filtered or unexported fields
}

type PrepareExec struct {
	IS      infoschema.InfoSchema
	Ctx     context.Context
	Name    string
	SQLText string

	ID           uint32
	ResultFields []*ast.ResultField
	ParamCount   int
	Err          error
}

type Prepared struct {
	Stmt          ast.StmtNode
	Params        []*ast.ParamMarkerExpr
	SchemaVersion int64
}

type ProjectionExec struct {
	Src          Executor
	ResultFields []*ast.ResultField
	// contains filtered or unexported fields
}

type ReplaceExec struct {
	*InsertValues
	Priority int
	// contains filtered or unexported fields
}

type ReverseExec struct {
	Src Executor
	// contains filtered or unexported fields
}

type Row struct {
	// Data is the output record data for current Plan.
	Data []types.Datum

	RowKeys []*RowKeyEntry
}

type RowKeyEntry struct {
	// The table which this row come from.
	Tbl table.Table
	// Row key.
	Handle int64
	// Table alias name.
	TableAsName *model.CIStr
}

type SelectFieldsExec struct {
	Src          Executor
	ResultFields []*ast.ResultField
	// contains filtered or unexported fields
}

type SelectLockExec struct {
	Src  Executor
	Lock ast.SelectLockType
	// contains filtered or unexported fields
}

type SelectionExec struct {
	Src       Executor
	Condition expression.Expression
	// contains filtered or unexported fields
}

type ShowDDLExec struct {
	// contains filtered or unexported fields
}

type ShowExec struct {
	Tp     ast.ShowStmtType // Databases/Tables/Columns/....
	DBName model.CIStr
	Table  *ast.TableName  // Used for showing columns.
	Column *ast.ColumnName // Used for `desc table column`.
	Flag   int             // Some flag parsed from sql, such as FULL.
	Full   bool
	User   string // Used for show grants.

	// Used by show variables
	GlobalScope bool
	// contains filtered or unexported fields
}

type SimpleExec struct {
	Statement ast.StmtNode
	// contains filtered or unexported fields
}

type SortExec struct {
	Src     Executor
	ByItems []*ast.ByItem
	Rows    []*orderByRow

	Limit *plan.Limit
	Idx   int
	// contains filtered or unexported fields
}

type TableDualExec struct {
	// contains filtered or unexported fields
}

type TableScanExec struct {
	// contains filtered or unexported fields
}

type TrimExec struct {
	Src Executor
	// contains filtered or unexported fields
}

type UnionExec struct {
	Sels []Executor
	// contains filtered or unexported fields
}

type UnionScanExec struct {
	Src Executor
	// contains filtered or unexported fields
}

type UpdateExec struct {
	SelectExec  Executor
	OrderedList []*ast.Assignment
	// contains filtered or unexported fields
}

type XAggregateExec struct {
	Src          Executor
	ResultFields []*ast.ResultField
	AggFields    []*types.FieldType

	AggFuncs []*ast.AggregateFuncExpr
	// contains filtered or unexported fields
}

type XExecutor interface {
	// AddAggregate adds aggregate info into an executor.
	AddAggregate(funcs []*tipb.Expr, byItems []*tipb.ByItem, fields []*types.FieldType)
	// GetTableName gets the table name of this XExecutor.
	GetTableName() *ast.TableName
}

type XSelectIndexExec struct {
	XExecutor
	// contains filtered or unexported fields
}

type XSelectTableExec struct {
	XExecutor
	// contains filtered or unexported fields
}