db

package
v0.0.0-...-78a0d84 Latest Latest
Warning

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

 Go to latest Published: Aug 27, 2021 License: MIT Imports: 17 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	DB_type_mysql    = "mysql"
	DB_type_postgres = "postgres"
)
View Source 
const (
	MEM_STATE_ORI = iota
	MEM_STATE_NEW
	MEM_STATE_UPDATE
	MEM_STATE_DEL
)

Variables

View Source 
var ConvertTypeError = errors.New("convert type error")

Functions

func AddDB 

func AddDB(dbName string, dbMgr *DBMgr)

func Del 

func Del(dbName string)

func FreeMemMode 

func FreeMemMode(v *MemMode)

Types

type DBFactory 

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

func (*DBFactory) Add 

func (db *DBFactory) Add(dbName string, dbMgr *DBMgr)

func (*DBFactory) Clean 

func (db *DBFactory) Clean()

func (*DBFactory) Del 

func (db *DBFactory) Del(dbName string)

func (*DBFactory) Get 

func (db *DBFactory) Get(dbName string) *DBMgr

type DBMgr 

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

func GetDB 

func GetDB(dbName string) *DBMgr

func NewDBMgr 

func NewDBMgr(dbType, dbName, user, pwd, host string, logCfg ...*conf.LogConfig) *DBMgr

func NewDBMgrByCfg 

func NewDBMgrByCfg(dbType string, dbCfg *conf.DBConfig, logCfg ...*conf.LogConfig) *DBMgr

func (*DBMgr) Close 

func (dbMgr *DBMgr) Close()

func (*DBMgr) DBConn 

func (dbMgr *DBMgr) DBConn() *gorm.DB

func (*DBMgr) Delete 

func (dbMgr *DBMgr) Delete(tableName, where string) error

func (*DBMgr) Insert 

func (dbMgr *DBMgr) Insert(tableName, fields, value string) error

func (*DBMgr) NewRecord 

func (dbMgr *DBMgr) NewRecord(dest interface{}) error

func (*DBMgr) Query 

func (dbMgr *DBMgr) Query(tableName string, f func(*sql.Rows))

func (*DBMgr) QueryCond 

func (dbMgr *DBMgr) QueryCond(tableName, where string, f func(*sql.Rows))

func (*DBMgr) QueryCondEx 

func (dbMgr *DBMgr) QueryCondEx(tableName, where string, objCallback func() interface{}, f func(interface{}))

func (*DBMgr) QueryKeyCond 

func (dbMgr *DBMgr) QueryKeyCond(tableName, key, where string, f func(*sql.Rows))

func (*DBMgr) QueryOneCond 

func (dbMgr *DBMgr) QueryOneCond(tableName, where string, f func(*sql.Row))

func (*DBMgr) QueryOneCondEx 

func (dbMgr *DBMgr) QueryOneCondEx(tableName, where string, objCallback func() interface{}, f func(interface{}))

func (*DBMgr) QueryPrimaryKey 

func (dbMgr *DBMgr) QueryPrimaryKey(pk, tableName string) int64

func (*DBMgr) QueryRecord 

func (dbMgr *DBMgr) QueryRecord(tableName, where string, dest interface{}) error

func (*DBMgr) SaveRecord 

func (dbMgr *DBMgr) SaveRecord(dest interface{}) error

func (*DBMgr) SetLogLevel 

func (dbMgr *DBMgr) SetLogLevel(lv int)

func (*DBMgr) SetLogRotation 

func (dbMgr *DBMgr) SetLogRotation(maxAge, rotationTime int, pathFile string)

func (*DBMgr) Update 

func (dbMgr *DBMgr) Update(tableName, fields, value string) error

type IDBMgr 

type IDBMgr interface {
	Close()
}

type IRedisClient 

type IRedisClient interface {
	Get() redis.Conn
	Close() error
}

type IkCallback 

type IkCallback func(obj interface{}) (ikField string, ikVal interface{})

type MemMgr 

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

func NewMemMgr 

func NewMemMgr(rc *RedisClient, dbName, tableName, pk string,
	pkCallback PkCallback, logCfg ...*conf.LogConfig) *MemMgr

func (*MemMgr) AddData 

func (mm *MemMgr) AddData(d interface{}, expire ...int64) bool

func (*MemMgr) AddMem 

func (mm *MemMgr) AddMem(d interface{}, expire ...int64) bool

func (*MemMgr) CleanIkData 

func (mm *MemMgr) CleanIkData(dest interface{})

func (*MemMgr) DelData 

func (mm *MemMgr) DelData(dest interface{}) bool

func (*MemMgr) GetCond 

func (mm *MemMgr) GetCond(key string, val interface{}) string

func (*MemMgr) GetDBMgr 

func (mm *MemMgr) GetDBMgr() *DBMgr

func (*MemMgr) GetData 

