session

Documentation

Index

• func Start(cmd *cobra.Command, sessionManagerCfg *SessionManagerConfig) error
• type CmdType
• type ConnHandler
  • func NewHandler(config *SessionManagerConfig, connIdent string) (*ConnHandler, error)
  • func (h *ConnHandler) Finalize() error
  • func (h *ConnHandler) HandleFieldList(table string, fieldWildcard string) ([]*mysql.Field, error)
  • func (h *ConnHandler) HandleQuery(query string) (*mysql.Result, error)
  • func (h *ConnHandler) HandleStmtExecute(context interface{}, query string, args []interface{}) (*mysql.Result, error)
  • func (h *ConnHandler) HandleStmtPrepare(query string) (int, int, interface{}, error)
  • func (h *ConnHandler) UseDB(db string) error
• type MySQLConfig
• type SessionManagerConfig

Functions

func Start

func Start(cmd *cobra.Command, sessionManagerCfg *SessionManagerConfig) error

Types

type CmdType

type CmdType int

const (
	CmdType_Select   CmdType = 0
	CmdType_MakeView CmdType = 1
	CmdType_Other    CmdType = 256
)

type ConnHandler

type ConnHandler struct {
	server.EmptyHandler
	// contains filtered or unexported fields
}

func NewHandler

func NewHandler(config *SessionManagerConfig, connIdent string) (*ConnHandler, error)

func (*ConnHandler) Finalize

func (h *ConnHandler) Finalize() error

func (*ConnHandler) HandleFieldList

func (h *ConnHandler) HandleFieldList(table string, fieldWildcard string) ([]*mysql.Field, error)

func (*ConnHandler) HandleQuery

func (h *ConnHandler) HandleQuery(query string) (*mysql.Result, error)

func (*ConnHandler) HandleStmtExecute

func (h *ConnHandler) HandleStmtExecute(context interface{}, query string, args []interface{}) (*mysql.Result, error)

func (*ConnHandler) HandleStmtPrepare

func (h *ConnHandler) HandleStmtPrepare(query string) (int, int, interface{}, error)

func (*ConnHandler) UseDB

func (h *ConnHandler) UseDB(db string) error

type MySQLConfig

type MySQLConfig struct {
	Host    string
	Port    int
	User    string
	Pass    string
	Db      string
	Options string
}

MySQLConfig configures a MySQL compatible database connection.

type SessionManagerConfig

type SessionManagerConfig struct {
	User  string
	Pass  string
	Port  int
	MySQL MySQLConfig
}

SessionManagerConfig is the configuration for the step.