pgext

Documentation

Index

• type PgxBeginner
  • func (pgb *PgxBeginner) Begin(ctx context.Context, rawopts ...any) (*gotx.Transaction[pgx.Tx], error)
• type PostgresError
  • func AsPostgresError(err error) *PostgresError
  • func (pe *PostgresError) IsUniqueViolation(col ...string) bool
• type SelectBuilder
• type Table
  • func (t *Table[T]) Count(ctx context.Context, builder ...SelectBuilder) (uint64, error)
  • func (t *Table[T]) Find(ctx context.Context, where ...SelectBuilder) (*T, error)
  • func (t *Table[T]) FindAll(ctx context.Context, builder ...SelectBuilder) ([]T, error)
  • func (t *Table[T]) Insert(ctx context.Context, data []*T, returning ...bool) ([]T, error)
  • func (t *Table[T]) InsertOne(ctx context.Context, record *T, returning ...bool) (*T, error)
  • func (t *Table[T]) Update(ctx context.Context, record any, builder UpdateBuilder, returning ...bool) ([]T, error)
• type Transactor
  • func NewTransactor(pool *pgxpool.Pool) *Transactor
• type UpdateBuilder

Types

type PgxBeginner

type PgxBeginner struct {
	Pool *pgxpool.Pool
}

func (*PgxBeginner) Begin

func (pgb *PgxBeginner) Begin(ctx context.Context, rawopts ...any) (
	*gotx.Transaction[pgx.Tx], error,
)

type PostgresError

type PostgresError struct {
	*pgconn.PgError
}

func AsPostgresError

func AsPostgresError(err error) *PostgresError

func (*PostgresError) IsUniqueViolation

func (pe *PostgresError) IsUniqueViolation(col ...string) bool

type SelectBuilder

type SelectBuilder = func(sb *sqlbuilder.SelectBuilder)

type Table

type Table[T any] struct {
	Name  string
	Txer  *Transactor
	Log   *slog.Logger
	RowTo pgx.RowToFunc[T]
	// contains filtered or unexported fields
}

func (*Table[T]) Count

func (t *Table[T]) Count(ctx context.Context, builder ...SelectBuilder) (uint64, error)

func (*Table[T]) Find

func (t *Table[T]) Find(ctx context.Context, where ...SelectBuilder) (*T, error)

func (*Table[T]) FindAll

func (t *Table[T]) FindAll(ctx context.Context, builder ...SelectBuilder) ([]T, error)

func (*Table[T]) Insert

func (t *Table[T]) Insert(ctx context.Context, data []*T, returning ...bool) ([]T, error)

func (*Table[T]) InsertOne

func (t *Table[T]) InsertOne(ctx context.Context, record *T, returning ...bool) (*T, error)

func (*Table[T]) Update

func (t *Table[T]) Update(
	ctx context.Context,
	record any,
	builder UpdateBuilder,
	returning ...bool,
) ([]T, error)

type Transactor

type Transactor = gotx.Transactor[pgx.Tx]

func NewTransactor

func NewTransactor(pool *pgxpool.Pool) *Transactor

type UpdateBuilder

type UpdateBuilder = func(ub *sqlbuilder.UpdateBuilder)