entity

Nov 11, 2025

Changes in this version

+ func NewUpsertTarget(ent Entity) string

Sep 20, 2025

Changes in this version

+ func SavePoint(ctx context.Context, tx Tx, name string, fn func() error) (err error)

+ func TrySavePoint(ctx context.Context, db DB, name string, fn func() error) error

Sep 18, 2025

Changes in this version

+ func TransactionWithOptionsX[T Tx, U TxInitiator[T]](ctx context.Context, db U, opt *sql.TxOptions, fn func(db DB) error) (err error)

+ func TransactionX[T Tx, U TxInitiator[T]](ctx context.Context, db U, fn func(db DB) error) (err error)

+ func TryTransactionWithOptionsX[T Tx](ctx context.Context, db DB, opt *sql.TxOptions, fn func(db DB) error) error

+ func TryTransactionX[T Tx](ctx context.Context, db DB, fn func(db DB) error) error

Sep 18, 2025

Changes in this version

+ func NewUpsertRecord(ent Entity, otherColumns ...string) goqu.Record

+ type Tx interface

+ Commit func() error

+ Rollback func() error

+ type TxInitiator interface

+ BeginTxx func(ctx context.Context, opts *sql.TxOptions) (T, error)

Aug 12, 2025

Changes in this version

type DomainObjectRepository

+ func (r *DomainObjectRepository[ID, DO, PO]) Get(ctx context.Context, stmt *goqu.SelectDataset) (DO, error)

type Repository

+ func (r *Repository[ID, R]) Get(ctx context.Context, stmt *goqu.SelectDataset) (R, error)

Aug 3, 2025

Changes in this version

+ func Upsert(ctx context.Context, ent Entity, db DB) error

type DomainObjectRepository

+ func (r *DomainObjectRepository[ID, DO, PO]) Upsert(ctx context.Context, do DO) error

type Repository

+ func (r *Repository[ID, R]) Upsert(ctx context.Context, row R) error

Aug 3, 2025

Changes in this version

+ type DomainObjectRepository struct

+ func NewDomainObjectRepository[ID comparable, DO any, PO PersistentObject[ID, DO]](persistentRepository *Repository[ID, PO]) *DomainObjectRepository[ID, DO, PO]

+ func (r *DomainObjectRepository[ID, DO, PO]) Create(ctx context.Context, do DO) error

+ func (r *DomainObjectRepository[ID, DO, PO]) Delete(ctx context.Context, do DO) error

+ func (r *DomainObjectRepository[ID, DO, PO]) Find(ctx context.Context, id ID) (DO, error)

+ func (r *DomainObjectRepository[ID, DO, PO]) ForEach(ctx context.Context, stmt *goqu.SelectDataset, ...) error

+ func (r *DomainObjectRepository[ID, DO, PO]) NewPersistentObject(ctx context.Context, do DO) (PO, error)

+ func (r *DomainObjectRepository[ID, DO, PO]) PageQuery(ctx context.Context, stmt *goqu.SelectDataset, currentPage, pageSize int) ([]DO, Pagination, error)

+ func (r *DomainObjectRepository[ID, DO, PO]) Query(ctx context.Context, stmt *goqu.SelectDataset) ([]DO, error)

+ func (r *DomainObjectRepository[ID, DO, PO]) ToDomainObjects(src []PO) ([]DO, error)

+ func (r *DomainObjectRepository[ID, DO, PO]) Update(ctx context.Context, do DO) error

+ func (r *DomainObjectRepository[ID, DO, PO]) UpdateBy(ctx context.Context, id ID, apply func(do DO) (bool, error)) error

+ func (r *DomainObjectRepository[ID, DO, PO]) UpdateByQuery(ctx context.Context, stmt *goqu.SelectDataset, apply func(do DO) (bool, error)) error

+ type PersistentObject interface

+ GetID func() ID

+ Set func(context.Context, DO) error

+ ToDomainObject func() (DO, error)

type Repository

+ func (r *Repository[ID, R]) UpdateBy(ctx context.Context, id ID, apply func(row R) (bool, error)) error

May 30, 2025

Changes in this version

+ type Row interface

