postgres

Documentation

Index

• type Client
  • func NewClient(dsn string, opts ...Option) (*Client, error)
  • func (c *Client) Close(_ context.Context) error
  • func (c *Client) DB() *sql.DB
  • func (c *Client) Exec(ctx context.Context, query string, args ...any) (pgconn.CommandTag, error)
  • func (c *Client) Master() *pgxpool.Pool
  • func (c *Client) Ping(ctx context.Context) error
  • func (c *Client) Query(ctx context.Context, query string, args ...any) (pgx.Rows, error)
  • func (c *Client) QueryRow(ctx context.Context, query string, args ...any) pgx.Row
  • func (c *Client) ScanQuery(ctx context.Context, dst any, query string, args ...any) error
  • func (c *Client) ScanQueryRow(ctx context.Context, dst any, query string, args ...any) error
• type Option
  • func WithLogger(logger *slog.Logger) Option
• type Transaction
  • func NewTransaction(db *pgxpool.Pool) *Transaction
  • func (t *Transaction) ReadCommitted(ctx context.Context, fn func(ctx context.Context) error) error

Types

type Client

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

func NewClient

func NewClient(dsn string, opts ...Option) (*Client, error)

func (*Client) Close

func (c *Client) Close(_ context.Context) error

func (*Client) DB

func (c *Client) DB() *sql.DB

func (*Client) Exec

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

func (*Client) Master

func (c *Client) Master() *pgxpool.Pool

func (*Client) Ping

func (c *Client) Ping(ctx context.Context) error

func (*Client) Query

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

func (*Client) QueryRow

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

func (*Client) ScanQuery

func (c *Client) ScanQuery(ctx context.Context, dst any, query string, args ...any) error

func (*Client) ScanQueryRow

func (c *Client) ScanQueryRow(ctx context.Context, dst any, query string, args ...any) error

type Option

type Option func(c *Client) error

func WithLogger

func WithLogger(logger *slog.Logger) Option

type Transaction

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

func NewTransaction

func NewTransaction(db *pgxpool.Pool) *Transaction

func (*Transaction) ReadCommitted

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