xgormv2

Documentation

Index

• func NewDBClient(configPath string, opts ...gorm.Option) *gorm.DB
• func ToGormScopes(scopes []Scope) []func(db *gorm.DB) *gorm.DB
• func ToMap(maps []Map) map[string]interface{}
• type BaseRepo
  • func NewBaseRepo[T schema.Tabler](rwDB *gorm.DB, rDBs []*gorm.DB) *BaseRepo[T]
  • func (b *BaseRepo[T]) Create(ctx context.Context, t *T, tx ...*gorm.DB) error
  • func (b *BaseRepo[T]) CreateInBatches(ctx context.Context, ts []*T, batchSize int, tx ...*gorm.DB) error
  • func (b *BaseRepo[T]) GetByScopes(ctx context.Context, scopes []Scope, tx ...*gorm.DB) (*T, error)
  • func (b *BaseRepo[T]) GetCountByScopes(ctx context.Context, scopes []Scope, tx ...*gorm.DB) (int64, error)
  • func (b *BaseRepo[T]) GetListByScopes(ctx context.Context, scopes []Scope, tx ...*gorm.DB) ([]*T, error)
  • func (b *BaseRepo[T]) GetRDB(tx ...*gorm.DB) *gorm.DB
  • func (b *BaseRepo[T]) GetRwDB(tx ...*gorm.DB) *gorm.DB
  • func (b *BaseRepo[T]) MapExprAdd(k string, v interface{}) Map
  • func (b *BaseRepo[T]) MapExprSub(k string, v interface{}) Map
  • func (b *BaseRepo[T]) MapKV(k string, v interface{}) Map
  • func (b *BaseRepo[T]) SaveByScopes(ctx context.Context, t *T, scopes []Scope, tx ...*gorm.DB) error
  • func (b *BaseRepo[T]) ScopeBetween(k string, v1, v2 interface{}) Scope
  • func (b *BaseRepo[T]) ScopeEqual(k string, v interface{}) Scope
  • func (b *BaseRepo[T]) ScopeGT(k string, v interface{}) Scope
  • func (b *BaseRepo[T]) ScopeGTE(k string, v interface{}) Scope
  • func (b *BaseRepo[T]) ScopeIN(k string, v interface{}) Scope
  • func (b *BaseRepo[T]) ScopeInnerJoin(joinTable string, onTableFiled, onJoinTableField string) Scope
  • func (b *BaseRepo[T]) ScopeLT(k string, v interface{}) Scope
  • func (b *BaseRepo[T]) ScopeLTE(k string, v interface{}) Scope
  • func (b *BaseRepo[T]) ScopeLeftJoin(joinTable string, onTableFiled, onJoinTableField string) Scope
  • func (b *BaseRepo[T]) ScopeLike(k string, v interface{}) Scope
  • func (b *BaseRepo[T]) ScopeLimit(v int) Scope
  • func (b *BaseRepo[T]) ScopeNotEqual(k string, v interface{}) Scope
  • func (b *BaseRepo[T]) ScopeNotIN(k string, v interface{}) Scope
  • func (b *BaseRepo[T]) ScopeOffset(v int) Scope
  • func (b *BaseRepo[T]) ScopeOrderBy(k, expr string) Scope
  • func (b *BaseRepo[T]) Transaction(f func(tx *gorm.DB) error) error
  • func (b *BaseRepo[T]) UpdateByScopesAndMaps(ctx context.Context, scopes []Scope, maps []Map, tx ...*gorm.DB) (int64, error)
• type ICreator
• type IGetter
• type ITx
• type IUpdater
• type Map
• type Scope

Functions

func NewDBClient

func NewDBClient(configPath string, opts ...gorm.Option) *gorm.DB

NewDBClient ...

func ToGormScopes

func ToGormScopes(scopes []Scope) []func(db *gorm.DB) *gorm.DB

ToGormScopes ...

func ToMap

func ToMap(maps []Map) map[string]interface{}

ToMap ...

Types

type BaseRepo

type BaseRepo[T schema.Tabler] struct {
	// contains filtered or unexported fields
}

func NewBaseRepo

func NewBaseRepo[T schema.Tabler](rwDB *gorm.DB, rDBs []*gorm.DB) *BaseRepo[T]

NewBaseRepo ...

func (*BaseRepo[T]) Create

func (b *BaseRepo[T]) Create(ctx context.Context, t *T, tx ...*gorm.DB) error

Create ...

func (*BaseRepo[T]) CreateInBatches

func (b *BaseRepo[T]) CreateInBatches(ctx context.Context, ts []*T, batchSize int, tx ...*gorm.DB) error

CreateInBatches ...

func (*BaseRepo[T]) GetByScopes

func (b *BaseRepo[T]) GetByScopes(ctx context.Context, scopes []Scope, tx ...*gorm.DB) (*T, error)

GetByScopes ...

func (*BaseRepo[T]) GetCountByScopes

func (b *BaseRepo[T]) GetCountByScopes(ctx context.Context, scopes []Scope, tx ...*gorm.DB) (int64, error)

GetCountByScopes ...

func (*BaseRepo[T]) GetListByScopes

func (b *BaseRepo[T]) GetListByScopes(ctx context.Context, scopes []Scope, tx ...*gorm.DB) ([]*T, error)

