db

package
v0.0.0-...-0c5ff18 Latest Latest
Warning

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

Go to latest
Published: Aug 14, 2015 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

View Source
const (
	MAX_DB_CONNECTIONS = 100
)

Variables

This section is empty.

Functions

This section is empty.

Types

type Connection

type Connection interface {
	GetID() int
	SetID(id int)
	Close() error
	//执行语句,是否返回主键
	Create(sql string) error
	Read(sql string) (*sql.Rows, error)
	Update(sql string) error
	Delete(sql string) error
	IsUsed() bool
	Used(b bool)
}

type DbConnection

type DbConnection struct {
	*sql.DB

	sync.RWMutex
	// contains filtered or unexported fields
}

func NewDbConnection

func NewDbConnection(db *sql.DB) *DbConnection

func (*DbConnection) Close

func (conn *DbConnection) Close() error

func (*DbConnection) Create

func (conn *DbConnection) Create(sql string) error

func (*DbConnection) Delete

func (conn *DbConnection) Delete(sql string) error

func (*DbConnection) GetID

func (conn *DbConnection) GetID() int

func (*DbConnection) IsUsed

func (conn *DbConnection) IsUsed() bool

func (*DbConnection) Read

func (conn *DbConnection) Read(sql string) (*sql.Rows, error)

func (*DbConnection) SetID

func (conn *DbConnection) SetID(id int)

func (*DbConnection) Update

func (conn *DbConnection) Update(sql string) error

func (*DbConnection) Used

func (conn *DbConnection) Used(b bool)

type DbPool

type DbPool interface {
	//初始化链接池
	//数据库名称,类型,连接串,初始化连接数
	InitPool(database string, dbtype string, connstr string, initConnsNum int) error
	//从连接池中获取一个连接
	GetConnection() Connection
	//将连接还给连接池
	ReleaseConnection(conn Connection) bool
	//销毁数据连接池
	DestroyPool()
}

func NewDefaultDbPool

func NewDefaultDbPool() DbPool

type DefaultDbPool

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

func (*DefaultDbPool) DestroyPool

func (this *DefaultDbPool) DestroyPool()

func (*DefaultDbPool) GetConnection

func (this *DefaultDbPool) GetConnection() Connection

func (*DefaultDbPool) InitPool

func (this *DefaultDbPool) InitPool(database string, dbtype string, connstr string, initConnsNum int) error

func (*DefaultDbPool) ReleaseConnection

func (this *DefaultDbPool) ReleaseConnection(conn Connection) bool

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL