repo

Documentation

Index

• Constants
• func CountByCondition(db *gorm.DB, tableTypePtr *reflect.Type, ...) (num int64)
• func CreateAll(db *gorm.DB, tableTypePtr *reflect.Type, itemPtr interface{})
• func DeleteByCondition(tx *gorm.DB, tableTypePtr *reflect.Type, ...)
• func ExistsByCondition(db *gorm.DB, tableTypePtr *reflect.Type, ...) (exist bool)
• func GetByCondition(db *gorm.DB, tableTypePtr *reflect.Type, itemPtr interface{}, ...)
• func GetMainAndSubCond(db *gorm.DB, itemPtr interface{}, funcSlice []func(db *gorm.DB) *gorm.DB) (total int64)
• func ObtainClientDb(ctx iris.Context) (db *gorm.DB)
• func ObtainClientDbTx(ctx iris.Context) (db *gorm.DB)
• func ObtainClientId(ctx iris.Context) (clientId int64, err error)
• func ObtainCustomDbByDbName(dbName string) (db *gorm.DB)
• func ObtainCustomTxDbByDbName(ctx iris.Context, dbName string) (tx *gorm.DB)
• func ObtainDb(ctx iris.Context, txFlag bool) *gorm.DB
• func ObtainDbObjByDbName(dbName string) (db *gorm.DB)
• func ObtainDbTxObjByDbName(ctx iris.Context, dbName string) (tx *gorm.DB)
• func ObtainImpossibleScope() (fnSlice []func(db *gorm.DB) *gorm.DB)
• func ObtainInevitableScope() (fnSlice []func(db *gorm.DB) *gorm.DB)
• func ObtainMasterDb() (db *gorm.DB)
• func ObtainMasterDbTx(ctx iris.Context) (tx *gorm.DB)
• func ObtainTableNameByEntityPtr(entityPtr interface{}) (tableName string)
• func ObtainTableNameByType(tPtr *reflect.Type) (tableName string)
• func Paginate(pageNumber int, pageSize int) func(db *gorm.DB) *gorm.DB
• type TableName

Constants

const (
	ErrFoundMessage = "entity found err"
	ErrCountMessage = "entity count err"
)

Functions

func CountByCondition

func CountByCondition(db *gorm.DB, tableTypePtr *reflect.Type, funcSlice []func(db *gorm.DB) *gorm.DB) (num int64)

func CreateAll

func CreateAll(db *gorm.DB, tableTypePtr *reflect.Type, itemPtr interface{})

func DeleteByCondition

func DeleteByCondition(tx *gorm.DB, tableTypePtr *reflect.Type, funcSlice []func(db *gorm.DB) *gorm.DB)

func ExistsByCondition

func ExistsByCondition(db *gorm.DB, tableTypePtr *reflect.Type, funcSlice []func(db *gorm.DB) *gorm.DB) (exist bool)

func GetByCondition

func GetByCondition(db *gorm.DB, tableTypePtr *reflect.Type, itemPtr interface{}, funcSlice []func(db *gorm.DB) *gorm.DB)

func GetMainAndSubCond

func GetMainAndSubCond(db *gorm.DB, itemPtr interface{}, funcSlice []func(db *gorm.DB) *gorm.DB) (total int64)

func ObtainClientDb

func ObtainClientDb(ctx iris.Context) (db *gorm.DB)

ObtainClientDb 获取常规动态租户数据源

func ObtainClientDbTx

func ObtainClientDbTx(ctx iris.Context) (db *gorm.DB)

ObtainClientDbTx 获取带事务的动态租户数据源

func ObtainClientId

func ObtainClientId(ctx iris.Context) (clientId int64, err error)

ObtainClientId 获取当前的租户id

func ObtainCustomDbByDbName

func ObtainCustomDbByDbName(dbName string) (db *gorm.DB)

ObtainCustomDbByDbName 根据自定义的数据源名称获取自定义数据源对象

func ObtainCustomTxDbByDbName

func ObtainCustomTxDbByDbName(ctx iris.Context, dbName string) (tx *gorm.DB)

ObtainCustomTxDbByDbName 根据自定义的数据源名称获取带事务的自定义数据源对象

func ObtainDb

func ObtainDb(ctx iris.Context, txFlag bool) *gorm.DB

ObtainDb 获取数据源

@Param ctx http会话对象

@Param txFlag 是否获取带事务的数据源标识（true 是 false 否）

func ObtainDbObjByDbName

func ObtainDbObjByDbName(dbName string) (db *gorm.DB)

ObtainDbObjByDbName 根据名称获取独立存储空间的db对象

func ObtainDbTxObjByDbName

func ObtainDbTxObjByDbName(ctx iris.Context, dbName string) (tx *gorm.DB)

ObtainDbTxObjByDbName 根据名称获取独立存储空间且带事务的db对象,该方法仅限用于一次请求需要操作多个数据源的场景

func ObtainImpossibleScope

func ObtainImpossibleScope() (fnSlice []func(db *gorm.DB) *gorm.DB)

func ObtainInevitableScope

func ObtainInevitableScope() (fnSlice []func(db *gorm.DB) *gorm.DB)

func ObtainMasterDb

func ObtainMasterDb() (db *gorm.DB)

ObtainMasterDb 获取常规主数据源

func ObtainMasterDbTx

func ObtainMasterDbTx(ctx iris.Context) (tx *gorm.DB)

ObtainMasterDbTx 获取带事务的数据源

func ObtainTableNameByEntityPtr

func ObtainTableNameByEntityPtr(entityPtr interface{}) (tableName string)

func ObtainTableNameByType

func ObtainTableNameByType(tPtr *reflect.Type) (tableName string)

func Paginate

func Paginate(pageNumber int, pageSize int) func(db *gorm.DB) *gorm.DB

Paginate db分页封装

Types

type TableName

type TableName interface {
	TableName() string
}