Versions in this module Expand all Collapse all v1 v1.0.9 Apr 20, 2018 Changes in this version + const CreateColumnPrivTable + const CreateDBPrivTable + const CreateGCDeleteRangeTable + const CreateGloablVariablesTable + const CreateHelpTopic + const CreateStatsBucketsTable + const CreateStatsColsTable + const CreateStatsMetaTable + const CreateTablePrivTable + const CreateTiDBTable + const CreateUserTable + const EngineGoLevelDBMemory + var SchemaChangedWithoutRetry bool + var SchemaOutOfDateRetryInterval = int64(500 * time.Millisecond) + var SchemaOutOfDateRetryTimes = int32(10) + func BootstrapSession(store kv.Storage) (*domain.Domain, error) + func Compile(ctx context.Context, stmtNode ast.StmtNode) (ast.Statement, error) + func GetRows(rs ast.RecordSet) ([][]types.Datum, error) + func IsQuery(sql string) bool + func NewStore(path string) (kv.Storage, error) + func Parse(ctx context.Context, src string) ([]ast.StmtNode, error) + func RegisterLocalStore(name string, driver engine.Driver) error + func RegisterStore(name string, driver kv.Driver) error + func SetCommitRetryLimit(limit int) + func SetSchemaLease(lease time.Duration) + func SetStatsLease(lease time.Duration) + type PreCommitHook struct + func (h PreCommitHook) String() string + type Session interface + AffectedRows func() uint64 + Auth func(user *auth.UserIdentity, auth []byte, salt []byte) bool + Cancel func() + Close func() + CommitTxn func() error + DropPreparedStmt func(stmtID uint32) error + Execute func(sql string) ([]ast.RecordSet, error) + ExecutePreparedStmt func(stmtID uint32, param ...interface{}) (ast.RecordSet, error) + FieldList func(tableName string) (fields []*ast.ResultField, err error) + LastInsertID func() uint64 + PrepareStmt func(sql string) (stmtID uint32, paramCount int, fields []*ast.ResultField, err error) + PrepareTxnCtx func() + RollbackTxn func() error + SetClientCapability func(uint32) + SetCollation func(coID int) error + SetConnectionID func(uint64) + SetSessionManager func(util.SessionManager) + SetTLSState func(*tls.ConnectionState) + ShowProcess func() util.ProcessInfo + Status func() uint16 + String func() string + func CreateSession(store kv.Storage) (Session, error) + type StmtHistory struct + func GetHistory(ctx context.Context) *StmtHistory + func (h *StmtHistory) Add(stmtID uint32, st ast.Statement, stmtCtx *variable.StatementContext, ...) + func (h *StmtHistory) Count() int
Go to main page