mysql

Documentation

Index

• Constants
• Variables
• func GetMysqlConnection(uri string) (*sql.DB, error)
• func ProcessSchema(ctx context.Context, opts daemontypes.DaemonOpts)
• func RunProxy(ctx context.Context, opts daemontypes.DaemonOpts)
• type MysqlPacketType

Constants

const (
	COM_QUIT             = 0x01
	COM_INIT_DB          = 0x02
	COM_QUERY            = 0x03
	COM_FIELD_LIST       = 0x04
	COM_CREATE_DB        = 0x05
	COM_DROP_DB          = 0x06
	COM_REFRESH          = 0x07
	COM_STATISTICS       = 0x09
	COM_PROCESS_INFO     = 0x0a
	COM_CONNECT          = 0x0b
	COM_PROCESS_KILL     = 0x0c
	COM_DEBUG            = 0x0d
	COM_PING             = 0x0e
	COM_CHANGE_USER      = 0x11
	COM_RESET_CONNECTION = 0x1f
	COM_STMT_PREPARE     = 0x16
	COM_STMT_EXECUTE     = 0x17
	COM_STMT_CLOSE       = 0x19
)

const (
	MysqlPacketTypeUnknown           = 0xFF
	MysqlPacketTypeOKPacket          = 0x00
	MysqlPacketTypeEOFPacket         = 0xFE
	MysqlPacketTypeHandshake         = 0x0A
	MysqlPacketTypeHandshakeResponse = 0x01
	MysqlPacketTypeColumnDefinition  = 0x03
	MysqlPacketTypeComFieldList      = 0x04
)

Variables

var (
	ErrNonQueryData                   = fmt.Errorf("non-query data")
	ErrNonQueryDataOrIncompletePacket = fmt.Errorf("non-query data or incomplete packet")
	ErrUnknownPreparedStatement       = fmt.Errorf("unknown prepared statement")
)

var (
	DB *sql.DB
)

var (
	Interval = 30 * time.Minute
)

Functions

func GetMysqlConnection

func GetMysqlConnection(uri string) (*sql.DB, error)

func ProcessSchema

func ProcessSchema(ctx context.Context, opts daemontypes.DaemonOpts)

func RunProxy

func RunProxy(ctx context.Context, opts daemontypes.DaemonOpts)

Types

type MysqlPacketType

type MysqlPacketType byte