client

Documentation

Index

• type Conn
  • func CreateConnection(opts ...Option) (Conn, error)
• type Option
  • func WithAttribute(key string, val string) Option
  • func WithCollation(collation *core.Collation) Option
  • func WithHost(host string) Option
  • func WithInsecureSkipVerify(insecureSkipVerify bool) Option
  • func WithLocation(loc *time.Location) Option
  • func WithPassword(password string) Option
  • func WithPort(port int) Option
  • func WithSSLCA(sslCA string) Option
  • func WithSSLCert(sslCert string) Option
  • func WithSSLKey(sslKey string) Option
  • func WithUseSSL(useSSL bool) Option
  • func WithUser(user string) Option
• type Rows

Types

type Conn

type Conn interface {
	Capabilities() core.CapabilityFlag
	AffectedRows() uint64
	LastInsertId() uint64

	ReadPacket() ([]byte, error)

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

	Exec(string) (*mysql.Result, error)
	Query(string) (Rows, error)

	Ping() error
	Close() error
}

func CreateConnection

func CreateConnection(opts ...Option) (Conn, error)

type Option

type Option interface {
	// contains filtered or unexported methods
}

func WithAttribute

func WithAttribute(key string, val string) Option

func WithCollation

func WithCollation(collation *core.Collation) Option

func WithHost

func WithHost(host string) Option

func WithInsecureSkipVerify

func WithInsecureSkipVerify(insecureSkipVerify bool) Option

func WithLocation

func WithLocation(loc *time.Location) Option

func WithPassword

func WithPassword(password string) Option

func WithPort

func WithPort(port int) Option

func WithSSLCA

func WithSSLCA(sslCA string) Option

func WithSSLCert

func WithSSLCert(sslCert string) Option

func WithSSLKey

func WithSSLKey(sslKey string) Option

func WithUseSSL

func WithUseSSL(useSSL bool) Option

func WithUser

func WithUser(user string) Option

type Rows

type Rows interface {
	Columns() []packet.Column

	Next() (packet.Row, error)

	// HasNextResultSet is called at the end of the current result set and
	// reports whether there is another result set after the current one.
	HasNextResultSet() bool

	// NextResultSet advances the driver to the next result set even
	// if there are remaining rows in the current result set.
	//
	// NextResultSet should return io.EOF when there are no more result sets.
	NextResultSet() error
}