func (mm *MemMgr) GetData(key interface{}, dest interface{}, checkDB ...bool) error

func (*MemMgr) GetDataByIK 

func (mm *MemMgr) GetDataByIK(ikName string, ikValue, dest interface{}, queryWhere ...string) error

func (*MemMgr) GetPKIncr 

func (mm *MemMgr) GetPKIncr() int64

func (*MemMgr) GetTableName 

func (mm *MemMgr) GetTableName() string

func (*MemMgr) SetExpire 

func (mm *MemMgr) SetExpire(second int64)

func (*MemMgr) SetIKCallback 

func (mm *MemMgr) SetIKCallback(ikCallbackList []IkCallback)

func (*MemMgr) SetLogConf 

func (mm *MemMgr) SetLogConf(logConf *conf.LogConfig)

func (*MemMgr) SetLogLevel 

func (mm *MemMgr) SetLogLevel(lv int)

func (*MemMgr) SetLogRotation 

func (mm *MemMgr) SetLogRotation(maxAge, rotationTime int, pathFile string)

func (*MemMgr) SetPkCallback 

func (mm *MemMgr) SetPkCallback(pkCallback PkCallback)

func (*MemMgr) UpdateData 

func (mm *MemMgr) UpdateData(d interface{}, expire ...int64) bool

type MemMode 

type MemMode struct {
	State int
	Data  interface{}
}

func NewMemMode 

func NewMemMode() *MemMode

type PkCallback 

type PkCallback func(obj interface{}) (pkVal interface{})

type RedisClient 

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

func NewRedisClient 

func NewRedisClient(host string, maxIdle, maxActive int) *RedisClient

func NewRedisClusterClient 

func NewRedisClusterClient(hostList []string, maxIdle, maxActive int) *RedisClient

func (*RedisClient) Close 

func (rc *RedisClient) Close() error

func (*RedisClient) CloseConn 

func (rc *RedisClient) CloseConn(conn redis.Conn)

func (*RedisClient) Del 

func (rc *RedisClient) Del(keys ...interface{}) (d interface{}, err error)

func (*RedisClient) Expire 

func (rc *RedisClient) Expire(key string, second int64) (d interface{}, err error)

func (*RedisClient) Get 

func (rc *RedisClient) Get(key string) (d interface{}, err error)

func (*RedisClient) GetConn 

func (rc *RedisClient) GetConn() redis.Conn

func (*RedisClient) HDel 

func (rc *RedisClient) HDel(key, field interface{}) (d interface{}, err error)

func (*RedisClient) HGet 

func (rc *RedisClient) HGet(key, field interface{}) (d interface{}, err error)

func (*RedisClient) HGetAll 

func (rc *RedisClient) HGetAll(key string) (d interface{}, err error)

func (*RedisClient) HMGet 

func (rc *RedisClient) HMGet(keys ...interface{}) (d []interface{}, err error)

func (*RedisClient) HSet 

func (rc *RedisClient) HSet(key, field, v interface{}) (d interface{}, err error)

func (*RedisClient) Incr 

func (rc *RedisClient) Incr(key interface{}) (d interface{}, err error)

func (*RedisClient) MGet 

func (rc *RedisClient) MGet(keys ...interface{}) (d []interface{}, err error)

func (*RedisClient) MSet 

func (rc *RedisClient) MSet(kvs ...interface{}) (d interface{}, err error)

func (*RedisClient) PipeDel 

func (rc *RedisClient) PipeDel(conn redis.Conn, keys ...interface{}) error

func (*RedisClient) PipeEnd 

func (rc *RedisClient) PipeEnd(conn redis.Conn) error

func (*RedisClient) PipeHDel 

func (rc *RedisClient) PipeHDel(conn redis.Conn, key, field interface{}) error

func (*RedisClient) PipeHGet 

func (rc *RedisClient) PipeHGet(conn redis.Conn, key, field interface{}) error

func (*RedisClient) PipeHSet 

func (rc *RedisClient) PipeHSet(conn redis.Conn, key, field, value interface{}) error

func (*RedisClient) PipeRecv 

func (rc *RedisClient) PipeRecv(conn redis.Conn) (interface{}, error)

func (*RedisClient) PipeSet 

func (rc *RedisClient) PipeSet(conn redis.Conn, key, value interface{}) error

func (*RedisClient) PipeZAdd 

func (rc *RedisClient) PipeZAdd(conn redis.Conn, key string, kvs map[string]string) error

func (*RedisClient) Set 

func (rc *RedisClient) Set(key string, v interface{}, expire ...int64) (d interface{}, err error)

func (*RedisClient) ZAdd 

func (rc *RedisClient) ZAdd(key string, kvs map[string]string) (d interface{}, err error)

func (*RedisClient) ZRange 

func (rc *RedisClient) ZRange(key string, start, end int) (d [][]interface{}, err error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.