Versions in this module Expand all Collapse all v1 v1.0.1 Jul 31, 2024 Changes in this version + var ExperimentalGMS bool + type ColumnWithRawDefault struct + Default string + SqlColumn *sql.Column + type Config struct + IncludeRootAccount bool + IsReadOnly bool + IsServerLocked bool + TemporaryUsers []TemporaryUser + VersionPostfix string + type Engine struct + Analyzer *analyzer.Analyzer + BackgroundThreads *sql.BackgroundThreads + EventScheduler *eventscheduler.EventScheduler + IsServerLocked bool + LS *sql.LockSubsystem + MemoryManager *sql.MemoryManager + PreparedDataCache *PreparedDataCache + ProcessList sql.ProcessList + ReadOnly atomic.Bool + Version sql.AnalyzerVersion + func New(a *analyzer.Analyzer, cfg *Config) *Engine + func NewDefault(pro sql.DatabaseProvider) *Engine + func (e *Engine) AnalyzeQuery(ctx *sql.Context, query string) (sql.Node, error) + func (e *Engine) BoundQueryPlan(ctx *sql.Context, query string, parsed sqlparser.Statement, ...) (sql.Node, error) + func (e *Engine) Close() error + func (e *Engine) CloseSession(connID uint32) + func (e *Engine) EngineAnalyzer() *analyzer.Analyzer + func (e *Engine) EnginePreparedDataCache() *PreparedDataCache + func (e *Engine) InitializeEventScheduler(ctxGetterFunc func() (*sql.Context, func() error, error), ...) error + func (e *Engine) IsReadOnly() bool + func (e *Engine) PrepQueryPlanForExecution(ctx *sql.Context, query string, plan sql.Node) (sql.Schema, sql.RowIter, error) + func (e *Engine) PrepareParsedQuery(ctx *sql.Context, statementKey, query string, stmt sqlparser.Statement) (sql.Node, error) + func (e *Engine) PrepareQuery(ctx *sql.Context, query string) (sql.Node, error) + func (e *Engine) Query(ctx *sql.Context, query string) (sql.Schema, sql.RowIter, error) + func (e *Engine) QueryWithBindings(ctx *sql.Context, query string, parsed sqlparser.Statement, ...) (sql.Schema, sql.RowIter, error) + func (e *Engine) WithBackgroundThreads(b *sql.BackgroundThreads) *Engine + type PreparedDataCache struct + func NewPreparedDataCache() *PreparedDataCache + func (p *PreparedDataCache) CacheStmt(sessId uint32, query string, stmt sqlparser.Statement) + func (p *PreparedDataCache) CachedStatementsForSession(sessId uint32) map[string]sqlparser.Statement + func (p *PreparedDataCache) DeleteSessionData(sessId uint32) + func (p *PreparedDataCache) GetCachedStmt(sessId uint32, query string) (sqlparser.Statement, bool) + func (p *PreparedDataCache) UncacheStmt(sessId uint32, query string) + type ProcessList struct + func NewProcessList() *ProcessList + func (pl *ProcessList) AddConnection(id uint32, addr string) + func (pl *ProcessList) AddPartitionProgress(pid uint64, tableName, partitionName string, total int64) + func (pl *ProcessList) AddTableProgress(pid uint64, name string, total int64) + func (pl *ProcessList) BeginQuery(ctx *sql.Context, query string) (*sql.Context, error) + func (pl *ProcessList) ConnectionReady(sess sql.Session) + func (pl *ProcessList) EndQuery(ctx *sql.Context) + func (pl *ProcessList) Kill(connID uint32) + func (pl *ProcessList) Processes() []sql.Process + func (pl *ProcessList) RemoveConnection(connID uint32) + func (pl *ProcessList) RemovePartitionProgress(pid uint64, tableName, partitionName string) + func (pl *ProcessList) RemoveTableProgress(pid uint64, name string) + func (pl *ProcessList) UpdatePartitionProgress(pid uint64, tableName, partitionName string, delta int64) + func (pl *ProcessList) UpdateTableProgress(pid uint64, name string, delta int64) + type TemporaryUser struct + Password string + Username string
Go to main page