+ SetID func(ID) error

May 30, 2025

Changes in this version

+ func TransactionWithOptions(db *sqlx.DB, opt *sql.TxOptions, fn func(tx *sqlx.Tx) error) (err error)

+ func TryTransactionWithOptions(db DB, opt *sql.TxOptions, fn func(DB) error) error

Apr 20, 2025

Changes in this version

type Repository

+ func (repo *Repository[ID, E]) GetDB() DB

+ func (repo *Repository[ID, E]) Query(ctx context.Context, stmt *goqu.SelectDataset) ([]E, error)

Nov 22, 2024

Changes in this version

+ func IsNotFound(err error) bool

type Pagination

+ func (p Pagination) ULimit() uint

+ func (p Pagination) UOffset() uint

type Repository

+ func (repo *Repository[ID, E]) NewEntity(id ID) E

Aug 29, 2024

Changes in this version

+ var ErrNotFound = errors.New("record not found")

+ type Factory func(ID) Ent

+ type Repository struct

+ func NewRepository[ID any, Ent Entity](db DB, factory Factory[ID, Ent]) *Repository[ID, Ent]

+ func (repo *Repository[ID, Ent]) Create(ctx context.Context, ent Ent) error

+ func (repo *Repository[ID, Ent]) Delete(ctx context.Context, ent Ent) error

+ func (repo *Repository[ID, Ent]) Find(ctx context.Context, id ID) (Ent, error)

+ func (repo *Repository[ID, Ent]) ForEach(ctx context.Context, stmt *goqu.SelectDataset, ...) error

+ func (repo *Repository[ID, Ent]) PageQuery(ctx context.Context, stmt *goqu.SelectDataset, currentPage, pageSize int) ([]Ent, Pagination, error)

+ func (repo *Repository[ID, Ent]) Save(ctx context.Context, ent Ent) error

+ func (repo *Repository[ID, Ent]) Update(ctx context.Context, id ID, apply func(ent Ent) (bool, error)) error

+ func (repo *Repository[ID, Ent]) UpdateByQuery(ctx context.Context, stmt *goqu.SelectDataset, ...) error

May 1, 2024

Changes in this version

+ type AfterDeleteHook interface

+ AfterDelete func(ctx context.Context) error

+ type AfterInsertHook interface

+ AfterInsert func(ctx context.Context) error

+ type AfterUpdateHook interface

+ AfterUpdate func(ctx context.Context) error

+ type BeforeDeleteHook interface

+ BeforeDelete func(ctx context.Context) error

+ type BeforeInsertHook interface

+ BeforeInsert func(ctx context.Context) error

+ type BeforeUpdateHook interface

+ BeforeUpdate func(ctx context.Context) error

+ type EventHook interface

+ OnEntityEvent func(ctx context.Context, ev Event) error

Jun 28, 2023

Changes in this version

+ func QueryBy(ctx context.Context, db DB, stmt *goqu.SelectDataset, ...) error

+ func TryTransaction(db DB, fn func(DB) error) error

Sep 15, 2021

Changes in this version

+ type Pagination struct

+ Current int

+ First int

+ Items int

+ Last int

+ Next int

+ Previous int

+ Size int

+ func NewPagination(current, size, items int) Pagination

+ func (p Pagination) Limit() int

+ func (p Pagination) Offset() int

Jan 8, 2021

Changes in this version

type CacheOption

+ Disable bool

Nov 26, 2020

Changes in this version

+ func ExecInsert(ctx context.Context, db DB, stmt *goqu.InsertDataset) (sql.Result, error)

Aug 5, 2020

Changes in this version

+ func GetRecord(ctx context.Context, dest interface{}, db DB, stmt *goqu.SelectDataset) error

+ func GetRecords(ctx context.Context, dest interface{}, db DB, stmt *goqu.SelectDataset) error

Aug 5, 2020

Changes in this version

+ func GetRecorde(ctx context.Context, dest interface{}, db DB, stmt *goqu.SelectDataset) error

+ func GetRecordes(ctx context.Context, dest interface{}, db DB, stmt *goqu.SelectDataset) error

Aug 5, 2020

Changes in this version

