db

Documentation

Overview

Copyright 2023 Christopher Briscoe. All rights reserved.

Copyright 2023 Christopher Briscoe. All rights reserved.

Index

• func NewPgConn(cfg *Config) (*pgx.Conn, error)
• func NewPgPool(cfg *Config) (*pgxpool.Pool, error)
• type Batch
  • func NewBatch(ctx context.Context, db *pgxpool.Pool) *Batch
  • func (b *Batch) Exec() (int64, error)
  • func (b *Batch) Queue(query string, arguments ...any)
• type Config

Functions

func NewPgConn

func NewPgConn(cfg *Config) (*pgx.Conn, error)

NewPgConn connects to a postgres db and returns a connection

func NewPgPool

func NewPgPool(cfg *Config) (*pgxpool.Pool, error)

NewPgPool connects to a postgres db and returns a pool of connections

Types

type Batch

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

Batch holds sql to be executed at once

func NewBatch

func NewBatch(ctx context.Context, db *pgxpool.Pool) *Batch

NewBatch returns a new Batch object

func (*Batch) Exec

func (b *Batch) Exec() (int64, error)

Exec executes all of the sql in the batch and returns the first error

func (*Batch) Queue

func (b *Batch) Queue(query string, arguments ...any)

Queue adds an sql statement to the batch

type Config

type Config struct {
	Host string `json:"host"`
	Port string `json:"port"`
	Name string `json:"name"`
	User string `json:"user"`
	Pass string `json:"pass"`
}

Config stores postgres database connection info