plan

type PlanTask ¶

type PlanTask interface {
	json.Marshaler
	json.Unmarshaler
	Accept(visitor expr.Visitor) (interface{}, error)
	Clone() PlanTask
}

A PlanTask is a part of a Plan, each task may have children

type Planner ¶

type Planner struct {
	// contains filtered or unexported fields
}

A planner creates an execution plan for a given Statement, with ability to cache plans

to be re-used. this is very simple planner, but potentially better planners with more
knowledge of schema, distributed runtimes etc could be plugged

func NewPlanner(schema string, stmt expr.SqlStatement, sys datasource.RuntimeSchema) (*Planner, error)

func (m *Planner) VisitCommand(stmt *expr.SqlCommand) (expr.Task, error)

func (m *Planner) VisitDelete(stmt *expr.SqlDelete) (expr.Task, error)

func (m *Planner) VisitDescribe(stmt *expr.SqlDescribe) (expr.Task, error)

func (m *Planner) VisitInsert(stmt *expr.SqlInsert) (expr.Task, error)

func (m *Planner) VisitPreparedStmt(stmt *expr.PreparedStatement) (expr.Task, error)

func (m *Planner) VisitSelect(stmt *expr.SqlSelect) (expr.Task, error)

func (m *Planner) VisitShow(stmt *expr.SqlShow) (expr.Task, error)

func (m *Planner) VisitUpdate(stmt *expr.SqlUpdate) (expr.Task, error)

func (m *Planner) VisitUpsert(stmt *expr.SqlUpsert) (expr.Task, error)