pg_api

Apr 16, 2025

Changes in this version

type PgDbClient

+ func (c PgDbClient) BeginTx(ctx context.Context, txOptions pgx.TxOptions) (pgx.Tx, error)

+ func (c PgDbClient) ExecDelete(ctx context.Context, builder sq.DeleteBuilder) int64

+ func (c PgDbClient) ExecUpdate(ctx context.Context, builder sq.UpdateBuilder) int64

+ func (c PgDbClient) Ping(ctx context.Context) error

+ func (c PgDbClient) QueryContextSelect(ctx context.Context, builder sq.SelectBuilder, where map[string]interface{}) pgx.Rows

+ func (c PgDbClient) QueryRowContextInsert(ctx context.Context, builder sq.InsertBuilder) pgx.Row

+ func (c PgDbClient) QueryRowContextSelect(ctx context.Context, builder sq.SelectBuilder) pgx.Row

+ func (c PgDbClient) UpdateReturning(ctx context.Context, builder sq.UpdateBuilder) pgx.Row

Apr 14, 2025

Changes in this version

type PG

+ func (pg PG) RunTransaction(ctx context.Context, txOptions transaction.TxOptions, f TransactionalFlow) error

type QueryExecutor

+ RunTransaction func(ctx context.Context, txOptions transaction.TxOptions, f TransactionalFlow) error

Apr 14, 2025

Changes in this version

+ type PgDbClient struct

+ func NewPgDBClient(ctx context.Context, dsn string) (PgDbClient, error)

+ func (c PgDbClient) API() PG

+ func (c PgDbClient) Close() error

+ func (c PgDbClient) RunTransaction(ctx context.Context, txOpts transaction.TxOptions, f TransactionalFlow) error

Apr 7, 2025

Changes in this version

+ const TxKey

+ func MakeContextTx(ctx context.Context, tx pgx.Tx) context.Context

+ type NamedQueryExecutor interface

+ ScanAllContext func(ctx context.Context, dest interface{}, q Query, args ...interface{}) error

+ ScanOneContext func(ctx context.Context, dest interface{}, q Query, args ...interface{}) error

+ type PG struct

+ API *pgxpool.Pool

+ func (pg PG) BeginTx(ctx context.Context, txOptions pgx.TxOptions) (pgx.Tx, error)

+ func (pg PG) Close()

+ func (pg PG) ExecContext(ctx context.Context, q Query, args ...interface{}) (pgconn.CommandTag, error)

+ func (pg PG) ExecDelete(ctx context.Context, builder sq.DeleteBuilder) int64

+ func (pg PG) ExecUpdate(ctx context.Context, builder sq.UpdateBuilder) int64

+ func (pg PG) Ping(ctx context.Context) error

+ func (pg PG) QueryContext(ctx context.Context, q Query, args ...interface{}) (pgx.Rows, error)

+ func (pg PG) QueryContextSelect(ctx context.Context, builder sq.SelectBuilder, where map[string]interface{}) pgx.Rows

+ func (pg PG) QueryRowContext(ctx context.Context, q Query, args ...interface{}) pgx.Row

+ func (pg PG) QueryRowContextInsert(ctx context.Context, builder sq.InsertBuilder) pgx.Row

+ func (pg PG) QueryRowContextSelect(ctx context.Context, builder sq.SelectBuilder) pgx.Row

+ func (pg PG) UpdateReturning(ctx context.Context, builder sq.UpdateBuilder) pgx.Row

+ type PgTransactionManager struct

+ func NewPgTransactionManager(db Transactor) *PgTransactionManager

+ func (m *PgTransactionManager) Transaction(ctx context.Context, opts transaction.TxOptions, fn TransactionalFlow) (err error)

+ type Pinger interface

+ Ping func(ctx context.Context) error

+ type Query struct

+ Name string

+ QueryRaw string

+ type QueryExecutor interface

+ ExecDelete func(ctx context.Context, builder squirrel.DeleteBuilder) int64

+ ExecUpdate func(ctx context.Context, builder squirrel.UpdateBuilder) int64

+ QueryContextSelect func(ctx context.Context, builder squirrel.SelectBuilder, ...) pgx.Rows

+ QueryRowContextInsert func(ctx context.Context, builder squirrel.InsertBuilder) pgx.Row

+ QueryRowContextSelect func(ctx context.Context, builder squirrel.SelectBuilder) pgx.Row

+ UpdateReturning func(ctx context.Context, builder squirrel.UpdateBuilder) pgx.Row

+ type SQLExecutor interface

+ type TransactionalFlow func(ctx context.Context) error

+ type Transactor interface

+ BeginTx func(ctx context.Context, txOptions pgx.TxOptions) (pgx.Tx, error)

+ type TxManager interface

+ Transaction func(ctx context.Context, opts transaction.TxOptions, f TransactionalFlow) error