mysql

Documentation

Index

• Variables
• func In(keys interface{}) string
• type MysqlDB
  • func New(wConn string, rConns []string) (mdb *MysqlDB, err error)
  • func (db *MysqlDB) Begin() (*sql.Tx, error)
  • func (db *MysqlDB) Close() error
  • func (db *MysqlDB) Exec(query string, args ...interface{}) (sql.Result, error)
  • func (db *MysqlDB) Ping() (err error)
  • func (db *MysqlDB) PrepareExec(query string) (*sql.Stmt, error)
  • func (db *MysqlDB) PrepareQuery(query string) (*sql.Stmt, error)
  • func (db *MysqlDB) Query(query string, args ...interface{}) (*sql.Rows, error)
  • func (db *MysqlDB) QueryFromMain(query string, args ...interface{}) (*sql.Rows, error)
  • func (db *MysqlDB) QueryRow(query string, args ...interface{}) *sql.Row
  • func (db *MysqlDB) QueryRowFromMain(query string, args ...interface{}) *sql.Row

Variables

var ErrNoRows = sql.ErrNoRows

Functions

func In

func In(keys interface{}) string

Types

type MysqlDB

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

func New

func New(wConn string, rConns []string) (mdb *MysqlDB, err error)

func (*MysqlDB) Begin

func (db *MysqlDB) Begin() (*sql.Tx, error)

func (*MysqlDB) Close

func (db *MysqlDB) Close() error

func (*MysqlDB) Exec

func (db *MysqlDB) Exec(query string, args ...interface{}) (sql.Result, error)

func (*MysqlDB) Ping

func (db *MysqlDB) Ping() (err error)

func (*MysqlDB) PrepareExec

func (db *MysqlDB) PrepareExec(query string) (*sql.Stmt, error)

func (*MysqlDB) PrepareQuery

func (db *MysqlDB) PrepareQuery(query string) (*sql.Stmt, error)

func (*MysqlDB) Query

func (db *MysqlDB) Query(query string, args ...interface{}) (*sql.Rows, error)

func (*MysqlDB) QueryFromMain

func (db *MysqlDB) QueryFromMain(query string, args ...interface{}) (*sql.Rows, error)

从主库读

func (*MysqlDB) QueryRow

func (db *MysqlDB) QueryRow(query string, args ...interface{}) *sql.Row

func (*MysqlDB) QueryRowFromMain

func (db *MysqlDB) QueryRowFromMain(query string, args ...interface{}) *sql.Row

从主库中查询