mysql

Documentation

Index

• Constants
• Variables
• func Distro(distro string) string
• func FormatError(err error) string
• func MySQLErrorCode(err error) uint16
• type Connection
  • func NewConnection(dsn string) *Connection
  • func (c *Connection) AtLeastVersion(minVersion string) (bool, error)
  • func (c *Connection) Close()
  • func (c *Connection) Connect() error
  • func (c *Connection) DB() *sql.DB
  • func (c *Connection) DSN() string
  • func (c *Connection) Exec(queries []string) error
  • func (c *Connection) GetGlobalVarNumber(varName string) float64
  • func (c *Connection) GetGlobalVarString(varName string) string
  • func (c *Connection) Set(queries []Query) error
  • func (c *Connection) UTCOffset() (time.Duration, time.Duration, error)
  • func (c *Connection) Uptime() (uptime int64, err error)
• type ConnectionFactory
• type Connector
• type Query
• type RealConnectionFactory
  • func (f *RealConnectionFactory) Make(dsn string) Connector

Constants

const (
	ER_SPECIFIC_ACCESS_DENIED_ERROR = 1227
	ER_SYNTAX_ERROR                 = 1064
	ER_USER_DENIED                  = 1142
)

MySQL error codes

Variables

var ErrNotConnected = errors.New("not connected")

Functions

func Distro

func Distro(distro string) string

func FormatError

func FormatError(err error) string

func MySQLErrorCode

func MySQLErrorCode(err error) uint16

Types

type Connection

type Connection struct {
	*sync.Mutex
	// contains filtered or unexported fields
}

func NewConnection

func NewConnection(dsn string) *Connection

func (*Connection) AtLeastVersion

func (c *Connection) AtLeastVersion(minVersion string) (bool, error)

Check if version v2 is equal or higher than v1 (v2 >= v1) v2 can be in form m.n.o-ubuntu

func (*Connection) Close

func (c *Connection) Close()

func (*Connection) Connect

func (c *Connection) Connect() error

func (*Connection) DB

func (c *Connection) DB() *sql.DB

func (*Connection) DSN

func (c *Connection) DSN() string

func (*Connection) Exec

func (c *Connection) Exec(queries []string) error

func (*Connection) GetGlobalVarNumber

func (c *Connection) GetGlobalVarNumber(varName string) float64

func (*Connection) GetGlobalVarString

func (c *Connection) GetGlobalVarString(varName string) string

func (*Connection) Set

func (c *Connection) Set(queries []Query) error

func (*Connection) UTCOffset

func (c *Connection) UTCOffset() (time.Duration, time.Duration, error)

func (*Connection) Uptime

func (c *Connection) Uptime() (uptime int64, err error)

type ConnectionFactory

type ConnectionFactory interface {
	Make(dsn string) Connector
}

type Connector

type Connector interface {
	DB() *sql.DB
	DSN() string
	Connect() error
	Close()
	Set([]Query) error
	Exec([]string) error
	GetGlobalVarString(varName string) string
	GetGlobalVarNumber(varName string) float64
	Uptime() (uptime int64, err error)
	AtLeastVersion(string) (bool, error)
	UTCOffset() (time.Duration, time.Duration, error)
}

type Query

type Query struct {
	Set    string // SET GLOBAL long_query_time=0
	Verify string // SELECT @@long_query_time
	Expect string // 0
}

type RealConnectionFactory

type RealConnectionFactory struct {
}

func (*RealConnectionFactory) Make

func (f *RealConnectionFactory) Make(dsn string) Connector