mysql

Documentation

Index

• type Conn
  • func NewClientConnection(conn net.Conn, capabilities core.CapabilityFlag) Conn
  • func NewServerConnection(conn net.Conn, connId uint32, capabilities core.CapabilityFlag) Conn
• type Result
  • func NewResult(affectedRows, lastInsertId uint64) *Result
  • func (r *Result) AffectedRows() uint64
  • func (r *Result) LastInsertId() uint64

Types

type Conn

type Conn interface {
	SetCapabilities(capabilities core.CapabilityFlag)

	ClientTLS(config *tls.Config)
	ServerTLS(config *tls.Config)
	TLS() bool

	ConnectionId() uint32
	Capabilities() core.CapabilityFlag

	ReadPacket() ([]byte, error)

	WritePacket(packet.Packet) error
	WriteCommandPacket(packet.Packet) error

	WriteEmptyOK() error
	WriteError(error) error

	Close() error
	Closed() bool
}

func NewClientConnection

func NewClientConnection(conn net.Conn, capabilities core.CapabilityFlag) Conn

func NewServerConnection

func NewServerConnection(conn net.Conn, connId uint32, capabilities core.CapabilityFlag) Conn

type Result

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

func NewResult

func NewResult(affectedRows, lastInsertId uint64) *Result

func (*Result) AffectedRows

func (r *Result) AffectedRows() uint64

func (*Result) LastInsertId

func (r *Result) LastInsertId() uint64