executor

package
Version: v1.0.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 3, 2018 License: GPL-3.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AggregateExecutor

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

AggregateExecutor represents aggregate executor. Including: COUNT/MAX/MIN/SUM/AVG/GROUPBY.

func NewAggregateExecutor

func NewAggregateExecutor(log *xlog.Log, plan planner.Plan) *AggregateExecutor

NewAggregateExecutor creates new AggregateExecutor.

func (*AggregateExecutor) Execute

func (executor *AggregateExecutor) Execute(ctx *xcontext.ResultContext) error

Execute used to execute the executor.

type DDLExecutor

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

DDLExecutor represents a CREATE, ALTER, DROP executor

func NewDDLExecutor

func NewDDLExecutor(log *xlog.Log, plan planner.Plan, txn backend.Transaction) *DDLExecutor

NewDDLExecutor creates DDL executor.

func (*DDLExecutor) Execute

func (executor *DDLExecutor) Execute(ctx *xcontext.ResultContext) error

Execute used to execute the executor.

type DeleteExecutor

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

DeleteExecutor represents delete executor

func NewDeleteExecutor

func NewDeleteExecutor(log *xlog.Log, plan planner.Plan, txn backend.Transaction) *DeleteExecutor

NewDeleteExecutor creates new delete executor.

func (*DeleteExecutor) Execute

func (executor *DeleteExecutor) Execute(ctx *xcontext.ResultContext) error

Execute used to execute the executor.

type Executor

type Executor interface {
	Execute(*xcontext.ResultContext) error
}

Executor interface.

type InsertExecutor

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

InsertExecutor represents insert executor

func NewInsertExecutor

func NewInsertExecutor(log *xlog.Log, plan planner.Plan, txn backend.Transaction) *InsertExecutor

NewInsertExecutor creates new insert executor.

func (*InsertExecutor) Execute

func (executor *InsertExecutor) Execute(ctx *xcontext.ResultContext) error

Execute used to execute the executor.

type JoinExecutor

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

JoinExecutor tuple.

func NewJoinExecutor

func NewJoinExecutor(log *xlog.Log, plan planner.Plan) *JoinExecutor

NewJoinExecutor creates new join executor.

func (*JoinExecutor) Execute

func (executor *JoinExecutor) Execute(ctx *xcontext.ResultContext) error

Execute used to execute the executor.

type LimitExecutor

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

LimitExecutor represents limit executor.

func NewLimitExecutor

func NewLimitExecutor(log *xlog.Log, plan planner.Plan) *LimitExecutor

NewLimitExecutor creates the new limit executor.

func (*LimitExecutor) Execute

func (executor *LimitExecutor) Execute(ctx *xcontext.ResultContext) error

Execute used to execute the executor.

type OrderByExecutor

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

OrderByExecutor represents order by executor.

func NewOrderByExecutor

func NewOrderByExecutor(log *xlog.Log, plan planner.Plan) *OrderByExecutor

NewOrderByExecutor creates new orderby executor.

func (*OrderByExecutor) Execute

func (executor *OrderByExecutor) Execute(ctx *xcontext.ResultContext) error

Execute used to execute the executor.

type SelectExecutor

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

SelectExecutor represents select executor

func NewSelectExecutor

func NewSelectExecutor(log *xlog.Log, plan planner.Plan, txn backend.Transaction) *SelectExecutor

NewSelectExecutor creates the new select executor.

func (*SelectExecutor) Execute

func (executor *SelectExecutor) Execute(ctx *xcontext.ResultContext) error

Execute used to execute the executor.

type Tree

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

Tree is a container for all executors

func NewTree

func NewTree(log *xlog.Log, planTree *planner.PlanTree, txn backend.Transaction) *Tree

NewTree creates the new execute tree.

func (*Tree) Add

func (et *Tree) Add(executor Executor) error

Add adds a executor to the tree

func (*Tree) Execute

func (et *Tree) Execute() (*sqltypes.Result, error)

Execute executes all Executor.Execute

type UpdateExecutor

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

UpdateExecutor represents update executor

func NewUpdateExecutor

func NewUpdateExecutor(log *xlog.Log, plan planner.Plan, txn backend.Transaction) *UpdateExecutor

NewUpdateExecutor creates the new update executor.

func (*UpdateExecutor) Execute

func (executor *UpdateExecutor) Execute(ctx *xcontext.ResultContext) error

Execute used to execute the executor.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL