pg

Dec 19, 2024

Changes in this version

type QueryEncoder

+ func Multi(ops []QueryEncoder, del ...string) QueryEncoder

Dec 16, 2024

Changes in this version

type QueryEncoder

+ func Like(col any, val string, alsoSuffix ...bool) QueryEncoder

+ func NotLike(col any, val string, alsoSuffix ...bool) QueryEncoder

Dec 9, 2024

Changes in this version

+ var ErrReleasedTransaction = errors.New("tried to operate on a released transaction")

type Tx

+ func (tx *Tx) Release(ctx ...context.Context) (err error)

Nov 25, 2024

Changes in this version

+ func DoUpdate(numConflictingColumns int, ignoreColumns ...string) func(vals *Values) EncodeQuery

+ type InsertOptions struct

+ OnConflict func(vals *Values) EncodeQuery

+ ReturnColumn string

+ ReturnDst any

Nov 22, 2024

Changes in this version

+ type InsertOption func(vals *Values) EncodeQuery

+ func Upsert(numConflictingColumns int, ignoreColumns ...string) InsertOption

Oct 31, 2024

Changes in this version

+ type Alias [2]StringEncoder

+ func (t Alias) Col(col string) ChainedIdentifier

+ func (t Alias) EncodeString(b *fast.StringBuffer)

type ChainedIdentifier

+ func (t ChainedIdentifier) Alias(col string) Alias

type Identifier

+ func (t Identifier) Alias(col string) Alias

Oct 31, 2024

Changes in this version

+ type ChainedIdentifier [2]StringEncoder

+ func (t ChainedIdentifier) Col(col string) ChainedIdentifier

+ func (t ChainedIdentifier) EncodeString(b *fast.StringBuffer)

type Identifier

+ func (t Identifier) Col(col string) ChainedIdentifier

Oct 23, 2024

Changes in this version

type DB

+ func New(ctx context.Context, connString string, alterConfig ...func(*pgxpool.Config)) (db *DB, err error)

+ type EncodeQuery func(buf *fast.StringBuffer, queryArgs *[]any)

+ func Multiple(enc ...QueryEncoder) EncodeQuery

+ func (fn EncodeQuery) EncodeQuery(buf *fast.StringBuffer, queryArgs *[]any)

+ type EncodeString func(buf *fast.StringBuffer)

+ func (fn EncodeString) EncodeString(buf *fast.StringBuffer)

type QueryEncoder

+ func Order(column string, order ...string) QueryEncoder

+ type StringEncoder = fast.StringEncoder

type Values

+ func (r *Values) EncodeQuery(buf *fast.StringBuffer, queryArgs *[]any)

Apr 2, 2024

Changes in this version

+ func PrefixSearch(str string) string

type QueryEncoder

+ func Search(col, val string, options ...SearchOptions) QueryEncoder

+ type SearchOptions struct

+ Dictionary string

+ Preprocessor func(string) string

Mar 18, 2024

Changes in this version

type DB

+ func (db *DB) Close()

Mar 13, 2024

Changes in this version

+ type Cond func(buf *fast.StringBuffer, queryArgs *[]any)

+ func (c Cond) EncodeQuery(buf *fast.StringBuffer, queryArgs *[]any)

+ type DB struct

+ func NewDB(db *pgxpool.Pool) *DB

+ func (db *DB) AcquireValues() *Values

+ func (db *DB) Delete(ctx context.Context, table Identifier, cond QueryEncoder) (count int64, err error)

+ func (db *DB) Exec(ctx context.Context, query string, args ...any) (pgconn.CommandTag, error)

+ func (db *DB) InsertValues(ctx context.Context, table Identifier, vals *Values, conflictColumns ...string) (count int64, err error)

+ func (db *DB) Query(ctx context.Context, query string, args ...any) (pgx.Rows, error)

+ func (db *DB) QueryRow(ctx context.Context, query string, args ...any) pgx.Row

+ func (db *DB) ReleaseValues(v *Values)

+ func (db *DB) Transaction(ctx context.Context, readOnly ...bool) (tx *Tx, err error)

+ func (db *DB) UpdateValues(ctx context.Context, table Identifier, vals *Values, cond QueryEncoder) (count int64, err error)

+ type Error struct

+ func (err Error) Args() []any

+ func (err Error) Error() string

+ func (err Error) Query() string

+ func (err Error) String() string

+ type Identifier string

+ func (t Identifier) EncodeString(b *fast.StringBuffer)

+ type MultiAnd interface

+ And func(QueryEncoder) MultiAnd

+ func And(ops ...QueryEncoder) MultiAnd

+ type MultiOr interface

+ Or func(QueryEncoder) MultiOr

+ func Or(ops ...QueryEncoder) MultiOr

+ type QueryEncoder interface

+ EncodeQuery func(buf *fast.StringBuffer, queryArgs *[]any)

+ func Eq(col string, val any) QueryEncoder

+ func Gt(col string, val any) QueryEncoder

+ func Gte(col string, val any) QueryEncoder

+ func In(col string, val any) QueryEncoder

+ func Lt(col string, val any) QueryEncoder

+ func Lte(col string, val any) QueryEncoder

+ func NotEq(col string, val any) QueryEncoder

+ func NotIn(col string, val any) QueryEncoder

+ func Raw(s string, args ...any) QueryEncoder

+ type Tx struct

+ func (tx *Tx) Commit(ctx ...context.Context) (err error)

+ func (tx *Tx) Deadline() (deadline time.Time, ok bool)

+ func (tx *Tx) Done() <-chan struct{}

+ func (tx *Tx) Err() error

+ func (tx *Tx) Rollback(ctx ...context.Context) (err error)

+ func (tx *Tx) Value(key any) any

+ type Values struct

+ func (r *Values) Empty() bool

+ func (r *Values) Len() int

+ func (r *Values) Value(column string, value any) *Values