db

Documentation

Index

• type Postgres
  • func NewPostgres(ctx context.Context, connStr string) (*Postgres, error)
  • func (p *Postgres) Exec(ctx context.Context, query string, args ...any) (pgconn.CommandTag, error)
  • func (p *Postgres) Query(ctx context.Context, query string, args ...any) (pgx.Rows, error)
  • func (p *Postgres) QueryRow(ctx context.Context, query string, args ...any) pgx.Row
  • func (p *Postgres) Tx(ctx context.Context, fn func(pgx.Tx) error) error

Types

type Postgres

type Postgres struct {
	*sqlc.Queries
	// contains filtered or unexported fields
}

func NewPostgres

func NewPostgres(ctx context.Context, connStr string) (*Postgres, error)

func (*Postgres) Exec

func (p *Postgres) Exec(ctx context.Context, query string, args ...any) (pgconn.CommandTag, error)

func (*Postgres) Query

func (p *Postgres) Query(ctx context.Context, query string, args ...any) (pgx.Rows, error)

func (*Postgres) QueryRow

func (p *Postgres) QueryRow(ctx context.Context, query string, args ...any) pgx.Row

func (*Postgres) Tx

func (p *Postgres) Tx(ctx context.Context, fn func(pgx.Tx) error) error