daoctl

Documentation

Index

• Variables
• func Delete(model *gdb.Model) (rowsAffected int64)
• func DeleteWithError(model *gdb.Model) (rowsAffected int64, err error)
• func Find[T any](db *gdb.Model, orderBy []sys_model.OrderBy, ...) (response *sys_model.CollectRes[T], err error)
• func GetAll[T any](db *gdb.Model, info *sys_model.Pagination) (response *sys_model.CollectRes[*T], err error)
• func GetById[T any](model *gdb.Model, id int64) *T
• func GetByIdWithError[T any](model *gdb.Model, id int64) (*T, error)
• func Insert(model *gdb.Model, data ...interface{}) (lastInsertId int64, rowsAffected int64)
• func InsertIgnore(model *gdb.Model, data ...interface{}) (lastInsertId int64, rowsAffected int64)
• func InsertIgnoreWithError(model *gdb.Model, data ...interface{}) (lastInsertId int64, rowsAffected int64, err error)
• func InsertWithError(model *gdb.Model, data ...interface{}) (lastInsertId int64, rowsAffected int64, err error)
• func Query[T any](db *gdb.Model, searchFields *sys_model.SearchParams, IsExport bool) (response *sys_model.CollectRes[T], err error)
• func RemoveQueryCache(db gdb.DB, prefix string)
• func Save(model *gdb.Model, data ...interface{}) (lastInsertId int64, rowsAffected int64)
• func SaveWithError(model *gdb.Model, data ...interface{}) (lastInsertId int64, rowsAffected int64, err error)
• func Scan[T any](model *gdb.Model) *T
• func ScanList[T any](model *gdb.Model, bindToAttrName string, relationAttrNameAndFields ...string) *T
• func ScanListWithError[T any](model *gdb.Model, bindToAttrName string, relationAttrNameAndFields ...string) (*T, error)
• func ScanWithError[T any](model *gdb.Model) (*T, error)
• func Update(model *gdb.Model, dataAndWhere ...interface{}) (rowsAffected int64)
• func UpdateWithError(model *gdb.Model, dataAndWhere ...interface{}) (rowsAffected int64, err error)

Variables

var CacheHookHandler = gdb.HookHandler{
	Update: cleanCache[gdb.HookUpdateInput],
	Insert: cleanCache[gdb.HookInsertInput],
	Delete: cleanCache[gdb.HookDeleteInput],
	Select: func(ctx context.Context, in *gdb.HookSelectInput) (result gdb.Result, err error) {
		conf := gdb.CacheOption{
			Duration: time.Hour * 24,
			Name:     in.Table,
			Force:    false,
		}
		table := gstr.Replace(in.Table, "\"", "")
		for _, cacheConf := range sys_consts.Global.OrmCacheConf {
			if cacheConf.TableName == table {
				conf.Duration = time.Second * (time.Duration)(cacheConf.ExpireSeconds)
				conf.Force = cacheConf.Force
			}
		}
		in.Model.Cache(conf)
		result, err = in.Next(ctx)
		return
	},
}

Functions

func Delete

func Delete(model *gdb.Model) (rowsAffected int64)

func DeleteWithError

func DeleteWithError(model *gdb.Model) (rowsAffected int64, err error)

func Find

func Find[T any](db *gdb.Model, orderBy []sys_model.OrderBy, searchFields ...sys_model.FilterInfo) (response *sys_model.CollectRes[T], err error)

func GetAll

func GetAll[T any](db *gdb.Model, info *sys_model.Pagination) (response *sys_model.CollectRes[*T], err error)

func GetById

func GetById[T any](model *gdb.Model, id int64) *T

func GetByIdWithError

func GetByIdWithError[T any](model *gdb.Model, id int64) (*T, error)

func Insert

func Insert(model *gdb.Model, data ...interface{}) (lastInsertId int64, rowsAffected int64)

func InsertIgnore

func InsertIgnore(model *gdb.Model, data ...interface{}) (lastInsertId int64, rowsAffected int64)

func InsertIgnoreWithError

func InsertIgnoreWithError(model *gdb.Model, data ...interface{}) (lastInsertId int64, rowsAffected int64, err error)

func InsertWithError

func InsertWithError(model *gdb.Model, data ...interface{}) (lastInsertId int64, rowsAffected int64, err error)

func Query

func Query[T any](db *gdb.Model, searchFields *sys_model.SearchParams, IsExport bool) (response *sys_model.CollectRes[T], err error)

func RemoveQueryCache

func RemoveQueryCache(db gdb.DB, prefix string)

func Save

func Save(model *gdb.Model, data ...interface{}) (lastInsertId int64, rowsAffected int64)

func SaveWithError

func SaveWithError(model *gdb.Model, data ...interface{}) (lastInsertId int64, rowsAffected int64, err error)

func Scan

func Scan[T any](model *gdb.Model) *T

func ScanList

func ScanList[T any](model *gdb.Model, bindToAttrName string, relationAttrNameAndFields ...string) *T

func ScanListWithError

func ScanListWithError[T any](model *gdb.Model, bindToAttrName string, relationAttrNameAndFields ...string) (*T, error)

func ScanWithError

func ScanWithError[T any](model *gdb.Model) (*T, error)

func Update

func Update(model *gdb.Model, dataAndWhere ...interface{}) (rowsAffected int64)

func UpdateWithError

func UpdateWithError(model *gdb.Model, dataAndWhere ...interface{}) (rowsAffected int64, err error)