db

package
v1.2.82 Latest Latest
Warning

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

Go to latest
Published: Apr 6, 2023 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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 added in v1.2.80

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

Count 计数

func (*HoTimeDB) Table added in v1.2.0

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

func (*HoTimeDB) Update

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

Update 更新数据

type HotimeDBBuilder added in v1.2.0

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

func (*HotimeDBBuilder) And added in v1.2.0

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

func (*HotimeDBBuilder) Count added in v1.2.0

func (that *HotimeDBBuilder) Count() int

func (*HotimeDBBuilder) Delete added in v1.2.0

func (that *HotimeDBBuilder) Delete() int64

func (*HotimeDBBuilder) From added in v1.2.0

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

func (*HotimeDBBuilder) FullJoin added in v1.2.0

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

func (*HotimeDBBuilder) Get added in v1.2.0

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

func (*HotimeDBBuilder) Group added in v1.2.0

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

func (*HotimeDBBuilder) InnerJoin added in v1.2.0

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

func (*HotimeDBBuilder) Join added in v1.2.0

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

func (*HotimeDBBuilder) LeftJoin added in v1.2.0

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

func (*HotimeDBBuilder) Limit added in v1.2.0

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

func (*HotimeDBBuilder) Or added in v1.2.0

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

func (*HotimeDBBuilder) Order added in v1.2.0

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

func (*HotimeDBBuilder) Page added in v1.2.0

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

func (*HotimeDBBuilder) RightJoin added in v1.2.0

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

func (*HotimeDBBuilder) Select added in v1.2.0

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

func (*HotimeDBBuilder) Update added in v1.2.0

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

func (*HotimeDBBuilder) Where added in v1.2.0

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

Jump to

Keyboard shortcuts

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