sql

Documentation

Index

• func Compile(ctx context.Context, rawStmt ast.StmtNode) (plan.Plan, error)
• func Query(sql string) (*flow.Dataset, plan.Plan, error)
• func RegisterTable(dataset *flow.Dataset, tableName string, columns []executor.TableColumn)
• type Session
  • func CreateSession(info infoschema.InfoSchema) (Session, error)

Functions

func Compile

func Compile(ctx context.Context, rawStmt ast.StmtNode) (plan.Plan, error)

Compile is safe for concurrent use by multiple goroutines.

func Query

func Query(sql string) (*flow.Dataset, plan.Plan, error)

func RegisterTable

func RegisterTable(dataset *flow.Dataset, tableName string, columns []executor.TableColumn)

Types

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 infoschema.InfoSchema) (Session, error)

CreateSession creates a new session environment.