txpostgres

Documentation

Index

• func AsPgError(err error) (*pgconn.PgError, bool)
• func IsNoRows(err error) bool
• func New(pool ports.DatabasePool) ports.TxManager
• type DBer
  • func FromCtx(ctx context.Context, pool ports.DatabasePool) DBer
• type Manager
  • func (m *Manager) WithinTx(ctx context.Context, fn func(ctx context.Context) error) error

Functions

func AsPgError

func AsPgError(err error) (*pgconn.PgError, bool)

func IsNoRows

func IsNoRows(err error) bool

func New

func New(pool ports.DatabasePool) ports.TxManager

Types

type DBer

type DBer interface {
	Exec(ctx context.Context, sql string, args ...any) (ports.DatabaseResult, error)
	Query(ctx context.Context, sql string, args ...any) (ports.DatabaseRows, error)
	QueryRow(ctx context.Context, sql string, args ...any) ports.DatabaseRow
}

DBer is satisfied by transactions and the pool facade below.

func FromCtx

func FromCtx(ctx context.Context, pool ports.DatabasePool) DBer

FromCtx returns the active transaction if present; otherwise a facade that acquires/releases a connection per call (no leaks).

type Manager

type Manager struct {
	Pool ports.DatabasePool
}

Manager implements ports.TxManager using a pgx-like pool.

func (*Manager) WithinTx

func (m *Manager) WithinTx(
	ctx context.Context, fn func(ctx context.Context) error,
) error