executor

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

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

type Closeable interface {
	// Close closes the object.
	Close() error
}

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 DummyScanExec struct {
	// 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 HashAggExec struct {
	Src Executor

	ResultFields []*ast.ResultField

	AggFuncs []expression.AggregationFunction

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

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

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

type InsertExec struct {
	*InsertValues

	OnDuplicate []*ast.Assignment

	Priority int
	Ignore   bool
	// 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 LimitExec struct {
	Src    Executor
	Offset uint64
	Count  uint64
	Idx    uint64
	// contains filtered or unexported fields
}

type LoadData struct {
	IsLocal bool
	// contains filtered or unexported fields
}

type LoadDataInfo struct {
	Path       string
	Table      table.Table
	FieldsInfo *ast.FieldsClause
	LinesInfo  *ast.LinesClause
	// contains filtered or unexported fields
}

type MaxOneRowExec struct {
	Src Executor
	// 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 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 []*plan.ByItems
	Rows    []*orderByRow

	Idx int
	// contains filtered or unexported fields
}

type StreamAggExec struct {
	Src Executor

	ResultFields []*ast.ResultField

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

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

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

type TopnExec struct {
	SortExec
	// contains filtered or unexported fields
}

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

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

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

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

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

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