dependency

Documentation

Index

• Constants
• type BaseOption
  • func NewBaseOption(opts ...BaseOptionFunc) *BaseOption
• type BaseOptionFunc
  • func WithBatchSize(v int64) BaseOptionFunc
  • func WithConds(vs ...any) BaseOptionFunc
  • func WithDataBase(v string) BaseOptionFunc
  • func WithDbShardingKey(v ...any) BaseOptionFunc
  • func WithIDGenerate(v func(context.Context) 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
  • func WithTableName(v string) BaseOptionFunc
  • func WithTbShardingKey(v ...any) BaseOptionFunc
• type DbAction
• type EmptyPo
  • func (p EmptyPo) Database() string
  • func (p EmptyPo) ID() any
  • func (p EmptyPo) TableName() string
  • func (p EmptyPo) ToJson() string
  • func (p EmptyPo) ToRow() []string
• type IBizRequest
• type IDbSharding
• type IEntity
• type IGenerateID
• type IPage
• type IPaginator
• type IPo
• type IRange
• type IRepository
• type ISortField
• type ITableSharding
• 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
	TableName     string                        `json:"tableName"`     // table name
	DataBase      string                        `json:"dataBase"`      // db name
	DbShardingKey []any                         `json:"dbShardingKey"` // db sharding key
	TbShardingKey []any                         `json:"tbShardingKey"` // table sharding key
	IDGenerate    func(ctx context.Context) any `json:"-"`             // id generate func
}

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 WithDataBase

func WithDataBase(v string) BaseOptionFunc

WithDataBase

func WithDbShardingKey

func WithDbShardingKey(v ...any) BaseOptionFunc

WithDbShardingKey

func WithIDGenerate

func WithIDGenerate(v func(context.Context) any) BaseOptionFunc

WithIDGenerate

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

func WithTableName

func WithTableName(v string) BaseOptionFunc

WithTableName

func WithTbShardingKey

func WithTbShardingKey(v ...any) BaseOptionFunc

WithTbShardingKey

type DbAction

type DbAction func(ctx context.Context) error

action

type EmptyPo

type EmptyPo struct{}

EmptyPo empty impl

func (EmptyPo) Database

func (p EmptyPo) Database() string

func (EmptyPo) ID

func (p EmptyPo) ID() any

func (EmptyPo) TableName

func (p EmptyPo) TableName() string

func (EmptyPo) ToJson

func (p EmptyPo) ToJson() string

func (EmptyPo) ToRow

func (p EmptyPo) ToRow() []string

type IBizRequest

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

IBizRequest business tag reqquest

type IDbSharding

type IDbSharding interface {
	DbSharding(keys ...any) string
}

IDbSharding split database by keys

type IEntity

type IEntity interface {
	IPo
}

type IGenerateID

type IGenerateID interface {
	SetID(id any)
}

IGenerateID customer id generate

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
	ToRow() []string
	ToJson() 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 ITableSharding

type ITableSharding interface {
	TableSharding(keys ...any) string
	TableTotal() uint32
}

ITableSharding split table by keys

type IUnitOfWork

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

IUnitOfWork trans