executor

Documentation

Index

• func KillThread(mysqlCfg *config.MysqlConfig, threadId int64) error
• type MysqlExcutor
  • func NewMysqlExcutor(execConfig *config.ExecConfig, mysqlCfg *config.MysqlConfig, query string) *MysqlExcutor
  • func (this *MysqlExcutor) Execute() ([]map[string]interface{}, []string, error)

Functions

func KillThread

func KillThread(mysqlCfg *config.MysqlConfig, threadId int64) error

Types

type MysqlExcutor

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

func NewMysqlExcutor

func NewMysqlExcutor(execConfig *config.ExecConfig, mysqlCfg *config.MysqlConfig, query string) *MysqlExcutor

func (*MysqlExcutor) Execute

func (this *MysqlExcutor) Execute() ([]map[string]interface{}, []string, error)