Versions in this module Expand all Collapse all v1 v1.0.9 Apr 20, 2018 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 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 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 + 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 + Ctx context.Context + Expensive bool + InfoSchema infoschema.InfoSchema + Plan plan.Plan + ReadOnly bool + StmtNode ast.StmtNode + Text string + func (a *ExecStmt) Exec(ctx context.Context) (ast.RecordSet, error) + func (a *ExecStmt) IsPrepared() bool + func (a *ExecStmt) IsReadOnly() bool + func (a *ExecStmt) OriginText() string + func (a *ExecStmt) RebuildPlan() error + 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