sqle

Feb 28, 2024

Changes in this version

type Engine

+ EventScheduler *eventscheduler.EventScheduler

+ func (e *Engine) BoundQueryPlan(ctx *sql.Context, query string, parsed sqlparser.Statement, ...) (sql.Node, error)

+ 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) 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)

type PreparedDataCache

+ func (p *PreparedDataCache) CachedStatementsForSession(sessId uint32) map[string]sqlparser.Statement

Aug 23, 2023

Changes in this version

type Engine

+ ReadOnly atomic.Bool

Jun 29, 2023

Changes in this version

+ var ExperimentalGMS bool

type Engine

+ Version sql.AnalyzerVersion

Apr 18, 2023

Changes in this version

type Engine

+ PreparedDataCache *PreparedDataCache

+ type PreparedDataCache struct

+ func NewPreparedDataCache() *PreparedDataCache

+ func (p *PreparedDataCache) CacheStmt(sessId uint32, query string, node sql.Node)

+ func (p *PreparedDataCache) DeleteSessionData(sessId uint32)

+ func (p *PreparedDataCache) GetCachedStmt(sessId uint32, query string) (sql.Node, bool)

+ func (p *PreparedDataCache) GetSessionData(sessId uint32) map[string]sql.Node

+ func (p *PreparedDataCache) UncacheStmt(sessId uint32, query string)

type ProcessList

+ func (pl *ProcessList) AddConnection(id uint32, addr string)

+ 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) RemoveConnection(connID uint32)

Nov 1, 2022

Changes in this version

type Config

+ IsServerLocked bool

type Engine

+ IsServerLocked bool

Jun 12, 2022

Changes in this version

+ func ColumnsFromCheckDefinition(ctx *sql.Context, def *sql.CheckDefinition) ([]string, error)

type Config

+ IncludeRootAccount bool

+ IsReadOnly bool

+ TemporaryUsers []TemporaryUser

type Engine

+ BackgroundThreads *sql.BackgroundThreads

+ IsReadOnly bool

+ PreparedData map[uint32]PreparedData

+ func (e *Engine) CachePreparedStmt(ctx *sql.Context, analyzed sql.Node, query string)

+ func (e *Engine) Close() error

+ func (e *Engine) CloseSession(ctx *sql.Context)

+ func (e *Engine) PrepareQuery(ctx *sql.Context, query string) (sql.Node, error)

+ func (e *Engine) WithBackgroundThreads(b *sql.BackgroundThreads) *Engine

+ type PreparedData struct

+ Node sql.Node

+ Query string

+ type TemporaryUser struct

+ Password string

+ Username string

Oct 20, 2021

Changes in this version

+ const ConnectTimeLogKey

+ const ConnectionIdLogField

type Engine

+ MemoryManager *sql.MemoryManager

+ ProcessList sql.ProcessList

+ type ProcessList struct

+ func NewProcessList() *ProcessList

+ func (pl *ProcessList) AddPartitionProgress(pid uint64, tableName, partitionName string, total int64)

+ func (pl *ProcessList) AddProcess(ctx *sql.Context, query string) (*sql.Context, error)

+ func (pl *ProcessList) AddTableProgress(pid uint64, name string, total int64)

+ func (pl *ProcessList) Done(pid uint64)

+ func (pl *ProcessList) Kill(connID uint32)

+ func (pl *ProcessList) Processes() []sql.Process

+ 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)

Jun 2, 2021

Changes in this version

type Engine

+ func (e *Engine) QueryNodeWithBindings(ctx *sql.Context, query string, parsed sql.Node, ...) (sql.Schema, sql.RowIter, error)

Feb 1, 2021

Changes in this version

+ var QueryCounter = discard.NewCounter()

+ var QueryErrorCounter = discard.NewCounter()

+ var QueryHistogram = discard.NewHistogram()

+ func ApplyDefaults(ctx *sql.Context, tblSch sql.Schema, cols []int, row sql.Row) (sql.Row, error)

+ func ResolveDefaults(tableName string, schema []*ColumnWithRawDefault) (sql.Schema, error)

+ type ColumnWithRawDefault struct

+ Default string

+ SqlColumn *sql.Column

+ type Config struct

+ Auth auth.Auth

+ VersionPostfix string

+ type Engine struct

+ Analyzer *analyzer.Analyzer

+ Auth auth.Auth

+ Catalog *sql.Catalog

+ LS *sql.LockSubsystem

+ func New(c *sql.Catalog, a *analyzer.Analyzer, cfg *Config) *Engine

+ func NewDefault() *Engine

+ func (e *Engine) AddDatabase(db sql.Database)

+ func (e *Engine) AnalyzeQuery(ctx *sql.Context, query string) (sql.Schema, error)

+ func (e *Engine) Async(ctx *sql.Context, query string) bool

+ func (e *Engine) Query(ctx *sql.Context, query string) (sql.Schema, sql.RowIter, error)

+ func (e *Engine) QueryWithBindings(ctx *sql.Context, query string, bindings map[string]sql.Expression) (sql.Schema, sql.RowIter, error)