+ var ErrConflict = fmt.Errorf("database record conflict")

+ var ReadTimeout = 3 * time.Second

+ var WriteTimeout = 3 * time.Second

+ func Delete(ctx context.Context, ent Entity, db DB) error

+ func DeleteCache(ent Cacheable) error

+ func ExecDelete(ctx context.Context, db DB, stmt *goqu.DeleteDataset) (sql.Result, error)

+ func ExecUpdate(ctx context.Context, db DB, stmt *goqu.UpdateDataset) (sql.Result, error)

+ func GetRecode(ctx context.Context, dest interface{}, db DB, stmt *goqu.SelectDataset) error

+ func GetRecodes(ctx context.Context, dest interface{}, db DB, stmt *goqu.SelectDataset) error

+ func GetTotalCount(ctx context.Context, db DB, stmt *goqu.SelectDataset) (int, error)

+ func Insert(ctx context.Context, ent Entity, db DB) (int64, error)

+ func Load(ctx context.Context, ent Entity, db DB) error

+ func SaveCache(ent Cacheable) error

+ func Transaction(db *sqlx.DB, fn func(tx *sqlx.Tx) error) (err error)

+ func Update(ctx context.Context, ent Entity, db DB) error

+ type CacheOption struct

+ Cacher Cacher

+ Compress bool

+ Expiration time.Duration

+ Key string

+ RecursiveDecode []string

+ type Cacheable interface

+ CacheOption func() CacheOption

+ type Cacher interface

+ Delete func(key string) error

+ Get func(key string) ([]byte, error)

+ Put func(key string, data []byte, expiration time.Duration) error

+ var DefaultCacher Cacher

+ type Column struct

+ AutoIncrement bool

+ DBField string

+ PrimaryKey bool

+ RefuseUpdate bool

+ ReturningInsert bool

+ ReturningUpdate bool

+ StructField string

+ func (c Column) String() string

+ type DB interface

+ BindNamed func(string, interface{}) (string, []interface{}, error)

+ DriverName func() string

+ Get func(dest interface{}, query string, args ...interface{}) error

+ GetContext func(ctx context.Context, dest interface{}, query string, args ...interface{}) error

+ NamedExec func(query string, arg interface{}) (sql.Result, error)

+ NamedExecContext func(ctx context.Context, query string, arg interface{}) (sql.Result, error)

+ NamedQuery func(query string, arg interface{}) (*sqlx.Rows, error)

+ PrepareNamed func(query string) (*sqlx.NamedStmt, error)

+ PrepareNamedContext func(ctx context.Context, query string) (*sqlx.NamedStmt, error)

+ Preparex func(query string) (*sqlx.Stmt, error)

+ PreparexContext func(ctx context.Context, query string) (*sqlx.Stmt, error)

+ Rebind func(string) string

+ Select func(dest interface{}, query string, args ...interface{}) error

+ SelectContext func(ctx context.Context, dest interface{}, query string, args ...interface{}) error

+ type Entity interface

+ OnEntityEvent func(ctx context.Context, ev Event) error

+ TableName func() string

+ type Event int

+ const EventAfterDelete

+ const EventAfterInsert

+ const EventAfterUpdate

+ const EventBeforeDelete

+ const EventBeforeInsert

+ const EventBeforeUpdate

+ const EventUnknown

+ type Metadata struct

+ Columns []Column

+ PrimaryKeys []Column

+ TableName string

+ Type reflect.Type

+ func NewMetadata(ent Entity) (*Metadata, error)

+ type PrepareInsertStatement struct

+ func PrepareInsert(ctx context.Context, ent Entity, db DB) (*PrepareInsertStatement, error)

+ func (pis *PrepareInsertStatement) Close() error

+ func (pis *PrepareInsertStatement) ExecContext(ctx context.Context, ent Entity) (lastID int64, err error)

+ type PrepareUpdateStatement struct

+ func PrepareUpdate(ctx context.Context, ent Entity, db DB) (*PrepareUpdateStatement, error)

+ func (pus *PrepareUpdateStatement) Close() error

+ func (pus *PrepareUpdateStatement) ExecContext(ctx context.Context, ent Entity) error