data

Documentation

Index

• Constants
• type DB
  • func GetDB() *DB
  • func (o *DB) Execute(sql string, args ...interface{}) error
  • func (o *DB) Init() error
  • func (o *DB) Worker(ch <-chan DBMessage, ach <-chan DBInsert, proc int)
• type DBInsert
• type DBMessage

Constants

const DB_MAX_WORKER = 100

Types

type DB

type DB struct {
	Conn      *sql.DB
	Chan      chan DBMessage
	AsyncChan chan DBInsert

	CurChanNum uint64

	MsgList *list.List
}

DB 数据库访问对象

func GetDB

func GetDB() *DB

GetDB 获取数据库访问服务

func (*DB) Execute

func (o *DB) Execute(sql string, args ...interface{}) error

Execute 执行SQL语句

func (*DB) Init

func (o *DB) Init() error

Init 初始化数据库

func (*DB) Worker

func (o *DB) Worker(ch <-chan DBMessage, ach <-chan DBInsert, proc int)

Worker 工作线程

type DBInsert

type DBInsert struct {
	SQL  string
	Args []interface{}
}

type DBMessage

type DBMessage struct {
	SQL  string
	Args []interface{}
	Dest []interface{}
	ReCh chan error
}