postgrespgxdb

Documentation

Index

• Constants
• func IsConstraintError(err error, name string) bool
• type AffectedLessThenNecessaryError
  • func (e *AffectedLessThenNecessaryError) Error() string
• type Config
  • func (cfg *Config) GetDSN() string
• type Conn
• type DBQuery
  • func New(cfg *Config, log types.SQLLoggerFunc) (DBQuery, error)

Constants

const (
	SCMPrepare  = "prepare"
	SCMDescribe = "describe"
)

StatementCacheMode values prepare - default describe - use it for PGBouncer connections

const (
	ConstraintErrorCode = "23505"
)

Functions

func IsConstraintError

func IsConstraintError(err error, name string) bool

Types

type AffectedLessThenNecessaryError

type AffectedLessThenNecessaryError struct {
	Affected  int64
	Necessary int64
}

func (*AffectedLessThenNecessaryError) Error

func (e *AffectedLessThenNecessaryError) Error() string

type Config

type Config struct {
	Host               string
	Port               string
	Name               string
	User               string
	Password           string
	SSLMode            string
	BinaryParameters   string // lib/pq setting for prepared statements in pgbouncer
	StatementCacheMode string
	MaxConnections     string
}

Start Config -------------------------------------------------

func (*Config) GetDSN

func (cfg *Config) GetDSN() string

type Conn

type Conn struct {
	*pgxpool.Pool
	*types.DBLog
}

type DBQuery

type DBQuery interface {
	Exec(ctx context.Context, sql string, arguments ...interface{}) (pgconn.CommandTag, error)
	Query(ctx context.Context, sql string, optionsAndArgs ...interface{}) (pgx.Rows, error)
	QueryRow(ctx context.Context, sql string, optionsAndArgs ...interface{}) pgx.Row
	Begin(ctx context.Context) (pgx.Tx, error)
	BeginTx(ctx context.Context, txOptions pgx.TxOptions) (pgx.Tx, error)
	SendBatch(ctx context.Context, b *pgx.Batch) pgx.BatchResults
	Close()
	types.SQLLogger
}

Start Connect -------------------------------------------------

func New

func New(cfg *Config, log types.SQLLoggerFunc) (DBQuery, error)