mysql

package
v1.7.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 22, 2018 License: AGPL-3.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

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

MySQL error codes

Variables

View Source 
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) GetGlobalVarBoolean added in v1.5.0 

func (c *Connection) GetGlobalVarBoolean(varName string) (varValue sql.NullBool, err error)

func (*Connection) GetGlobalVarInteger added in v1.5.0 

func (c *Connection) GetGlobalVarInteger(varName string) (varValue sql.NullInt64, err error)

func (*Connection) GetGlobalVarNumeric added in v1.5.0 

func (c *Connection) GetGlobalVarNumeric(varName string) (varValue sql.NullFloat64, err error)

func (*Connection) GetGlobalVarString 

func (c *Connection) GetGlobalVarString(varName string) (varValue sql.NullString, err error)

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)

func (*Connection) VersionConstraint added in v1.5.0 

func (c *Connection) VersionConstraint(constraint string) (bool, error)

VersionConstraint checks if version fits given constraint

type ConnectionFactory 

type ConnectionFactory interface {
	Make(dsn string) Connector
}

type Connector 

type Connector interface {
	VersionConstraint(constraint string) (bool, error)
	AtLeastVersion(string) (bool, error)
	Connect() error
	Close()
	DB() *sql.DB
	DSN() string
	Exec([]string) error
	GetGlobalVarBoolean(varName string) (varValue sql.NullBool, err error)
	GetGlobalVarString(varName string) (varValue sql.NullString, err error)
	GetGlobalVarNumeric(varName string) (varValue sql.NullFloat64, err error)
	GetGlobalVarInteger(varName string) (varValue sql.NullInt64, err error)
	Set([]Query) error
	Uptime() (uptime int64, err 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

Source Files

  • error.go
  • factory.go
  • mysql.go

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.