Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var CreateConnection = func(dbHost *DBHost) Connection { return new(nilConnection) }
CreateConnection create connection function, this is default value, must replace it.
Functions ¶
This section is empty.
Types ¶
type Connection ¶
type Connection interface { // GetConnectionID get connection id GetConnectionID() uint32 // SetConnectionID set connection id SetConnectionID(id uint32) // Connect db server. Connect(dbHost *DBHost, db string) error // Reconnect db server. Reconnect() error // Close db server. Close() error // ReturnConnection give back connection. ReturnConnection() // UseDB to set current db. UseDB(database string) error // Ping db server. Ping() error // Begin transaction Begin() error // Commit transaction Commit() error // Rollback transaction Rollback() error // SetAutoCommit SetAutoCommit(autocommit bool) error // GetAddr Get addr info GetAddr() string // IsClosed check connection status IsClosed() bool }
Connection is backend connection.
type ConnectionPool ¶
type ConnectionPool struct { MaxPoolSize uint32 // contains filtered or unexported fields }
ConnectionPool to manage connection pool.
func NewConnectionPool ¶
func NewConnectionPool(maxPoolSize uint32, dbHost *DBHost) *ConnectionPool
NewConnectionPool create connection pool
func (*ConnectionPool) GetConnection ¶
func (p *ConnectionPool) GetConnection(database string) (Connection, error)
GetConnection get connection from pool
func (*ConnectionPool) GetIdleCount ¶
func (p *ConnectionPool) GetIdleCount() uint32
GetIdleCount Get Idle count.
func (*ConnectionPool) ReturnConnection ¶
func (p *ConnectionPool) ReturnConnection(conn Connection)
ReturnConnection give back connection to pool
type DBHost ¶
type DBHost struct { Addr string User string Password string Weight int Pool *ConnectionPool }
DBHost db host.
func (*DBHost) GetConnection ¶
func (h *DBHost) GetConnection(database string) (Connection, error)
GetConnection to connect a backend conn.
func (*DBHost) ReturnConnection ¶
func (h *DBHost) ReturnConnection(conn Connection)
ReturnConnection tu give back a backend conn.
Click to show internal directories.
Click to hide internal directories.