postgres

package

v1.1.0 Latest Latest Go to latest Published: Mar 17, 2026 License: Apache-2.0 Imports: 9 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

Postgres wraps a Bun DB connection and error checker for Postgres-specific behavior.

func New(ctx context.Context, c db.Config) (*Postgres, error)

New initializes a Postgres connection using a pgx pool and returns a helper.

func (p *Postgres) BeginTx(ctx context.Context) (bun.Tx, error)

BeginTx begins a new transaction with default options.

func (p *Postgres) Close(ctx context.Context) error

Close closes the underlying Bun DB.

func (p *Postgres) DB() *bun.DB

DB exposes the underlying Bun DB.

func (p *Postgres) ErrorChecker() db.ErrorChecker

ErrorChecker returns a Postgres error classifier.

func (p *Postgres) RunInTx(
	ctx context.Context,
	fn func(ctx context.Context, tx bun.Tx) error,
) error

RunInTx executes a function within a transaction.

type PostgresErrorChecker struct{}

PostgresErrorChecker classifies common Postgres errors such as no rows and unique constraint violations.

func (checker *PostgresErrorChecker) IsErrNoRows(err error) bool

func (checker *PostgresErrorChecker) IsUniqueConstraintError(err error) bool