group

Documentation

Index

• func NewComplexTx(optimizer proto.Optimizer) proto.DBGroupTx
• func NewDBGroup(appid, name string, algorithm config.LoadBalanceAlgorithm, ...) (proto.DBGroupExecutor, error)
• type ComplexTx
  • func (tx *ComplexTx) Begin(ctx context.Context, executor proto.DBGroupExecutor) (proto.Tx, error)
  • func (tx *ComplexTx) Close()
  • func (tx *ComplexTx) Commit(ctx context.Context) (result proto.Result, err error)
  • func (tx *ComplexTx) Execute(ctx context.Context, stmt ast.StmtNode, args ...interface{}) (proto.Result, uint16, error)
  • func (tx *ComplexTx) Query(ctx context.Context, query string) (proto.Result, uint16, error)
  • func (tx *ComplexTx) Rollback(ctx context.Context) (result proto.Result, err error)
• type DBGroup
  • func (group *DBGroup) AddDB(db proto.DB)
  • func (group *DBGroup) Begin(ctx context.Context) (proto.Tx, proto.Result, error)
  • func (group *DBGroup) Execute(ctx context.Context, query string) (proto.Result, uint16, error)
  • func (group *DBGroup) GroupName() string
  • func (group *DBGroup) PrepareExecute(ctx context.Context, query string, args ...interface{}) (proto.Result, uint16, error)
  • func (group *DBGroup) PrepareExecuteStmt(ctx context.Context, stmt *proto.Stmt) (proto.Result, uint16, error)
  • func (group *DBGroup) PrepareQuery(ctx context.Context, query string, args ...interface{}) (proto.Result, uint16, error)
  • func (group *DBGroup) Query(ctx context.Context, query string) (proto.Result, uint16, error)
  • func (group *DBGroup) QueryAll(ctx context.Context, query string) (proto.Result, uint16, error)
  • func (group *DBGroup) RemoveDB(name string)
  • func (group *DBGroup) XAStart(ctx context.Context, sql string) (proto.Tx, proto.Result, error)

Functions

func NewComplexTx

func NewComplexTx(optimizer proto.Optimizer) proto.DBGroupTx

func NewDBGroup

func NewDBGroup(appid, name string,
	algorithm config.LoadBalanceAlgorithm,
	dataSources []*config.DataSourceRef) (proto.DBGroupExecutor, error)

Types

type ComplexTx

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

func (*ComplexTx) Begin

func (tx *ComplexTx) Begin(ctx context.Context, executor proto.DBGroupExecutor) (proto.Tx, error)

func (*ComplexTx) Close

func (tx *ComplexTx) Close()

func (*ComplexTx) Commit

func (tx *ComplexTx) Commit(ctx context.Context) (result proto.Result, err error)

func (*ComplexTx) Execute

func (tx *ComplexTx) Execute(ctx context.Context, stmt ast.StmtNode, args ...interface{}) (proto.Result, uint16, error)

func (*ComplexTx) Query

func (tx *ComplexTx) Query(ctx context.Context, query string) (proto.Result, uint16, error)

func (*ComplexTx) Rollback

func (tx *ComplexTx) Rollback(ctx context.Context) (result proto.Result, err error)

type DBGroup

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

func (*DBGroup) AddDB

func (group *DBGroup) AddDB(db proto.DB)

func (*DBGroup) Begin

func (group *DBGroup) Begin(ctx context.Context) (proto.Tx, proto.Result, error)

func (*DBGroup) Execute

func (group *DBGroup) Execute(ctx context.Context, query string) (proto.Result, uint16, error)

func (*DBGroup) GroupName

func (group *DBGroup) GroupName() string

func (*DBGroup) PrepareExecute

func (group *DBGroup) PrepareExecute(ctx context.Context, query string, args ...interface{}) (proto.Result, uint16, error)

func (*DBGroup) PrepareExecuteStmt

func (group *DBGroup) PrepareExecuteStmt(ctx context.Context, stmt *proto.Stmt) (proto.Result, uint16, error)

func (*DBGroup) PrepareQuery

func (group *DBGroup) PrepareQuery(ctx context.Context, query string, args ...interface{}) (proto.Result, uint16, error)

func (*DBGroup) Query

func (group *DBGroup) Query(ctx context.Context, query string) (proto.Result, uint16, error)

func (*DBGroup) QueryAll

func (group *DBGroup) QueryAll(ctx context.Context, query string) (proto.Result, uint16, error)

func (*DBGroup) RemoveDB

func (group *DBGroup) RemoveDB(name string)

func (*DBGroup) XAStart

func (group *DBGroup) XAStart(ctx context.Context, sql string) (proto.Tx, proto.Result, error)