Versions in this module Expand all Collapse all v0 v0.0.4 Feb 5, 2025 Changes in this version + const CommitTransaction + const DummyPreparedStmt + const RollbackTransaction + const StartTransaction + type DBConnection interface + Execute func(query string, args ...interface{}) (*mysql.Result, error) + FieldList func(table, fieldWildcard string) ([]*mysql.Field, error) + Prepare func(query string) (DBStatement, error) + func NewMySQLConnWrapper(conn *client.Conn) DBConnection + type DBStatement interface + Close func() error + ColumnNum func() int + Execute func(args ...interface{}) (*mysql.Result, error) + ParamNum func() int + type EmptyReplicationHandler struct + func (h *EmptyReplicationHandler) HandleBinlogDump(mysql.Position) (*replication.BinlogStreamer, error) + func (h *EmptyReplicationHandler) HandleBinlogDumpGTID(*mysql.MysqlGTIDSet) (*replication.BinlogStreamer, error) + func (h *EmptyReplicationHandler) HandleRegisterSlave([]byte) error + type MySQLConnWrapper struct + func (c *MySQLConnWrapper) Execute(query string, args ...interface{}) (*mysql.Result, error) + func (c *MySQLConnWrapper) FieldList(table, fieldWildcard string) ([]*mysql.Field, error) + func (c *MySQLConnWrapper) Prepare(query string) (DBStatement, error) + type MySQLStmtWrapper struct + func (s *MySQLStmtWrapper) Close() error + func (s *MySQLStmtWrapper) ColumnNum() int + func (s *MySQLStmtWrapper) Execute(args ...interface{}) (*mysql.Result, error) + func (s *MySQLStmtWrapper) ParamNum() int + type StmtWithParsedDataContext struct + GuidFinder *sqlparser.CharGUIDFinder + IsDummy bool + Stmts map[uint32]DBStatement + type TC9Proxy struct + func NewTC9Proxy(clientID int, connections map[uint32]DBConnection, parser *parser.Parser) *TC9Proxy + func (p *TC9Proxy) ConnByRealm(realmID uint32) DBConnection + func (p *TC9Proxy) HandleFieldList(table string, fieldWildcard string) ([]*mysql.Field, error) + func (p *TC9Proxy) HandleOtherCommand(cmd byte, data []byte) error + func (p *TC9Proxy) HandleQuery(query string) (*mysql.Result, error) + func (p *TC9Proxy) HandleStmtClose(context interface{}) error + func (p *TC9Proxy) HandleStmtExecute(ctx interface{}, query string, args []interface{}) (*mysql.Result, error) + func (p *TC9Proxy) HandleStmtPrepare(query string) (int, int, interface{}, error) + func (p *TC9Proxy) RunOnEveryConn(f func(db DBConnection)) + func (p *TC9Proxy) UseDB(string) error + type TransactionState uint8 + const TransactionInProgress + const TransactionNone + const TransactionRequested
Go to main page