dbdriver

Documentation

Index

• func Connect(ctx context.Context, connString string) (*pgxpool.Pool, error)
• type Config
• type DB
  • func New(ctx context.Context, cfg Config) (*DB, error)
  • func (o *DB) Begin(ctx context.Context) (pgx.Tx, error)
  • func (o *DB) Close()
  • func (o *DB) RawConn() *pgxpool.Pool
• type DBTX
• type RowScanner

Functions

func Connect

func Connect(ctx context.Context, connString string) (*pgxpool.Pool, error)

Connect connString like: // # Example DSN

user=jack password=secret host=pg.example.com port=5432 dbname=mydb sslmode=verify-ca pool_max_conns=10

# Example URL
postgres://jack:secret@pg.example.com:5432/mydb?sslmode=verify-ca&pool_max_conns=10

Types

type Config

type Config struct {
	Logger     zerolog.Logger
	ConnString string
}

type DB

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

func New

func New(ctx context.Context, cfg Config) (*DB, error)

func (*DB) Begin

func (o *DB) Begin(ctx context.Context) (pgx.Tx, error)

func (*DB) Close

func (o *DB) Close()

func (*DB) RawConn

func (o *DB) RawConn() *pgxpool.Pool

type DBTX

type DBTX interface {
	Exec(context.Context, string, ...interface{}) (pgconn.CommandTag, error)
	Query(context.Context, string, ...interface{}) (pgx.Rows, error)
	QueryRow(context.Context, string, ...interface{}) pgx.Row
}

type RowScanner

type RowScanner interface {
	Scan(dest ...interface{}) error
}