Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

postgresdb

package

Go to main page

Versions in this module

v0

v0.3.0

Mar 1, 2026

v0.2.0

Dec 10, 2025

v0.1.0

Dec 10, 2025

Changes in this version

+ const ModuleName

+ var ErrNoDBConnection error = fmt.Errorf("database connection pool not set")

+ var ErrNoTransaction error = fmt.Errorf("transaction has not been started")

+ var ErrNotFound error = fmt.Errorf("resource not found")

+ func BuildDSN(user, password, host, database string, port uint, queryOpts ...string) *url.URL

+ func New() modules.Module

+ func WithDSN(dsn string) modules.Option

+ func WithDatabase(database string) modules.Option

+ func WithHost(host string) modules.Option

+ func WithMigrations(cfg *MigrationsConfig) modules.Option

+ func WithMigrationsLocation(location string) modules.Option

+ func WithMigrationsSchemaName(schemaName string) modules.Option

+ func WithMigrationsTable(table string) modules.Option

+ func WithPassword(password string) modules.Option

+ func WithPort(port uint) modules.Option

+ func WithUser(user string) modules.Option

+ type CloseTx func(error) error

+ type ExecOption func(*Executor)

+ func WithFilter(filter query.Filter) ExecOption

+ func WithLimit(limit query.Limit) ExecOption

+ func WithOrderBy(orderBy query.OrderBy) ExecOption

+ func WithTransaction(tx Tx) ExecOption

+ type Executor struct

+ func NewExecutor(querier Querier, opts ...ExecOption) *Executor

+ func (e *Executor) Exec(ctx context.Context, sql string, args ...any) (pgconn.CommandTag, error)

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

+ func (e *Executor) QueryRow(ctx context.Context, sql string, args ...any) (pgx.Row, error)

+ type Migrations struct

+ func InitMigrations(cfg *MigrationsConfig) (*Migrations, error)

+ func (m *Migrations) Close() error

+ func (m *Migrations) Down() error

+ func (m *Migrations) Up() error

+ type MigrationsConfig struct

+ Location string

+ Pool *pgxpool.Pool

+ SchemaName string

+ Table string

+ type Module struct

+ func (m *Module) Configure(opts ...modules.Option) error

+ func (m *Module) Health(ctx context.Context) error

+ func (m *Module) Pool() *pgxpool.Pool

+ func (m *Module) Shutdown() error

+ func (m *Module) Start() (err error)

+ type Querier interface

+ Exec func(context.Context, string, ...any) (pgconn.CommandTag, error)

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

+ QueryRow func(context.Context, string, ...any) pgx.Row

+ type Tx interface