repo

Documentation

Index

• type BaseRepo
  • func NewBaseRepo[T any]() *BaseRepo[T]
  • func (r *BaseRepo[T]) CountAll() (int64, error)
  • func (r *BaseRepo[T]) DeleteBy(condition map[string]interface{}, hardDelete bool) error
  • func (r *BaseRepo[T]) DeleteById(id uint64) error
  • func (r *BaseRepo[T]) Exec(sql string, values ...interface{}) (*gorm.DB, error)
  • func (r *BaseRepo[T]) FindBy(condition map[string]interface{}) (*T, error)
  • func (r *BaseRepo[T]) FindByID(id uint64) (*T, error)
  • func (r *BaseRepo[T]) GetByPage(page int, pageSize int) ([]*T, error)
  • func (r *BaseRepo[T]) Insert(model *T) error
  • func (r *BaseRepo[T]) InsertOrIgnore(model *T, condition map[string]interface{}) (int64, error)
  • func (r *BaseRepo[T]) InsertOrUpdate(insertItem *T, condition map[string]interface{}, updateValues *T) error
  • func (r *BaseRepo[T]) SelectBy(condition map[string]interface{}, results *[]*T, opts ...SelOpt) error
  • func (r *BaseRepo[T]) UpdateBy(condition map[string]interface{}, updateValues *T) (int64, error)
  • func (r *BaseRepo[T]) UpdateById(id uint64, updateValues *T) error
  • func (r *BaseRepo[T]) Upsert(model *T, condition map[string]interface{}) error
  • func (r *BaseRepo[T]) UpsertByID(model *T, updateFields []string) error
• type IBaseRepo
• type SelOpt
  • func WithLimit(limit int) SelOpt
  • func WithOrderBy(orderBy string) SelOpt

Types

type BaseRepo

type BaseRepo[T any] struct{ Orm *gorm.DB }

func NewBaseRepo

func NewBaseRepo[T any]() *BaseRepo[T]

NewBaseRepo 暂未使用接口返回

func (*BaseRepo[T]) CountAll

func (r *BaseRepo[T]) CountAll() (int64, error)

CountAll 指定表无条件统计全部数量

func (*BaseRepo[T]) DeleteBy

func (r *BaseRepo[T]) DeleteBy(condition map[string]interface{}, hardDelete bool) error

DeleteBy 根据给定条件删除记录，可选是否硬删除（仅对于有软删除的表）

func (*BaseRepo[T]) DeleteById

func (r *BaseRepo[T]) DeleteById(id uint64) error

DeleteById 按照ID删除一条

func (*BaseRepo[T]) Exec

func (r *BaseRepo[T]) Exec(sql string, values ...interface{}) (*gorm.DB, error)

Exec 执行原生sql语句

func (*BaseRepo[T]) FindBy

func (r *BaseRepo[T]) FindBy(condition map[string]interface{}) (*T, error)

FindBy 根据条件查找一条记录

func (*BaseRepo[T]) FindByID

func (r *BaseRepo[T]) FindByID(id uint64) (*T, error)

FindByID 按照ID读取一条记录

func (*BaseRepo[T]) GetByPage

func (r *BaseRepo[T]) GetByPage(page int, pageSize int) ([]*T, error)

GetByPage 根据分页获取记录

func (*BaseRepo[T]) Insert

func (r *BaseRepo[T]) Insert(model *T) error

Insert 插入一条记录

func (*BaseRepo[T]) InsertOrIgnore

func (r *BaseRepo[T]) InsertOrIgnore(model *T, condition map[string]interface{}) (int64, error)

InsertOrIgnore 无显式事务 先查找，存在则忽略，否则插入 (并发性也可以由数据库相同的unique key来保证)

func (*BaseRepo[T]) InsertOrUpdate

func (r *BaseRepo[T]) InsertOrUpdate(insertItem *T, condition map[string]interface{}, updateValues *T) error

InsertOrUpdate 事务版本 先查找，不存在则插入，存在则更新

func (*BaseRepo[T]) SelectBy

func (r *BaseRepo[T]) SelectBy(condition map[string]interface{}, results *[]*T, opts ...SelOpt) error

SelectBy 按照条件查找多条 可使用链式方法添加order和limit等参数

func (*BaseRepo[T]) UpdateBy

func (r *BaseRepo[T]) UpdateBy(condition map[string]interface{}, updateValues *T) (int64, error)

UpdateBy 根据条件更新记录

func (*BaseRepo[T]) UpdateById

func (r *BaseRepo[T]) UpdateById(id uint64, updateValues *T) error

UpdateById 按照ID更新一条

func (*BaseRepo[T]) Upsert

func (r *BaseRepo[T]) Upsert(model *T, condition map[string]interface{}) error

Upsert 非显式事务(onConflict和clauses)，根据condition查找记录，如果存在则更新，如果不存在则创建

func (*BaseRepo[T]) UpsertByID

func (r *BaseRepo[T]) UpsertByID(model *T, updateFields []string) error

UpsertByID 非显式事务(onConflict和clauses)，固定根据id查找记录，如果存在则更新，如果不存在则创建

type IBaseRepo

type IBaseRepo[T any] interface {
	Exec(sql string, values ...interface{}) (*gorm.DB, error)
	CountAll() (int64, error)
	Insert(model *T) error
	UpdateById(id uint64, updateValues *T) error
	DeleteById(id uint64) error
	DeleteBy(condition map[string]interface{}, hardDelete bool) error
	FindByID(id uint64) (*T, error)
	FindBy(condition map[string]interface{}) (*T, error)
	SelectBy(condition map[string]interface{}, results *[]*T, opts ...SelOpt) error
	InsertOrIgnore(model *T, condition map[string]interface{}) (int64, error)
	InsertOrUpdate(insertItem *T, condition map[string]interface{}, updateValues *T) error
	UpsertByID(model *T, updateFields []string) error
	Upsert(model *T, condition map[string]interface{}) error
	GetByPage(page int, pageSize int) ([]*T, error)
	UpdateBy(condition map[string]interface{}, updateValues *T) (int64, error)
}

type SelOpt

type SelOpt func(*gorm.DB) *gorm.DB

SelOpt SelectBy 条件配置

func WithLimit

func WithLimit(limit int) SelOpt

func WithOrderBy

func WithOrderBy(orderBy string) SelOpt