plan

Documentation

Index

• Constants
• type DeletePlan
  • func (p *DeletePlan) Execute(ctx context.Context, hints ...*ast.TableOptimizerHint) (proto.Result, uint16, error)
• type InsertPlan
  • func (p *InsertPlan) Execute(ctx context.Context, hints ...*ast.TableOptimizerHint) (proto.Result, uint16, error)
• type Limit
• type MultiDeletePlan
  • func (p *MultiDeletePlan) Execute(ctx context.Context, _ ...*ast.TableOptimizerHint) (result proto.Result, warns uint16, err error)
• type MultiUpdatePlan
  • func (p *MultiUpdatePlan) Execute(ctx context.Context, _ ...*ast.TableOptimizerHint) (result proto.Result, warns uint16, err error)
• type OrderByCell
• type OrderByCells
  • func (c OrderByCells) Len() int
  • func (c OrderByCells) Less(i, j int) bool
  • func (c OrderByCells) Swap(i, j int)
• type OrderField
• type QueryOnMultiDBPlan
  • func (p *QueryOnMultiDBPlan) Execute(ctx context.Context, _ ...*ast.TableOptimizerHint) (proto.Result, uint16, error)
• type QueryOnSingleDBPlan
  • func (p *QueryOnSingleDBPlan) Execute(ctx context.Context, hints ...*ast.TableOptimizerHint) (proto.Result, uint16, error)
• type ResultWithErr
• type ResultWithErrs
  • func (r ResultWithErrs) Len() int
  • func (r ResultWithErrs) Less(i, j int) bool
  • func (r ResultWithErrs) Swap(i, j int)
• type UpdatePlan
  • func (p *UpdatePlan) Execute(ctx context.Context, hints ...*ast.TableOptimizerHint) (proto.Result, uint16, error)

Constants

const FuncColumns = "FuncColumns"

Types

type DeletePlan

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

func (*DeletePlan) Execute

func (p *DeletePlan) Execute(ctx context.Context, hints ...*ast.TableOptimizerHint) (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, hints ...*ast.TableOptimizerHint) (proto.Result, uint16, error)

type Limit

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

type MultiDeletePlan

type MultiDeletePlan struct {
	Stmt  *ast.DeleteStmt
	Plans []*DeletePlan
}

func (*MultiDeletePlan) Execute

func (p *MultiDeletePlan) Execute(ctx context.Context, _ ...*ast.TableOptimizerHint) (result proto.Result, warns uint16, err error)

type MultiUpdatePlan

type MultiUpdatePlan struct {
	Stmt  *ast.UpdateStmt
	Plans []*UpdatePlan
}

func (*MultiUpdatePlan) Execute

func (p *MultiUpdatePlan) Execute(ctx context.Context, _ ...*ast.TableOptimizerHint) (result proto.Result, warns uint16, err error)

type OrderByCell

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

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 OrderField

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

type QueryOnMultiDBPlan

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

func (*QueryOnMultiDBPlan) Execute

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

type QueryOnSingleDBPlan

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

func (*QueryOnSingleDBPlan) Execute

func (p *QueryOnSingleDBPlan) Execute(ctx context.Context, hints ...*ast.TableOptimizerHint) (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 UpdatePlan

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

func (*UpdatePlan) Execute

func (p *UpdatePlan) Execute(ctx context.Context, hints ...*ast.TableOptimizerHint) (proto.Result, uint16, error)