db

Documentation

Index

• type HoTimeDB
  • func (that *HoTimeDB) Action(action func(db HoTimeDB) (isSuccess bool)) (isSuccess bool)
  • func (that *HoTimeDB) Count(table string, qu ...interface{}) int
  • func (that *HoTimeDB) Delete(table string, data map[string]interface{}) int64
  • func (that *HoTimeDB) Exec(query string, args ...interface{}) (sql.Result, *Error)
  • func (that *HoTimeDB) Get(table string, qu ...interface{}) Map
  • func (that *HoTimeDB) GetPrefix() string
  • func (that *HoTimeDB) GetType() string
  • func (that *HoTimeDB) InitDb(err ...*Error) *Error
  • func (that *HoTimeDB) Insert(table string, data map[string]interface{}) int64
  • func (that *HoTimeDB) Page(page, pageRow int) *HoTimeDB
  • func (that *HoTimeDB) PageSelect(table string, qu ...interface{}) []Map
  • func (that *HoTimeDB) Query(query string, args ...interface{}) []Map
  • func (that *HoTimeDB) Row(resl *sql.Rows) []Map
  • func (that *HoTimeDB) Select(table string, qu ...interface{}) []Map
  • func (that *HoTimeDB) SetConnect(connect func(err ...*Error) (master, slave *sql.DB), err ...*Error)
  • func (that *HoTimeDB) Sum(table string, column string, qu ...interface{}) float64
  • func (that *HoTimeDB) Table(table string) *HotimeDBBuilder
  • func (that *HoTimeDB) Update(table string, data Map, where Map) int64
• type HotimeDBBuilder
  • func (that *HotimeDBBuilder) And(qu ...interface{}) *HotimeDBBuilder
  • func (that *HotimeDBBuilder) Count() int
  • func (that *HotimeDBBuilder) Delete() int64
  • func (that *HotimeDBBuilder) From(table string) *HotimeDBBuilder
  • func (that *HotimeDBBuilder) FullJoin(table, joinStr string) *HotimeDBBuilder
  • func (that *HotimeDBBuilder) Get(qu ...interface{}) Map
  • func (that *HotimeDBBuilder) Group(qu ...interface{}) *HotimeDBBuilder
  • func (that *HotimeDBBuilder) InnerJoin(table, joinStr string) *HotimeDBBuilder
  • func (that *HotimeDBBuilder) Join(qu ...interface{}) *HotimeDBBuilder
  • func (that *HotimeDBBuilder) LeftJoin(table, joinStr string) *HotimeDBBuilder
  • func (that *HotimeDBBuilder) Limit(qu ...interface{}) *HotimeDBBuilder
  • func (that *HotimeDBBuilder) Or(qu ...interface{}) *HotimeDBBuilder
  • func (that *HotimeDBBuilder) Order(qu ...interface{}) *HotimeDBBuilder
  • func (that *HotimeDBBuilder) Page(page, pageRow int) *HotimeDBBuilder
  • func (that *HotimeDBBuilder) RightJoin(table, joinStr string) *HotimeDBBuilder
  • func (that *HotimeDBBuilder) Select(qu ...interface{}) []Map
  • func (that *HotimeDBBuilder) Update(qu ...interface{}) int64
  • func (that *HotimeDBBuilder) Where(qu ...interface{}) *HotimeDBBuilder

Types

type HoTimeDB

type HoTimeDB struct {
	*sql.DB
	ContextBase
	DBName string
	*cache.HoTimeCache
	Log         *logrus.Logger
	Type        string
	Prefix      string
	LastQuery   string
	LastData    []interface{}
	ConnectFunc func(err ...*Error) (*sql.DB, *sql.DB)
	LastErr     *Error

	*sql.Tx //事务对象
	SlaveDB *sql.DB
	Mode    int //mode为0生产模式,1、为测试模式、2为开发模式
	// contains filtered or unexported fields
}

func (*HoTimeDB) Action

func (that *HoTimeDB) Action(action func(db HoTimeDB) (isSuccess bool)) (isSuccess bool)

Action 事务，如果action返回true则执行成功；false则回滚

func (*HoTimeDB) Count

func (that *HoTimeDB) Count(table string, qu ...interface{}) int

Count 计数

func (*HoTimeDB) Delete

func (that *HoTimeDB) Delete(table string, data map[string]interface{}) int64

func (*HoTimeDB) Exec

