Documentation
¶
Index ¶
- func Compile(ctx context.Context, rawStmt ast.StmtNode) (plan.Plan, error)
- func NewBaseCursor(ctx context.Context, children ...basic.Cursor) baseCursor
- func NewCursorBuilder(ctx context.Context, schema schemas.InfoSchema) *cursorBuilder
- type Executor
- type PreparedStatement
- type ProjectionExec
- type SelectionExec
- type Session
- type XMySQLEngine
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewCursorBuilder ¶
func NewCursorBuilder(ctx context.Context, schema schemas.InfoSchema) *cursorBuilder
Types ¶
type PreparedStatement ¶
type PreparedStatement struct {
}
type ProjectionExec ¶
type ProjectionExec struct {
// contains filtered or unexported fields
}
func (ProjectionExec) CursorName ¶
func (p ProjectionExec) CursorName() string
func (ProjectionExec) GetRow ¶
func (p ProjectionExec) GetRow() basic.Row
func (ProjectionExec) Next ¶
func (p ProjectionExec) Next() bool
func (ProjectionExec) Type ¶
func (p ProjectionExec) Type() string
type SelectionExec ¶
type SelectionExec struct {
Conditions []expression.Expression
// contains filtered or unexported fields
}
func (SelectionExec) CursorName ¶
func (s SelectionExec) CursorName() string
func (SelectionExec) GetRow ¶
func (s SelectionExec) GetRow() basic.Row
func (SelectionExec) Next ¶
func (s SelectionExec) Next() bool
func (SelectionExec) Open ¶
func (s SelectionExec) Open() error
func (SelectionExec) Type ¶
func (s SelectionExec) Type() string
type Session ¶
type Session interface {
context.Context
Status() uint16 // Flag of current status, such as autocommit.
String() string // For debug
Close() error
}
Session context
func CreateSession ¶
func CreateSession(info schemas.InfoSchema) (Session, error)
CreateSession creates a new session environment.
type XMySQLEngine ¶
type XMySQLEngine struct {
// contains filtered or unexported fields
}
SQL执行引擎 默认一个实例
func NewXMySQLEngine ¶
func NewXMySQLEngine(conf *conf.Cfg) *XMySQLEngine
func (*XMySQLEngine) ExecuteQuery ¶
func (srv *XMySQLEngine) ExecuteQuery(session innodb.MySQLServerSession, query string)
ast->plan->storebytes->result->net
Source Files
Click to show internal directories.
Click to hide internal directories.