repo

type AttachFunc[T model.Modelable] func(ctx context.Context, results []T, include string) error

type Connection struct {
	Db    sql.Database
	Store sql.Executor
	// contains filtered or unexported fields
}

type Ex = goqu.Ex

type ExOr = goqu.ExOr

type Expression = goqu.Expression

type GenericStore[T model.Modelable] interface {
	First(ctx context.Context, expr Expression, order ...OrderedExpression) (T, error)
	Find(ctx context.Context, dest T, id int64) error
	CountBy(ctx context.Context, expr Expression) (int64, error)
	Get(ctx context.Context, id int64) (T, error)
	GetBy(ctx context.Context, expr Expression) (T, error)
	GetForUpdate(ctx context.Context, expr Expression, order ...OrderedExpression) (T, error)
	Exists(ctx context.Context, expr Expression) (bool, error)
	List(ctx context.Context, opts ...clause.FilterOption) (*response.ListResponse[T], error)
	ListBy(ctx context.Context, expr Expression, opts ...clause.FilterOption) (*response.ListResponse[T], error)
	ListByIds(ctx context.Context, ids []int64) (*response.ListResponse[T], error)
	ListEach(ctx context.Context, fn func(item T) error, opts ...clause.FilterOption) error
	ListByEach(ctx context.Context, expr Expression, fn func(item T) error, opts ...clause.FilterOption) error
	Insert(ctx context.Context, req T) error
	// Upsert inserts a new record in the database, if the target column has a conflict then updates the fields instead
	Upsert(ctx context.Context, req T, target string) (bool, error)
	// Update updates a record on the repository
	Update(ctx context.Context, req T) error
	// UpdateMap updates a record from the repository, only updates the specified fields in the map
	UpdateMap(ctx context.Context, id int64, req map[string]any) error
	// UpdateMapBy updates the records matched by the expression, only updates the specified fields in the map
	UpdateMapBy(ctx context.Context, req map[string]any, expr Expression) (int64, error)
	// Delete removes a record from the repository, returns ErrNotFound if the ID doesn't exist
	Delete(ctx context.Context, id int64) error
	// DeleteBy removes the records matched by the expression, returns the deleted count on success
	DeleteBy(ctx context.Context, expr Ex) (int64, error)
}

type GenericStoreImpl[T model.Modelable] struct {
	Conn    sql.Executor
	Builder goqu.DialectWrapper
	Table   string
	// contains filtered or unexported fields
}

type Op = goqu.Op

type OrderedExpression = exp.OrderedExpression

type RepoError struct {
	Err error
	// contains filtered or unexported fields
}

type StoreOption[T model.Modelable] func(c *GenericStoreImpl[T])