mysql

Documentation

Index

• type Connector
  • func New(prefixHost, prefixClient string, logger logging.Logger) *Connector
• type DB

Types

type Connector

type Connector struct {
	DB

	WatcherConfigFuncs []daemon.WatcherConfigFunc
	daemon.HealthCheckFunc
	daemon.ShutdownFunc
	// contains filtered or unexported fields
}

Connector is wrapper sql.DB.

func New

func New(prefixHost, prefixClient string, logger logging.Logger) *Connector

New get a instance of mysql.

type DB

type DB interface {
	Begin() (*sql.Tx, error)
	BeginTx(context.Context, *sql.TxOptions) (*sql.Tx, error)
	Close() error
	Conn(context.Context) (*sql.Conn, error)
	Driver() driver.Driver
	Exec(string, ...interface{}) (sql.Result, error)
	ExecContext(context.Context, string, ...interface{}) (sql.Result, error)
	Ping() error
	PingContext(context.Context) error
	Prepare(string) (*sql.Stmt, error)
	PrepareContext(context.Context, string) (*sql.Stmt, error)
	Query(string, ...interface{}) (*sql.Rows, error)
	QueryContext(context.Context, string, ...interface{}) (*sql.Rows, error)
	QueryRow(string, ...interface{}) *sql.Row
	QueryRowContext(context.Context, string, ...interface{}) *sql.Row
	SetConnMaxIdleTime(time.Duration)
	SetConnMaxLifetime(time.Duration)
	SetMaxIdleConns(int)
	SetMaxOpenConns(int)
	Stats() sql.DBStats
}

DB is a sql interface.