GetListByScopes ...

func (*BaseRepo[T]) GetRDB

func (b *BaseRepo[T]) GetRDB(tx ...*gorm.DB) *gorm.DB

GetRDB 默认采用轮询负载

func (*BaseRepo[T]) GetRwDB

func (b *BaseRepo[T]) GetRwDB(tx ...*gorm.DB) *gorm.DB

func (*BaseRepo[T]) MapExprAdd

func (b *BaseRepo[T]) MapExprAdd(k string, v interface{}) Map

MapExprAdd ...

func (*BaseRepo[T]) MapExprSub

func (b *BaseRepo[T]) MapExprSub(k string, v interface{}) Map

MapExprSub ...

func (*BaseRepo[T]) MapKV

func (b *BaseRepo[T]) MapKV(k string, v interface{}) Map

func (*BaseRepo[T]) SaveByScopes

func (b *BaseRepo[T]) SaveByScopes(ctx context.Context, t *T, scopes []Scope, tx ...*gorm.DB) error

SaveByScopes ...

func (*BaseRepo[T]) ScopeBetween

func (b *BaseRepo[T]) ScopeBetween(k string, v1, v2 interface{}) Scope

ScopeBetween ...

func (*BaseRepo[T]) ScopeEqual

func (b *BaseRepo[T]) ScopeEqual(k string, v interface{}) Scope

ScopeEqual ...

func (*BaseRepo[T]) ScopeGT

func (b *BaseRepo[T]) ScopeGT(k string, v interface{}) Scope

ScopeGT ...

func (*BaseRepo[T]) ScopeGTE

func (b *BaseRepo[T]) ScopeGTE(k string, v interface{}) Scope

ScopeGTE ...

func (*BaseRepo[T]) ScopeIN

func (b *BaseRepo[T]) ScopeIN(k string, v interface{}) Scope

ScopeIN ...

func (*BaseRepo[T]) ScopeInnerJoin

func (b *BaseRepo[T]) ScopeInnerJoin(joinTable string, onTableFiled, onJoinTableField string) Scope

ScopeInnerJoin ...

func (*BaseRepo[T]) ScopeLT

func (b *BaseRepo[T]) ScopeLT(k string, v interface{}) Scope

ScopeLT ...

func (*BaseRepo[T]) ScopeLTE

func (b *BaseRepo[T]) ScopeLTE(k string, v interface{}) Scope

ScopeLTE ...

func (*BaseRepo[T]) ScopeLeftJoin

func (b *BaseRepo[T]) ScopeLeftJoin(joinTable string, onTableFiled, onJoinTableField string) Scope

ScopeLeftJoin ...

func (*BaseRepo[T]) ScopeLike

func (b *BaseRepo[T]) ScopeLike(k string, v interface{}) Scope

ScopeLike ...

func (*BaseRepo[T]) ScopeLimit

func (b *BaseRepo[T]) ScopeLimit(v int) Scope

ScopeLimit ...

func (*BaseRepo[T]) ScopeNotEqual

func (b *BaseRepo[T]) ScopeNotEqual(k string, v interface{}) Scope

ScopeNotEqual ...

func (*BaseRepo[T]) ScopeNotIN

func (b *BaseRepo[T]) ScopeNotIN(k string, v interface{}) Scope

ScopeNotIN ...

func (*BaseRepo[T]) ScopeOffset

func (b *BaseRepo[T]) ScopeOffset(v int) Scope

ScopeOffset ...

func (*BaseRepo[T]) ScopeOrderBy

func (b *BaseRepo[T]) ScopeOrderBy(k, expr string) Scope

ScopeOrderBy expr: ASC、DESC、>=0、<= 0 ...

func (*BaseRepo[T]) Transaction

func (b *BaseRepo[T]) Transaction(f func(tx *gorm.DB) error) error

Transaction ...

func (*BaseRepo[T]) UpdateByScopesAndMaps

func (b *BaseRepo[T]) UpdateByScopesAndMaps(ctx context.Context, scopes []Scope, maps []Map, tx ...*gorm.DB) (int64, error)

UpdateByScopesAndMaps ...

type ICreator

type ICreator[T any] interface {
	Create(ctx context.Context, t *T, tx ...*gorm.DB) error
	CreateInBatches(ctx context.Context, ts []*T, batchSize int, tx ...*gorm.DB) error
}

type IGetter

type IGetter[T any] interface {
	GetByScopes(ctx context.Context, scopes []Scope, tx ...*gorm.DB) (*T, error)
	GetListByScopes(ctx context.Context, scopes []Scope, tx ...*gorm.DB) ([]*T, error)
	GetCountByScopes(ctx context.Context, scopes []Scope, tx ...*gorm.DB) (int64, error)
}

type ITx

type ITx interface {
	Transaction(fc func(tx *gorm.DB) error) error
}

type IUpdater

type IUpdater[T any] interface {
	SaveByScopes(ctx context.Context, t *T, scopes []Scope, tx ...*gorm.DB) error
	UpdateByScopesAndMaps(ctx context.Context, scopes []Scope, maps []Map, tx ...*gorm.DB) (int64, error)
}

type Map

type Map map[string]interface{}

type Scope

type Scope func(db *gorm.DB) *gorm.DB