gorpcqueryservice

Documentation

Index

• type SqlQuery
  • func (sq *SqlQuery) Begin(ctx *rpcproto.Context, session *proto.Session, txInfo *proto.TransactionInfo) error
  • func (sq *SqlQuery) Commit(ctx *rpcproto.Context, session *proto.Session, noOutput *string) error
  • func (sq *SqlQuery) Execute(ctx *rpcproto.Context, query *proto.Query, reply *mproto.QueryResult) error
  • func (sq *SqlQuery) ExecuteBatch(ctx *rpcproto.Context, queryList *proto.QueryList, ...) error
  • func (sq *SqlQuery) GetSessionId(sessionParams *proto.SessionParams, sessionInfo *proto.SessionInfo) error
  • func (sq *SqlQuery) Rollback(ctx *rpcproto.Context, session *proto.Session, noOutput *string) error
  • func (sq *SqlQuery) SplitQuery(ctx *rpcproto.Context, req *proto.SplitQueryRequest, ...) error
  • func (sq *SqlQuery) StreamExecute(ctx *rpcproto.Context, query *proto.Query, ...) error

Types

type SqlQuery

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

func (*SqlQuery) Begin

func (sq *SqlQuery) Begin(ctx *rpcproto.Context, session *proto.Session, txInfo *proto.TransactionInfo) error

func (*SqlQuery) Commit

func (sq *SqlQuery) Commit(ctx *rpcproto.Context, session *proto.Session, noOutput *string) error

func (*SqlQuery) Execute

func (sq *SqlQuery) Execute(ctx *rpcproto.Context, query *proto.Query, reply *mproto.QueryResult) error

func (*SqlQuery) ExecuteBatch

func (sq *SqlQuery) ExecuteBatch(ctx *rpcproto.Context, queryList *proto.QueryList, reply *proto.QueryResultList) error

func (*SqlQuery) GetSessionId

func (sq *SqlQuery) GetSessionId(sessionParams *proto.SessionParams, sessionInfo *proto.SessionInfo) error

func (*SqlQuery) Rollback

func (sq *SqlQuery) Rollback(ctx *rpcproto.Context, session *proto.Session, noOutput *string) error

func (*SqlQuery) SplitQuery

func (sq *SqlQuery) SplitQuery(ctx *rpcproto.Context, req *proto.SplitQueryRequest, reply *proto.SplitQueryResult) error

func (*SqlQuery) StreamExecute

func (sq *SqlQuery) StreamExecute(ctx *rpcproto.Context, query *proto.Query, sendReply func(reply interface{}) error) error