Versions in this module Expand all Collapse all v1 v1.1.0-beta Feb 24, 2018 v1.1.0-alpha.1 Jan 19, 2018 v1.1.0-alpha Oct 31, 2017 v1.0.9 Apr 20, 2018 v1.0.8 Feb 11, 2018 v1.0.7 Jan 19, 2018 v1.0.6 Jan 8, 2018 v1.0.5 Dec 26, 2017 v1.0.4 Dec 11, 2017 v1.0.3 Nov 25, 2017 Changes in this version type ExecStmt + Ctx context.Context + ReadOnly bool + StmtNode ast.StmtNode + func (a *ExecStmt) IsReadOnly() bool + func (a *ExecStmt) RebuildPlan() error v1.0.2 Nov 13, 2017 v1.0.1 Oct 31, 2017 Changes in this version + type CancelDDLJobsExec struct + JobIDs []int64 + func (e *CancelDDLJobsExec) Close() error + func (e *CancelDDLJobsExec) Next() (Row, error) + func (e *CancelDDLJobsExec) Open() error + func (e *CancelDDLJobsExec) Schema() *expression.Schema v1.0.0 Oct 16, 2017 Changes in this version + const AlterTable + const AnalyzeTable + const Begin + const CodeCannotUser + const CodePasswordNoMatch + const Commit + const CreateDatabase + const CreateIndex + const CreateTable + const CreateUser + const Delete + const DropDatabase + const DropIndex + const DropTable + const Explain + const Grant + const IGNORE + const Insert + const LoadDataStmt + const LoadDataVarKey + const Replace + const Revoke + const RollBack + const Select + const Set + const Show + const TruncateTable + const Update + var BatchDeleteSize = 20000 + var BatchInsertSize = 20000 + var ErrBatchInsertFail = terror.ClassExecutor.New(codeBatchInsertFail, ...) + var ErrBuildExecutor = terror.ClassExecutor.New(codeErrBuildExec, "Failed to build executor") + var ErrPasswordNoMatch = terror.ClassExecutor.New(CodePasswordNoMatch, "Can't find any matching row in the user table") + var ErrPrepareDDL = terror.ClassExecutor.New(codePrepareDDL, "Can not prepare DDL statements") + var ErrPrepareMulti = terror.ClassExecutor.New(codePrepareMulti, "Can not prepare multiple statements") + var ErrResultIsEmpty = terror.ClassExecutor.New(codeResultIsEmpty, "result is empty") + var ErrRowKeyCount = terror.ClassExecutor.New(codeRowKeyCount, "Wrong row key entry count") + var ErrSchemaChanged = terror.ClassExecutor.New(codeSchemaChanged, "Schema has changed") + var ErrStmtNotFound = terror.ClassExecutor.New(codeStmtNotFound, "Prepared statement not found") + var ErrUnknownPlan = terror.ClassExecutor.New(codeUnknownPlan, "Unknown plan") + var ErrWrongParamCount = terror.ClassExecutor.New(codeWrongParamCount, "Wrong parameter count") + var ErrWrongValueCountOnRow = terror.ClassExecutor.New(codeWrongValueCountOnRow, "Column count doesn't match value count at row %d") + var LookupTableTaskChannelSize int32 = 50 + func CompileExecutePreparedStmt(ctx context.Context, ID uint32, args ...interface{}) ast.Statement + func GetFieldsFromLine(line []byte, fieldsInfo *ast.FieldsClause) ([]string, error) + func GetInfoSchema(ctx context.Context) infoschema.InfoSchema + func IsPointGetWithPKOrUniqueKeyByAutoCommit(ctx context.Context, p plan.Plan) bool + func ResetStmtCtx(ctx context.Context, s ast.StmtNode) + func StatementLabel(node ast.StmtNode, p plan.Plan, isExpensive *bool) string + type AnalyzeColumnsExec struct + type AnalyzeExec struct + func (e *AnalyzeExec) Close() error + func (e *AnalyzeExec) Next() (Row, error) + func (e *AnalyzeExec) Open() error + func (e *AnalyzeExec) Schema() *expression.Schema + type AnalyzeIndexExec struct + type ApplyJoinExec struct + func (e *ApplyJoinExec) Close() error + func (e *ApplyJoinExec) Next() (Row, error) + func (e *ApplyJoinExec) Open() error + func (e *ApplyJoinExec) Schema() *expression.Schema + type CacheExec struct + func (e *CacheExec) Close() error + func (e *CacheExec) Next() (Row, error) + func (e *CacheExec) Open() error + func (e *CacheExec) Schema() *expression.Schema + type CheckTableExec struct + func (e *CheckTableExec) Close() error + func (e *CheckTableExec) Next() (Row, error) + func (e *CheckTableExec) Open() error + func (e *CheckTableExec) Schema() *expression.Schema + type Closeable interface + Close func() error + type Compiler struct + func (c *Compiler) Compile(ctx context.Context, stmtNode ast.StmtNode) (*ExecStmt, error) + type DDLExec struct + Statement ast.StmtNode + func (e *DDLExec) Close() error + func (e *DDLExec) Next() (Row, error) + func (e *DDLExec) Open() error + func (e *DDLExec) Schema() *expression.Schema + type DataReader interface + type DeallocateExec struct + Name string + func (e *DeallocateExec) Close() error + func (e *DeallocateExec) Next() (Row, error) + func (e *DeallocateExec) Open() error + func (e *DeallocateExec) Schema() *expression.Schema + type DeleteExec struct + IsMultiTable bool + SelectExec Executor + Tables []*ast.TableName + func (e *DeleteExec) Close() error + func (e *DeleteExec) Next() (Row, error) + func (e *DeleteExec) Open() error + func (e *DeleteExec) Schema() *expression.Schema + type ExecStmt struct + Cacheable bool + Expensive bool + InfoSchema infoschema.InfoSchema + Plan plan.Plan + Text string + func (a *ExecStmt) Exec(ctx context.Context) (ast.RecordSet, error) + func (a *ExecStmt) IsPrepared() bool + func (a *ExecStmt) OriginText() string + type ExecuteExec struct + Ctx context.Context + ID uint32 + IS infoschema.InfoSchema + Name string + Plan plan.Plan + Stmt ast.StmtNode + StmtExec Executor + UsingVars []expression.Expression + func (e *ExecuteExec) Build() error + func (e *ExecuteExec) Close() error + func (e *ExecuteExec) Next() (Row, error) + func (e *ExecuteExec) Open() error + func (e *ExecuteExec) Schema() *expression.Schema + type Executor interface + Close func() error + Next func() (Row, error) + Open func() error + Schema func() *expression.Schema + type ExistsExec struct + func (e *ExistsExec) Close() error + func (e *ExistsExec) Next() (Row, error) + func (e *ExistsExec) Open() error + func (e *ExistsExec) Schema() *expression.Schema + type ExplainExec struct + func (e *ExplainExec) Close() error + func (e *ExplainExec) Next() (Row, error) + func (e *ExplainExec) Open() error + func (e *ExplainExec) Schema() *expression.Schema + type GrantExec struct + Level *ast.GrantLevel + ObjectType ast.ObjectTypeType + Privs []*ast.PrivElem + Users []*ast.UserSpec + WithGrant bool + func (e *GrantExec) Close() error + func (e *GrantExec) Next() (Row, error) + func (e *GrantExec) Open() error + func (e *GrantExec) Schema() *expression.Schema + type HashAggExec struct + AggFuncs []aggregation.Aggregation + GroupByItems []expression.Expression + func (e *HashAggExec) Close() error + func (e *HashAggExec) Next() (Row, error) + func (e *HashAggExec) Open() error + func (e *HashAggExec) Schema() *expression.Schema + type HashJoinExec struct + func (e *HashJoinExec) Close() error + func (e *HashJoinExec) Next() (Row, error) + func (e *HashJoinExec) Open() error + func (e *HashJoinExec) Schema() *expression.Schema + type HashSemiJoinExec struct + func (e *HashSemiJoinExec) Close() error + func (e *HashSemiJoinExec) Next() (Row, error) + func (e *HashSemiJoinExec) Open() error + func (e *HashSemiJoinExec) Schema() *expression.Schema + type IndexLookUpExecutor struct + func (e *IndexLookUpExecutor) Close() error + func (e *IndexLookUpExecutor) Next() (Row, error) + func (e *IndexLookUpExecutor) Open() error + func (e *IndexLookUpExecutor) Schema() *expression.Schema + type IndexLookUpJoin struct + func (e *IndexLookUpJoin) Close() error + func (e *IndexLookUpJoin) Next() (Row, error) + func (e *IndexLookUpJoin) Open() error + func (e *IndexLookUpJoin) Schema() *expression.Schema + type IndexReaderExecutor struct + func (e *IndexReaderExecutor) Close() error + func (e *IndexReaderExecutor) Next() (Row, error) + func (e *IndexReaderExecutor) Open() error + func (e *IndexReaderExecutor) Schema() *expression.Schema + type InsertExec struct + IgnoreErr bool + OnDuplicate []*expression.Assignment + Priority mysql.PriorityEnum + func (e *InsertExec) Close() error + func (e *InsertExec) Next() (Row, error) + func (e *InsertExec) Open() error + func (e *InsertExec) Schema() *expression.Schema + type InsertValues struct + Columns []*ast.ColumnName + GenColumns []*ast.ColumnName + GenExprs []expression.Expression + IsPrepare bool + Lists [][]expression.Expression + SelectExec Executor + Setlist []*expression.Assignment + Table table.Table + type LimitExec struct + Count uint64 + Idx uint64 + Offset uint64 + func (e *LimitExec) Close() error + func (e *LimitExec) Next() (Row, error) + func (e *LimitExec) Open() error + func (e *LimitExec) Schema() *expression.Schema + type LoadData struct + IsLocal bool + func (e *LoadData) Close() error + func (e *LoadData) Next() (Row, error) + func (e *LoadData) Open() error + func (e *LoadData) Schema() *expression.Schema + type LoadDataInfo struct + Ctx context.Context + FieldsInfo *ast.FieldsClause + LinesInfo *ast.LinesClause + Path string + Table table.Table + func NewLoadDataInfo(row []types.Datum, ctx context.Context, tbl table.Table, cols []*table.Column) *LoadDataInfo + func (e *LoadDataInfo) InsertData(prevData, curData []byte) ([]byte, bool, error) + func (e *LoadDataInfo) SetBatchCount(limit int64) + type MaxOneRowExec struct + func (e *MaxOneRowExec) Close() error + func (e *MaxOneRowExec) Next() (Row, error) + func (e *MaxOneRowExec) Open() error + func (e *MaxOneRowExec) Schema() *expression.Schema + type MergeJoinExec struct + func (e *MergeJoinExec) Close() error + func (e *MergeJoinExec) Next() (Row, error) + func (e *MergeJoinExec) Open() error + func (e *MergeJoinExec) Schema() *expression.Schema + type NestedLoopJoinExec struct + BigExec Executor + BigFilter expression.CNFExprs + Ctx context.Context + OtherFilter expression.CNFExprs + SmallExec Executor + SmallFilter expression.CNFExprs + func (e *NestedLoopJoinExec) Close() error + func (e *NestedLoopJoinExec) Next() (Row, error) + func (e *NestedLoopJoinExec) Open() error + func (e *NestedLoopJoinExec) Schema() *expression.Schema + type PrepareExec struct + Ctx context.Context + Err error + Fields []*ast.ResultField + ID uint32 + IS infoschema.InfoSchema + Name string + ParamCount int + SQLText string + func (e *PrepareExec) Close() error + func (e *PrepareExec) DoPrepare() + func (e *PrepareExec) Next() (Row, error) + func (e *PrepareExec) Open() error + func (e *PrepareExec) Schema() *expression.Schema + type Prepared struct + Params []*ast.ParamMarkerExpr + SchemaVersion int64 + Stmt ast.StmtNode + type ProjectionExec struct + func (e *ProjectionExec) Close() error + func (e *ProjectionExec) Next() (retRow Row, err error) + func (e *ProjectionExec) Open() error + func (e *ProjectionExec) Schema() *expression.Schema + type ReplaceExec struct + Priority int + func (e *ReplaceExec) Close() error + func (e *ReplaceExec) Next() (Row, error) + func (e *ReplaceExec) Open() error + func (e *ReplaceExec) Schema() *expression.Schema + type RevokeExec struct + Level *ast.GrantLevel + ObjectType ast.ObjectTypeType + Privs []*ast.PrivElem + Users []*ast.UserSpec + func (e *RevokeExec) Close() error + func (e *RevokeExec) Next() (Row, error) + func (e *RevokeExec) Open() error + func (e *RevokeExec) Schema() *expression.Schema + type Row []types.Datum + type SelectLockExec struct + Lock ast.SelectLockType + func (e *SelectLockExec) Close() error + func (e *SelectLockExec) Next() (Row, error) + func (e *SelectLockExec) Open() error + func (e *SelectLockExec) Schema() *expression.Schema + type SelectionExec struct + Conditions []expression.Expression + func (e *SelectionExec) Close() error + func (e *SelectionExec) Next() (Row, error) + func (e *SelectionExec) Open() error + func (e *SelectionExec) Schema() *expression.Schema + type SetExecutor struct + func (e *SetExecutor) Close() error + func (e *SetExecutor) Next() (Row, error) + func (e *SetExecutor) Open() error + func (e *SetExecutor) Schema() *expression.Schema + type ShowDDLExec struct + func (e *ShowDDLExec) Close() error + func (e *ShowDDLExec) Next() (Row, error) + func (e *ShowDDLExec) Open() error + func (e *ShowDDLExec) Schema() *expression.Schema + type ShowDDLJobsExec struct + func (e *ShowDDLJobsExec) Close() error + func (e *ShowDDLJobsExec) Next() (Row, error) + func (e *ShowDDLJobsExec) Open() error + func (e *ShowDDLJobsExec) Schema() *expression.Schema + type ShowExec struct + Column *ast.ColumnName + DBName model.CIStr + Flag int + Full bool + GlobalScope bool + Table *ast.TableName + Tp ast.ShowStmtType + User *auth.UserIdentity + func (e *ShowExec) Close() error + func (e *ShowExec) Next() (Row, error) + func (e *ShowExec) Open() error + func (e *ShowExec) Schema() *expression.Schema + type SimpleExec struct + Statement ast.StmtNode + func (e *SimpleExec) Close() error + func (e *SimpleExec) Next() (Row, error) + func (e *SimpleExec) Open() error + func (e *SimpleExec) Schema() *expression.Schema + type SortExec struct + ByItems []*plan.ByItems + Idx int + Rows []*orderByRow + func (e *SortExec) Close() error + func (e *SortExec) Len() int + func (e *SortExec) Less(i, j int) bool + func (e *SortExec) Next() (Row, error) + func (e *SortExec) Open() error + func (e *SortExec) Schema() *expression.Schema + func (e *SortExec) Swap(i, j int) + type StreamAggExec struct + AggFuncs []aggregation.Aggregation + GroupByItems []expression.Expression + StmtCtx *variable.StatementContext + func (e *StreamAggExec) Close() error + func (e *StreamAggExec) Next() (Row, error) + func (e *StreamAggExec) Open() error + func (e *StreamAggExec) Schema() *expression.Schema + type TableDualExec struct + func (e *TableDualExec) Close() error + func (e *TableDualExec) Next() (Row, error) + func (e *TableDualExec) Open() error + func (e *TableDualExec) Schema() *expression.Schema + type TableReaderExecutor struct + func (e *TableReaderExecutor) Close() error + func (e *TableReaderExecutor) Next() (Row, error) + func (e *TableReaderExecutor) Open() error + func (e *TableReaderExecutor) Schema() *expression.Schema + type TableScanExec struct + func (e *TableScanExec) Close() error + func (e *TableScanExec) Next() (Row, error) + func (e *TableScanExec) Open() error + func (e *TableScanExec) Schema() *expression.Schema + type TopNExec struct + func (e *TopNExec) Len() int + func (e *TopNExec) Less(i, j int) bool + func (e *TopNExec) Next() (Row, error) + func (e *TopNExec) Pop() interface{} + func (e *TopNExec) Push(x interface{}) + func (e *TopNExec) Schema() *expression.Schema + type UnionExec struct + func (e *UnionExec) Close() error + func (e *UnionExec) Next() (Row, error) + func (e *UnionExec) Open() error + func (e *UnionExec) Schema() *expression.Schema + type UnionScanExec struct + func (e *UnionScanExec) Close() error + func (e *UnionScanExec) Open() error + func (e *UnionScanExec) Schema() *expression.Schema + func (us *UnionScanExec) Len() int + func (us *UnionScanExec) Less(i, j int) bool + func (us *UnionScanExec) Next() (Row, error) + func (us *UnionScanExec) Swap(i, j int) + type UpdateExec struct + IgnoreErr bool + OrderedList []*expression.Assignment + SelectExec Executor + func (e *UpdateExec) Close() error + func (e *UpdateExec) Next() (Row, error) + func (e *UpdateExec) Open() error + func (e *UpdateExec) Schema() *expression.Schema + type XSelectIndexExec struct + func (e *XSelectIndexExec) Close() error + func (e *XSelectIndexExec) Next() (Row, error) + func (e *XSelectIndexExec) Open() error + func (e *XSelectIndexExec) Schema() *expression.Schema + type XSelectTableExec struct + Columns []*model.ColumnInfo + func (e *XSelectTableExec) Close() error + func (e *XSelectTableExec) Next() (Row, error) + func (e *XSelectTableExec) Open() error + func (e *XSelectTableExec) Schema() *expression.Schema
Go to main page