pgfx

Sep 22, 2026

Changes in this version

type DB

+ func (d *DB) FetchRowsInto[T any](ctx context.Context, dst []T, sql string, args ...any) ([]T, error)

+ func (d *DB) FetchValuesInto[T any](ctx context.Context, dst []T, sql string, args ...any) ([]T, error)

type Tx

+ func (t *Tx) FetchRowsInto[T any](ctx context.Context, dst []T, sql string, args ...any) ([]T, error)

+ func (t *Tx) FetchValuesInto[T any](ctx context.Context, dst []T, sql string, args ...any) ([]T, error)

Sep 17, 2026

Changes in this version

type Config

+ func (Config) ConfigName() string

Sep 14, 2026

Changes in this version

type DB

+ func (d *DB) FetchAfter[T any](ctx context.Context, query page.Query, req page.CursorRequest, args ...any) (page.CursorResult[T], error)

+ func (d *DB) FetchPageRows[T any](ctx context.Context, query page.Query, req page.Request, args ...any) ([]T, bool, error)

+ func (d *DB) FetchTotal(ctx context.Context, query page.Query, args ...any) (uint, error)

type Tx

+ func (t *Tx) FetchAfter[T any](ctx context.Context, query page.Query, req page.CursorRequest, args ...any) (page.CursorResult[T], error)

+ func (t *Tx) FetchPageRows[T any](ctx context.Context, query page.Query, req page.Request, args ...any) ([]T, bool, error)

+ func (t *Tx) FetchTotal(ctx context.Context, query page.Query, args ...any) (uint, error)

Sep 3, 2026

Changes in this version

+ type QueryKind uint8

+ const KindBatch

+ const KindCopyFrom

+ const KindQuery

+ func (k QueryKind) String() string

type QueryMetric

+ Kind QueryKind

Sep 3, 2026

Changes in this version

type DB

+ func (d *DB) FetchPage[T any](ctx context.Context, query page.Query, req page.Request, args ...any) ([]T, uint, error)

type Tx

+ func (t *Tx) FetchPage[T any](ctx context.Context, query page.Query, req page.Request, args ...any) ([]T, uint, error)

Sep 1, 2026

Changes in this version

+ type DB struct

+ func (d *DB) FetchRow[T any](ctx context.Context, sql string, args ...any) (T, error)

+ func (d *DB) FetchRows[T any](ctx context.Context, sql string, args ...any) ([]T, error)

+ func (d *DB) FetchValue[T any](ctx context.Context, sql string, args ...any) (T, error)

+ func (d *DB) FetchValues[T any](ctx context.Context, sql string, args ...any) ([]T, error)

+ func (d *DB) Transaction(ctx context.Context, opts pgx.TxOptions, fn func(*Tx) error) error

type Tx

+ func (t *Tx) BeginNested(ctx context.Context) (*Tx, error)

+ func (t *Tx) FetchRow[T any](ctx context.Context, sql string, args ...any) (T, error)

+ func (t *Tx) FetchRows[T any](ctx context.Context, sql string, args ...any) ([]T, error)

+ func (t *Tx) FetchValue[T any](ctx context.Context, sql string, args ...any) (T, error)

+ func (t *Tx) FetchValues[T any](ctx context.Context, sql string, args ...any) ([]T, error)

+ func (t *Tx) Transaction(ctx context.Context, fn func(*Tx) error) error

Aug 4, 2026

Changes in this version

+ var Module = fx.Module("pgfx", poolProvider(``))

+ func FetchRow[T any](ctx context.Context, q Querier, sql string, args ...any) (T, error)

+ func FetchRows[T any](ctx context.Context, q Querier, sql string, args ...any) ([]T, error)

+ func FetchValue[T any](ctx context.Context, q Querier, sql string, args ...any) (T, error)

+ func FetchValues[T any](ctx context.Context, q Querier, sql string, args ...any) ([]T, error)

+ func Make(ctx context.Context, cfg Config, opts ...Option) (*pgxpool.Pool, error)

+ func ModuleFor(name string) fx.Option

+ func QueryName(ctx context.Context) string

+ func Tx(ctx context.Context, db TxBeginner, opts pgx.TxOptions, fn func(pgx.Tx) error) (err error)

+ func WithQueryName(ctx context.Context, name string) context.Context

+ type Config struct

+ AppName string

+ Database string

+ Host string

+ Password secret.Secret

+ Pool PoolConfig

+ TLS TLSConfig

+ Timeouts TimeoutConfig

+ User string

+ func (cfg Config) Validate() error

+ type Option func(*options)

+ func WithAfterConnect(fn func(context.Context, *pgx.Conn) error) Option

+ func WithBeforeConnect(fn func(context.Context, *pgx.ConnConfig) error) Option

+ func WithDefaultQueryExecMode(mode pgx.QueryExecMode) Option

+ func WithQueryMetrics(fn QueryMetricFunc) Option

+ func WithRuntimeParam(key, value string) Option

+ func WithSQLInQueryMetrics(include bool) Option

+ func WithStatementCacheCapacity(capacity int) Option

+ func WithTLS(tlsConfig *tls.Config) Option

+ func WithTracer(tracer pgx.QueryTracer) Option

+ func WithTracing(opts ...otelpgx.Option) Option

+ type PoolConfig struct

+ HealthPeriod time.Duration

+ MaxConnIdleTime time.Duration

+ MaxConnLifetime time.Duration

+ MaxConnLifetimeJitter time.Duration

+ MaxConns int32

+ MinConns int32

+ MinIdleConns int32

+ type Querier interface

+ Query func(ctx context.Context, sql string, args ...any) (pgx.Rows, error)

+ type QueryMetric struct

+ Duration time.Duration

+ Err error

+ Name string

+ RowsAffected int64

+ SQL string

+ type QueryMetricFunc func(QueryMetric)

+ type TLSConfig struct

+ Cert string

+ Key string

+ Mode string

+ RootCert string

+ ServerName string

+ type TimeoutConfig struct

+ Connect time.Duration

+ type TxBeginner interface

+ BeginTx func(ctx context.Context, txOptions pgx.TxOptions) (pgx.Tx, error)