dependency

Documentation

Index

• Constants
• type BaseOption
  • func NewBaseOption(opts ...BaseOptionFunc) *BaseOption
• type BaseOptionFunc
  • func WithBatchSize(v int64) BaseOptionFunc
  • func WithConds(vs ...any) BaseOptionFunc
  • func WithIgnore(v bool) BaseOptionFunc
  • func WithLock(v bool) BaseOptionFunc
  • func WithOmits(vs ...string) BaseOptionFunc
  • func WithPage(v IPage) BaseOptionFunc
  • func WithReadOnly(v bool) BaseOptionFunc
  • func WithSelects(vs ...string) BaseOptionFunc
• type DbAction
• type IBizRequest
• type IEntity
• type IPage
• type IPaginator
• type IPo
• type IRange
• type IRepository
• type ISortField
• type IUnitOfWork

Constants

const (
	BATCH_SIZE = 1000 // default batch size
)

Types

type BaseOption

type BaseOption struct {
	Ignore    bool     `json:"ignore"`    // ignore if exist
	Lock      bool     `json:"lock"`      // lock row
	ReadOnly  bool     `json:"readOnly"`  // read only
	Selects   []string `json:"selects"`   // select fields
	Omits     []string `json:"omits"`     // omit fields select omit
	Conds     []any    `json:"conds"`     // conds where
	Page      IPage    `json:"page"`      // page
	BatchSize int64    `json:"batchSize"` // exec by batch
}

BaseOption base repo exec

func NewBaseOption

func NewBaseOption(opts ...BaseOptionFunc) *BaseOption

NewBaseOption with func

type BaseOptionFunc

type BaseOptionFunc func(o *BaseOption)

BaseOptionFunc base option func

func WithBatchSize

func WithBatchSize(v int64) BaseOptionFunc

WithBatchSize

func WithConds

func WithConds(vs ...any) BaseOptionFunc

WithConds

func WithIgnore

func WithIgnore(v bool) BaseOptionFunc

WithIgnore

func WithLock

func WithLock(v bool) BaseOptionFunc

WithLock

func WithOmits

func WithOmits(vs ...string) BaseOptionFunc

WithOmits

func WithPage

func WithPage(v IPage) BaseOptionFunc

WithPage

func WithReadOnly

func WithReadOnly(v bool) BaseOptionFunc

WithReadOnly

func WithSelects

func WithSelects(vs ...string) BaseOptionFunc

WithSelects

type DbAction

type DbAction func(ctx context.Context) error

action

type IBizRequest

type IBizRequest interface {
	GetBizId() int64
	ToUrlQuery() url.Values
}

IBizRequest business tag reqquest

type IEntity

type IEntity interface {
	IPo
}

type IPage

type IPage interface {
	GetPageIndex() int64
	GetPageSize() int64
	GetBegin() int64
	GetSize() int64
	GetSorts() []ISortField
}

IPage page request

type IPaginator

type IPaginator interface {
	IPage
	GetTotalRecord() int64
	GetTotalPage() int64
}

type IPo

type IPo interface {
	ID() any
	TableName() string
	Database() string
}

IPo for db po struct

type IRange

type IRange interface {
	GetBeg() int64
	GetEnd() int64
}

IRange range

type IRepository

type IRepository[T IEntity] interface {
	BaseCreate(ctx context.Context, ps []*T, opts ...BaseOptionFunc) (int64, error)
	BaseSave(ctx context.Context, ps []*T, opts ...BaseOptionFunc) (int64, error)
	BaseUpdate(ctx context.Context, p *T, opts ...BaseOptionFunc) (int64, error)
	BaseGet(ctx context.Context, opts ...BaseOptionFunc) (*T, error)
	BaseDelete(ctx context.Context, p *T, opts ...BaseOptionFunc) (int64, error)
	BaseCount(ctx context.Context, opts ...BaseOptionFunc) (int64, error)
	BaseQuery(ctx context.Context, opts ...BaseOptionFunc) ([]T, error)
}

IRepository repo

type ISortField

type ISortField interface {
	GetField() string
	GetIsDesc() bool
}

ISortField sort field

type IUnitOfWork

type IUnitOfWork interface {
	Execute(ctx context.Context, fs ...DbAction) (e error)
}

IUnitOfWork trans