plan

package
v0.1.2 Latest Latest
Warning

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

 Go to latest Published: Jun 13, 2022 License: Apache-2.0 Imports: 16 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type DeleteOnMultiDBPlan added in v0.1.1 

type DeleteOnMultiDBPlan struct {
	Stmt  *ast.DeleteStmt
	Plans []*DeleteOnSingleDBPlan
}

func (*DeleteOnMultiDBPlan) Execute added in v0.1.1 

func (p *DeleteOnMultiDBPlan) Execute(ctx context.Context) (proto.Result, uint16, error)

type DeleteOnSingleDBPlan added in v0.1.1 

type DeleteOnSingleDBPlan struct {
	Database string
	Tables   []string
	Stmt     *ast.DeleteStmt
	Args     []interface{}
	Executor proto.DBGroupExecutor
}

func (*DeleteOnSingleDBPlan) Execute added in v0.1.1 

func (p *DeleteOnSingleDBPlan) Execute(ctx context.Context) (proto.Result, uint16, error)

type InsertPlan 

type InsertPlan struct {
	Database string
	Table    string
	Columns  []string
	Stmt     *ast.InsertStmt
	Args     []interface{}
	Executor proto.DBGroupExecutor
}

func (*InsertPlan) Execute 

func (p *InsertPlan) Execute(ctx context.Context) (proto.Result, uint16, error)

type Limit 

type Limit struct {
	ArgsWithoutLimit []interface{}
	Offset           int64
	Count            int64
}

type OrderByCell 

type OrderByCell struct {
	Index int
	Val   interface{}
	Next  bool
	Row   proto.Row
}

type OrderByCells 

type OrderByCells []*OrderByCell

func (OrderByCells) Len 

func (c OrderByCells) Len() int

func (OrderByCells) Less 

func (c OrderByCells) Less(i, j int) bool

func (OrderByCells) Swap 

func (c OrderByCells) Swap(i, j int)

type QueryOnMultiDBPlan 

type QueryOnMultiDBPlan struct {
	Stmt  *ast.SelectStmt
	Plans []*QueryOnSingleDBPlan
}

func (*QueryOnMultiDBPlan) Execute 

func (p *QueryOnMultiDBPlan) Execute(ctx context.Context) (proto.Result, uint16, error)

type QueryOnSingleDBPlan 

type QueryOnSingleDBPlan struct {
	Database string
	Tables   []string
	Stmt     *ast.SelectStmt
	Limit    *Limit
	Args     []interface{}
	Executor proto.DBGroupExecutor
}

func (*QueryOnSingleDBPlan) Execute 

func (p *QueryOnSingleDBPlan) Execute(ctx context.Context) (proto.Result, uint16, error)

type ResultWithErr 

type ResultWithErr struct {
	Database string
	Result   proto.Result
	Warning  uint16
	Error    error
}

type ResultWithErrs 

type ResultWithErrs []*ResultWithErr

func (ResultWithErrs) Len 

func (r ResultWithErrs) Len() int

func (ResultWithErrs) Less 

func (r ResultWithErrs) Less(i, j int) bool

func (ResultWithErrs) Swap 

func (r ResultWithErrs) Swap(i, j int)

type UpdateOnMultiDBPlan added in v0.1.2 

type UpdateOnMultiDBPlan struct {
	Stmt  *ast.UpdateStmt
	Plans []*UpdateOnSingleDBPlan
}

func (*UpdateOnMultiDBPlan) Execute added in v0.1.2 

func (p *UpdateOnMultiDBPlan) Execute(ctx context.Context) (proto.Result, uint16, error)

type UpdateOnSingleDBPlan added in v0.1.2 

type UpdateOnSingleDBPlan struct {
	Database string
	Tables   []string
	Stmt     *ast.UpdateStmt
	Args     []interface{}
	Executor proto.DBGroupExecutor
}

func (*UpdateOnSingleDBPlan) Execute added in v0.1.2 

func (p *UpdateOnSingleDBPlan) Execute(ctx context.Context) (proto.Result, uint16, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.