pgsql

README

pgsql

pgsql is the helper functions for postgres

Documentation

Index

• Variables
• func IsCharacterNotInRepertoire(err error) bool
• func IsErrorClass(err error, class string) bool
• func IsErrorCode(err error, code string) bool
• func IsForeignKeyViolation(err error, constraint ...string) bool
• func IsInvalidTextRepresentation(err error) bool
• func IsQueryCanceled(err error) bool
• func IsSerializationFailure(err error) bool
• func IsUniqueViolation(err error, constraint ...string) bool
• func Iter(q interface{ ... }, iter Iterator, query string, args ...any) error
• func IterContext(ctx context.Context, q interface{ ... }, iter Iterator, query string, ...) error
• func JSON(value any) interface{ ... }
• func Null[T comparable](v *T) interface{ ... }
• func NullInt64(i *int64) interface{ ... }
• func NullString(s *string) interface{ ... }
• func NullTime(t *time.Time) interface{ ... }
• func RunInTx(db BeginTxer, opts *TxOptions, fn func(*sql.Tx) error) error
• func RunInTxContext(ctx context.Context, db BeginTxer, opts *TxOptions, fn func(*sql.Tx) error) error
• type BeginTxer
• type Iterator
• type QueryContext
• type Row
  • func (r *Row) Scan(dest ...any) error
• type Rows
  • func (r *Rows) Scan(dest ...any) error
• type Scanner
  • func Scan(scan Scanner) Scanner
• type Time
  • func (t *Time) Scan(src any) error
  • func (t Time) Value() (driver.Value, error)
• type TxOptions

Variables

var ErrAbortTx = errors.New("pgsql: abort tx")

ErrAbortTx rollbacks transaction and return nil error

Functions

func IsCharacterNotInRepertoire

func IsCharacterNotInRepertoire(err error) bool

IsCharacterNotInRepertoire checks is error a character_not_in_repertoire

func IsErrorClass

func IsErrorClass(err error, class string) bool

IsErrorClass checks is error has given class

func IsErrorCode

func IsErrorCode(err error, code string) bool

IsErrorCode checks is error has given code

func IsForeignKeyViolation

func IsForeignKeyViolation(err error, constraint ...string) bool

IsForeignKeyViolation checks is error an foreign_key_violation

func IsInvalidTextRepresentation

func IsInvalidTextRepresentation(err error) bool

IsInvalidTextRepresentation checks is error an invalid_text_representation

func IsQueryCanceled

func IsQueryCanceled(err error) bool

IsQueryCanceled checks is error an query_canceled error (pq: canceling statement due to user request)

func IsSerializationFailure

func IsSerializationFailure(err error) bool

IsSerializationFailure checks is error a serialization_failure error (pq: could not serialize access due to read/write dependencies among transactions)

func IsUniqueViolation

func IsUniqueViolation(err error, constraint ...string) bool

IsUniqueViolation checks is error an unique_violation with given constraint, constraint can be empty to ignore constraint name checks

func Iter

func Iter(q interface {
	QueryContext(context.Context, string, ...any) (*sql.Rows, error)
}, iter Iterator, query string, args ...any) error

func IterContext

func IterContext(ctx context.Context, q interface {
	QueryContext(context.Context, string, ...any) (*sql.Rows, error)
}, iter Iterator, query string, args ...any) error

func JSON

func JSON(value any) interface {
	driver.Valuer
	sql.Scanner
}

JSON wraps value with scanner and valuer

func Null

func Null[T comparable](v *T) interface {
	driver.Valuer
	sql.Scanner
}

func NullInt64

func NullInt64(i *int64) interface {
	driver.Valuer
	sql.Scanner
}

NullInt64 scans null into zero int64 and convert zero into sql null

func NullString

func NullString(s *string) interface {
	driver.Valuer
	sql.Scanner
}

NullString scans null into empty string and convert empty string into sql null

func NullTime

func NullTime(t *time.Time) interface {
	driver.Valuer
	sql.Scanner
}

NullTime likes Time but wrap time.Time with scanner

func RunInTx

func RunInTx(db BeginTxer, opts *TxOptions, fn func(*sql.Tx) error) error

RunInTx runs fn inside retryable transaction.

see RunInTxContext for more info.

func RunInTxContext

func RunInTxContext(ctx context.Context, db BeginTxer, opts *TxOptions, fn func(*sql.Tx) error) error

RunInTxContext runs fn inside retryable transaction with context. It use Serializable isolation level if tx options isolation is setted to sql.LevelDefault.

RunInTxContext DO NOT handle panic. But when panic, it will rollback the transaction.

Types

type BeginTxer

type BeginTxer interface {
	BeginTx(context.Context, *sql.TxOptions) (*sql.Tx, error)
}

BeginTxer type

type Iterator

type Iterator func(scan Scanner) error

type QueryContext

type QueryContext interface {
	QueryContext(context.Context, string, ...any) (*sql.Rows, error)
}

QueryContext interface

type Row

type Row struct {
	*sql.Row
}

func (*Row) Scan

func (r *Row) Scan(dest ...any) error

type Rows

type Rows struct {
	*sql.Rows
}

func (*Rows) Scan

func (r *Rows) Scan(dest ...any) error

type Scanner

type Scanner func(dest ...any) error

func Scan

func Scan(scan Scanner) Scanner

Scan wraps scanner with custom scanner

type Time

type Time struct {
	time.Time
}

Time is the time.Time but can scan null into empty

func (*Time) Scan

func (t *Time) Scan(src any) error

Scan implements Scanner interface

func (Time) Value

func (t Time) Value() (driver.Value, error)

Value implements Valuer interface

type TxOptions

type TxOptions struct {
	sql.TxOptions
	MaxAttempts int
}

TxOptions is the transaction options