db

Documentation

Index

• type FetchOptBuilder
  • func FetchOpt() FetchOptBuilder
• type Repo
  • func NewRepo[T any](db ice.DbInstance, tableName string, opt ...RepoOptBuilder) Repo[T]
• type RepoOptBuilder
  • func RepoOpt() RepoOptBuilder
• type UpdateBuilder
  • func Update() UpdateBuilder
• type VDB
  • func NewVDB[T any](db ice.DbInstance, dvalSql map[string]string) VDB[T]

Types

type FetchOptBuilder

type FetchOptBuilder interface {
	WithDeletedAtIsNull(val ...bool) FetchOptBuilder
	EndQuery(query string) FetchOptBuilder
	FullQuery(query string) FetchOptBuilder
	FullQueryFormatter(formatter func(query string) string) FetchOptBuilder
	UsingRW(val ...bool) FetchOptBuilder
}

func FetchOpt

func FetchOpt() FetchOptBuilder

type Repo

type Repo[T any] interface {
	SetInsert(columns string, fn func(e *T) []any)

	Fetch(clog clog.Instance, condition string, args ...any) (*T, error)
	Fetches(clog clog.Instance, condition string, args ...any) ([]*T, error)
	Insert(clog clog.Instance, e *T) error
	InsertRID(clog clog.Instance, e *T) (*int64, error)
	Update(clog clog.Instance, builder UpdateBuilder) error
	Delete(clog clog.Instance, condition string, args ...any) error

	TxFetch(clog clog.Instance, tx ice.DbTx, condition string, args ...any) (*T, error)
	TxFetches(clog clog.Instance, tx ice.DbTx, condition string, args ...any) ([]*T, error)
	TxInsert(clog clog.Instance, tx ice.DbTx, e *T) error
	TxInsertRID(clog clog.Instance, tx ice.DbTx, e *T) (*int64, error)
	TxBulkInsert(clog clog.Instance, tx ice.DbTx, entities []*T, chunkSize ...int) error
	TxUpdate(clog clog.Instance, tx ice.DbTx, builder UpdateBuilder) error
	TxDelete(clog clog.Instance, tx ice.DbTx, condition string, args ...any) error
}

func NewRepo

func NewRepo[T any](db ice.DbInstance, tableName string, opt ...RepoOptBuilder) Repo[T]

type RepoOptBuilder

type RepoOptBuilder interface {
	WithDeletedAtIsNull(val ...bool) RepoOptBuilder
	RWFetchWhenNull(val ...bool) RepoOptBuilder
}

func RepoOpt

func RepoOpt() RepoOptBuilder

type UpdateBuilder

type UpdateBuilder interface {
	AutoUpdatedAt(val ...bool) UpdateBuilder
	Set(query string, args ...any) UpdateBuilder
	SetIfNotNil(keyVal map[string]any) UpdateBuilder
	Where(query string, args ...any) UpdateBuilder
}

func Update

func Update() UpdateBuilder

type VDB

type VDB[T any] interface {
	Sql(sqlName string) string

	Fetch(clog clog.Instance, sqlName string, args ...any) (*T, error)
	Fetches(clog clog.Instance, sqlName string, args ...any) ([]*T, error)

	TxFetch(clog clog.Instance, tx ice.DbTx, sqlName string, args ...any) (*T, error)
	TxFetches(clog clog.Instance, tx ice.DbTx, sqlName string, args ...any) ([]*T, error)
}

func NewVDB

func NewVDB[T any](db ice.DbInstance, dvalSql map[string]string) VDB[T]