Documentation ¶
Overview ¶
@author: panfengguo @since: 2022/11/19 @desc: desc
@author: panfengguo @since: 2022/11/19 @desc: desc
@author: panfengguo @since: 2022/11/20 @desc: desc
@author: panfengguo @since: 2022/11/19 @desc: desc
@author: panfengguo @since: 2022/11/19 @desc: desc
Index ¶
- Constants
- func Compare(cell1 Cell, cell2 Cell, comp plan.CompareType_) bool
- func RegisterService(service ExecutorService) error
- func RemoteGetDataNum(site, table string) (int, error)
- func RunExecutor(config *config.ServerConfig)
- type Cell
- type CellInt
- type CellString
- type CellType
- type ExecuteQTArgs
- type ExecuteQTReply
- type Executor
- func (e *Executor) ExecuteCreateFrag(op *plan.Operator_) (*QueryResult, error)
- func (e *Executor) ExecuteDelete(op *plan.Operator_) (*QueryResult, error)
- func (e *Executor) ExecuteFunc(op *plan.Operator_) (*QueryResult, error)
- func (e *Executor) ExecuteInsert(op *plan.Operator_) (*QueryResult, error)
- func (e *Executor) ExecuteJoin(op *plan.Operator_) (*QueryResult, error)
- func (e *Executor) ExecutePredicate(op *plan.Operator_) (*QueryResult, error)
- func (e *Executor) ExecuteProject(op *plan.Operator_) (*QueryResult, error)
- func (e *Executor) ExecuteQT(args ExecuteQTArgs, reply *ExecuteQTReply) error
- func (e *Executor) ExecuteScan(op *plan.Operator_) (*QueryResult, error)
- func (e *Executor) ExecuteSelectCount(table string) (int, error)
- func (e *Executor) ExecuteUnion(op *plan.Operator_) (*QueryResult, error)
- func (e *Executor) GetDataNum(args GetDataNumArgs, reply *GetDataNumReply) error
- type ExecutorService
- type Field
- type GetDataNumArgs
- type GetDataNumReply
- type QueryResult
- type TempType
Constants ¶
View Source
const ( ScanSqlStr = "SELECT * FROM %s;" CreateTbStr = ` CREATE TABLE IF NOT EXISTS %s(%s )ENGINE=InnoDB DEFAULT CHARSET=utf8;` InsertSqlStr = `INSERT INTO %s (%s) VALUES (%s);` DeleteSqlStr = `DELETE FROM %s;` SelectCountSqlStr = `SELECT COUNT(1) FROM %s;` )
View Source
const ( CellIntType = iota CellStringType )
View Source
const ( ExecutorSvc = "ExecutorService" ExecuteQT = "ExecuteQT" GetDataNum = "GetDataNum" )
Variables ¶
This section is empty.
Functions ¶
func RegisterService ¶
func RegisterService(service ExecutorService) error
func RemoteGetDataNum ¶
func RunExecutor ¶
func RunExecutor(config *config.ServerConfig)
Types ¶
type CellString ¶
type CellString string
func (CellString) String ¶
func (c CellString) String() string
func (CellString) Type ¶
func (c CellString) Type() CellType
type ExecuteQTArgs ¶
type ExecuteQTReply ¶
type ExecuteQTReply struct {
QueryResult *QueryResult
}
type Executor ¶
type Executor struct { Ip string // executor服务ip Port int // executor服务端口 Db *sql.DB // executor本地db }
func NewExecutor ¶
func NewExecutor(config *config.ServerConfig) *Executor
func (*Executor) ExecuteCreateFrag ¶
func (e *Executor) ExecuteCreateFrag(op *plan.Operator_) (*QueryResult, error)
func (*Executor) ExecuteDelete ¶
func (e *Executor) ExecuteDelete(op *plan.Operator_) (*QueryResult, error)
func (*Executor) ExecuteFunc ¶
func (e *Executor) ExecuteFunc(op *plan.Operator_) (*QueryResult, error)
func (*Executor) ExecuteInsert ¶
func (e *Executor) ExecuteInsert(op *plan.Operator_) (*QueryResult, error)
func (*Executor) ExecuteJoin ¶
func (e *Executor) ExecuteJoin(op *plan.Operator_) (*QueryResult, error)
func (*Executor) ExecutePredicate ¶
func (e *Executor) ExecutePredicate(op *plan.Operator_) (*QueryResult, error)
func (*Executor) ExecuteProject ¶
func (e *Executor) ExecuteProject(op *plan.Operator_) (*QueryResult, error)
func (*Executor) ExecuteQT ¶
func (e *Executor) ExecuteQT(args ExecuteQTArgs, reply *ExecuteQTReply) error
func (*Executor) ExecuteScan ¶
func (e *Executor) ExecuteScan(op *plan.Operator_) (*QueryResult, error)
func (*Executor) ExecuteSelectCount ¶
func (*Executor) ExecuteUnion ¶
func (e *Executor) ExecuteUnion(op *plan.Operator_) (*QueryResult, error)
func (*Executor) GetDataNum ¶
func (e *Executor) GetDataNum(args GetDataNumArgs, reply *GetDataNumReply) error
type ExecutorService ¶
type ExecutorService interface { ExecuteQT(args ExecuteQTArgs, reply *ExecuteQTReply) error GetDataNum(args GetDataNumArgs, reply *GetDataNumReply) error }
type GetDataNumArgs ¶
type GetDataNumArgs struct {
Table string
}
type GetDataNumReply ¶
type GetDataNumReply struct {
DataNum int
}
type QueryResult ¶
func NewQueryResult ¶
func NewQueryResult(columnTypes []*sql.ColumnType, tableName string) (*QueryResult, error)
func RemoteExecuteQT ¶
func RemoteExecuteQT(host string, planT *plan.Plantree) (*QueryResult, error)
func (*QueryResult) NewDataRow ¶
func (q *QueryResult) NewDataRow() ([]interface{}, error)
func (*QueryResult) PrintResult ¶
func (q *QueryResult) PrintResult()
func (*QueryResult) String ¶
func (q *QueryResult) String() string
Click to show internal directories.
Click to hide internal directories.