executor

package
Version: v1.1.4 Latest Latest
Warning

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

Go to latest
Published: Jan 28, 2021 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 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 OthersExecutor added in v1.0.6

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

OthersExecutor -- represents special executor.

func NewOthersExecutor added in v1.0.6

func NewOthersExecutor(log *xlog.Log, plan planner.Plan, txn backend.Transaction) *OthersExecutor

NewOthersExecutor -- creates new others executor.

func (*OthersExecutor) Execute added in v1.0.6

func (executor *OthersExecutor) 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 UnionExecutor added in v1.0.7

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

UnionExecutor represents select executor

func NewUnionExecutor added in v1.0.7

func NewUnionExecutor(log *xlog.Log, plan planner.Plan, txn backend.Transaction) *UnionExecutor

NewUnionExecutor creates the new select executor.

func (*UnionExecutor) Execute added in v1.0.7

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

Execute used to execute the executor.

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.

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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