func (that *HoTimeDB) Exec(query string, args ...interface{}) (sql.Result, *Error)

func (*HoTimeDB) Get

func (that *HoTimeDB) Get(table string, qu ...interface{}) Map

func (*HoTimeDB) GetPrefix

func (that *HoTimeDB) GetPrefix() string

func (*HoTimeDB) GetType

func (that *HoTimeDB) GetType() string

GetType 设置数据库配置连接

func (*HoTimeDB) InitDb

func (that *HoTimeDB) InitDb(err ...*Error) *Error

func (*HoTimeDB) Insert

func (that *HoTimeDB) Insert(table string, data map[string]interface{}) int64

Insert 插入新数据

func (*HoTimeDB) Page

func (that *HoTimeDB) Page(page, pageRow int) *HoTimeDB

func (*HoTimeDB) PageSelect

func (that *HoTimeDB) PageSelect(table string, qu ...interface{}) []Map

func (*HoTimeDB) Query

func (that *HoTimeDB) Query(query string, args ...interface{}) []Map

func (*HoTimeDB) Row

func (that *HoTimeDB) Row(resl *sql.Rows) []Map

Row 数据库数据解析

func (*HoTimeDB) Select

func (that *HoTimeDB) Select(table string, qu ...interface{}) []Map

func (*HoTimeDB) SetConnect

func (that *HoTimeDB) SetConnect(connect func(err ...*Error) (master, slave *sql.DB), err ...*Error)

SetConnect 设置数据库配置连接

func (*HoTimeDB) Sum

func (that *HoTimeDB) Sum(table string, column string, qu ...interface{}) float64

Count 计数

func (*HoTimeDB) Table

func (that *HoTimeDB) Table(table string) *HotimeDBBuilder

func (*HoTimeDB) Update

func (that *HoTimeDB) Update(table string, data Map, where Map) int64

Update 更新数据

type HotimeDBBuilder

type HotimeDBBuilder struct {
	HoTimeDB *HoTimeDB
	// contains filtered or unexported fields
}

func (*HotimeDBBuilder) And

func (that *HotimeDBBuilder) And(qu ...interface{}) *HotimeDBBuilder

func (*HotimeDBBuilder) Count

func (that *HotimeDBBuilder) Count() int

func (*HotimeDBBuilder) Delete

func (that *HotimeDBBuilder) Delete() int64

func (*HotimeDBBuilder) From

func (that *HotimeDBBuilder) From(table string) *HotimeDBBuilder

func (*HotimeDBBuilder) FullJoin

func (that *HotimeDBBuilder) FullJoin(table, joinStr string) *HotimeDBBuilder

func (*HotimeDBBuilder) Get

func (that *HotimeDBBuilder) Get(qu ...interface{}) Map

func (*HotimeDBBuilder) Group

func (that *HotimeDBBuilder) Group(qu ...interface{}) *HotimeDBBuilder

func (*HotimeDBBuilder) InnerJoin

func (that *HotimeDBBuilder) InnerJoin(table, joinStr string) *HotimeDBBuilder

func (*HotimeDBBuilder) Join

func (that *HotimeDBBuilder) Join(qu ...interface{}) *HotimeDBBuilder

func (*HotimeDBBuilder) LeftJoin

func (that *HotimeDBBuilder) LeftJoin(table, joinStr string) *HotimeDBBuilder

func (*HotimeDBBuilder) Limit

func (that *HotimeDBBuilder) Limit(qu ...interface{}) *HotimeDBBuilder

func (*HotimeDBBuilder) Or

func (that *HotimeDBBuilder) Or(qu ...interface{}) *HotimeDBBuilder

func (*HotimeDBBuilder) Order

func (that *HotimeDBBuilder) Order(qu ...interface{}) *HotimeDBBuilder

func (*HotimeDBBuilder) Page

func (that *HotimeDBBuilder) Page(page, pageRow int) *HotimeDBBuilder

func (*HotimeDBBuilder) RightJoin

func (that *HotimeDBBuilder) RightJoin(table, joinStr string) *HotimeDBBuilder

func (*HotimeDBBuilder) Select

func (that *HotimeDBBuilder) Select(qu ...interface{}) []Map

func (*HotimeDBBuilder) Update

func (that *HotimeDBBuilder) Update(qu ...interface{}) int64

func (*HotimeDBBuilder) Where

func (that *HotimeDBBuilder) Where(qu ...interface{}) *HotimeDBBuilder