pg

Apr 24, 2025

Changes in this version

type IRepository

+ GetByBuilder func(ctx context.Context, selectBuilder sq.SelectBuilder) []any

type Repository

+ func (repo Repository[T]) GetByBuilder(ctx context.Context, selectBuilder sq.SelectBuilder) []T

Apr 24, 2025

Changes in this version

type Repository

+ ExtraBuilders []builder.Builder

Apr 18, 2025

Changes in this version

type IRepository

+ Upsert func(ctx context.Context, values ...interface{}) int64

type Repository

+ func (repo Repository[T]) Upsert(ctx context.Context, values ...interface{}) int64

Apr 18, 2025

Changes in this version

type Repository

+ UpsertBuilder sq.InsertBuilder

Apr 16, 2025

Changes in this version

+ type Closer interface

+ Close func() error

type DbClient

+ func (db DbClient) Logger() *slog.Logger

+ func (db DbClient) SetLogger(l *slog.Logger)

Apr 14, 2025

Changes in this version

type DbClient

+ API func() pg_api.PgDbClient

Apr 7, 2025

Changes in this version

+ const RETURNING_ID

+ type DbApi interface

+ Close func()

+ type DbClient interface

+ Close func() error

+ Pg func() PgDbClient

+ RunTransaction func(ctx context.Context, txOptions transaction.TxOptions, ...) error

+ func NewDBClient(ctx context.Context, dsn string) (DbClient, error)

+ type IRepository interface

+ Create func(ctx context.Context, values ...interface{}) int64

+ Delete func(ctx context.Context, id int64) int64

+ GetAll func(ctx context.Context) []any

+ GetBy func(ctx context.Context, where sq.Sqlizer) []any

+ GetById func(ctx context.Context, id int64) any

+ Update func(ctx context.Context, fields map[string]interface{}, id int64) int64

+ UpdateCollection func(ctx context.Context, fields map[string]interface{}, where sq.Sqlizer) int64

+ UpdateReturning func(ctx context.Context, builder sq.UpdateBuilder, ...) any

+ type Identifiable interface

+ GetID func() int64

+ type PgDbClient struct

+ func NewPgDBClient(ctx context.Context, dsn string) (PgDbClient, error)

+ func (c PgDbClient) API() pg_api.PG

+ func (c PgDbClient) Close() error

+ func (c PgDbClient) RunTransaction(ctx context.Context, txOpts transaction.TxOptions, f pg_api.TransactionalFlow) error

+ type Pinger interface

+ Ping func(ctx context.Context) error

+ type Related interface

+ GetParentID func() int64

+ PushToParent func(parent any)

+ type Relation struct

+ ForeignKey string

+ ParentIdGetter func(R) int64

+ Repo Repository[R]

+ func WrapRelation[R any](r Relation[R]) Relation[any]

+ func (r Relation[R]) GetForeignKey() string

+ func (r Relation[R]) GetParentId(child R) int64

+ type Repository struct

+ AddRelated func(*T, any)

+ AddRelation func(Relation[any])

+ Converter func(row pgx.Row) any

+ DB PgDbClient

+ DeleteBuilder sq.DeleteBuilder

+ InsertBuilder sq.InsertBuilder

+ Relations []Relation[any]

+ SelectBuilder sq.SelectBuilder

+ UpdateBuilder sq.UpdateBuilder

+ func NewRepository[T any](anchor T, db DbClient, insertBuilder sq.InsertBuilder, ...) Repository[T]

+ func WrapRepository[R any](repo Repository[R]) Repository[any]

+ func (repo Repository[T]) Create(ctx context.Context, values ...interface{}) int64

+ func (repo Repository[T]) Delete(ctx context.Context, id int64) int64

+ func (repo Repository[T]) GetAll(ctx context.Context) []T

+ func (repo Repository[T]) GetBy(ctx context.Context, where sq.Sqlizer) []T

+ func (repo Repository[T]) GetById(ctx context.Context, id int64) T

+ func (repo Repository[T]) Update(ctx context.Context, fields map[string]interface{}, id int64) int64

+ func (repo Repository[T]) UpdateCollection(ctx context.Context, fields map[string]interface{}, where sq.Sqlizer) int64

+ func (repo Repository[T]) UpdateReturning(ctx context.Context, builder sq.UpdateBuilder) any

+ func (repo Repository[T]) UpdateReturningWithExtendedConverter(ctx context.Context, builder sq.UpdateBuilder, ...) any