repository

package

v0.7.1 Latest Latest Go to latest Published: Mar 1, 2025 License: BSD-3-Clause Imports: 17 Imported by: 0

Details

This section is empty.

View Source

var DefaultQuerySize = 100

This section is empty.

type Identifiable interface {
	ItemID() string
	SetItemID(string)
}

type Repository struct {
	// contains filtered or unexported fields
}

func New(pool *pgxpool.Pool, model database.ModelInterface) (*Repository, error)

func (repo *Repository) DeleteBy(field string, operator constants.ComparisonOperator, value interface{}) error

func (repo *Repository) DeleteById(id string) error

func (repo *Repository) Find(order constants.SortOrder, size, offset int) (int, []interface{}, error)

func (repo *Repository) FindAll() ([]interface{}, error)

func (repo *Repository) FindByIds(ids ...string) ([]interface{}, error)

func (repo *Repository) FindOneBy(criteria map[string]interface{}) (interface{}, error)

func (repo *Repository) FindOneById(id string) (interface{}, error)

func (repo *Repository) GetNumberOfRows() (int, error)

func (repo *Repository) Insert(entity interface{}) (interface{}, error)

func (repo *Repository) Latest() (interface{}, error)

func (repo *Repository) MapFromEntity(model *database.Model) (interface{}, error)

func (repo *Repository) MapToEntity(entity interface{}) *database.Model

MapToEntity maps a domain model to a Database Model

func (repo *Repository) ScanRow(row Row) (interface{}, error)

func (repo *Repository) TableName() string

func (repo *Repository) UpdateById(id string, update interface{}) (interface{}, error)

type Row interface {
	Scan(dest ...any) error
}

type RowScanner interface {
	ScanRow(row Row) (interface{}, error)
}

type Temporal interface {
	CreatedAt() int64
	UpdatedAt() int64
	SetCreatedAt(time.Time)
	SetUpdatedAt(time.Time)
}