lpgx

package module

Go to main page

Versions in this module

v0

v0.21.0

Jun 13, 2024

v0.20.0

Jun 13, 2024

v0.11.8

Jun 12, 2024

Changes in this version

+ type Querier = lpgxt.Querier

v0.11.7

Jun 12, 2024

v0.11.6

Jun 12, 2024

Changes in this version

+ type StmtConn = lpgxt.Stmt[*pgx.Conn]

+ type StmtPoolTx = lpgxt.Stmt[*pgxpool.Tx]

+ type StmtTx = lpgxt.Stmt[pgx.Tx]

v0.11.5

Jun 12, 2024

Changes in this version

+ type PGXQuerierPoolConn interface

+ type PoolConn = PoolConnT[*pgxpool.Conn]

+ func NewPoolConn(conn *pgxpool.Conn, options ...Option) *PoolConn

+ type PoolConnT struct

+ func NewPoolConnT[T PGXQuerierPoolConn](querier T, options ...Option) *PoolConnT[T]

+ func (d *PoolConnT[T]) BeginTx(ctx context.Context, txOptions pgx.TxOptions) (*TxT[pgx.Tx], error)

+ func (d PoolConnT) Exec(ctx context.Context, query litsql.Query, params any) (pgconn.CommandTag, error)

+ func (d PoolConnT) Handler() T

+ func (d PoolConnT) Query(ctx context.Context, query litsql.Query, params any) (pgx.Rows, error)

+ func (d PoolConnT) QueryRow(ctx context.Context, query litsql.Query, params any) (pgx.Row, error)

+ type QuerierPoolConn = QuerierPoolConnT[*pgxpool.Conn]

+ type QuerierPoolConnT interface

+ BeginTx func(ctx context.Context, opts pgx.TxOptions) (*TxT[pgx.Tx], error)

+ type QuerierPoolTx = QuerierTxT[*pgxpool.Tx]

v0.11.4

Jun 12, 2024

Changes in this version

+ type Conn = ConnT[*pgx.Conn]

+ func NewConn(conn *pgx.Conn, options ...Option) *Conn

+ type ConnT struct

+ func NewConnT[T PGXQuerierConn](querier T, options ...Option) *ConnT[T]

+ func (d *ConnT[T]) BeginTx(ctx context.Context, txOptions pgx.TxOptions) (*TxT[pgx.Tx], error)

+ func (d ConnT) Prepare(ctx context.Context, name string, query litsql.Query) (*Stmt[T], error)

+ type PGXQuerierConn interface

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

+ type PGXQuerierPool interface

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

+ type PGXQuerierWithPrepare interface

+ Prepare func(ctx context.Context, name, sql string) (sd *pgconn.StatementDescription, err error)

+ type Pool = PoolT[*pgxpool.Pool]

+ func NewPool(conn *pgxpool.Pool, options ...Option) *Pool

+ type PoolT struct

+ func NewPoolT[T PGXQuerierPool](querier T, options ...Option) *PoolT[T]

+ func (d *PoolT[T]) BeginTx(ctx context.Context, txOptions pgx.TxOptions) (*TxT[pgx.Tx], error)

+ func (d PoolT) Exec(ctx context.Context, query litsql.Query, params any) (pgconn.CommandTag, error)

+ func (d PoolT) Handler() T

+ func (d PoolT) Query(ctx context.Context, query litsql.Query, params any) (pgx.Rows, error)

+ func (d PoolT) QueryRow(ctx context.Context, query litsql.Query, params any) (pgx.Row, error)

+ type QuerierConn = QuerierConnT[*pgx.Conn]

+ type QuerierConnT interface

+ BeginTx func(ctx context.Context, opts pgx.TxOptions) (*TxT[pgx.Tx], error)

+ type QuerierPool = QuerierPoolT[*pgxpool.Pool]

+ type QuerierPoolT interface

+ BeginTx func(ctx context.Context, opts pgx.TxOptions) (*TxT[pgx.Tx], error)

+ type QuerierWithPrepareT interface

+ Prepare func(ctx context.Context, name string, query litsql.Query) (*Stmt[T], error)

v0.11.3

Jun 12, 2024

Changes in this version

type DBT

+ func (d DBT) Exec(ctx context.Context, query litsql.Query, params any) (pgconn.CommandTag, error)

+ func (d DBT) Handler() T

+ func (d DBT) Prepare(ctx context.Context, name string, query litsql.Query) (*Stmt[T], error)

+ func (d DBT) Query(ctx context.Context, query litsql.Query, params any) (pgx.Rows, error)

+ func (d DBT) QueryRow(ctx context.Context, query litsql.Query, params any) (pgx.Row, error)

type TxT

+ func (d TxT) Exec(ctx context.Context, query litsql.Query, params any) (pgconn.CommandTag, error)

+ func (d TxT) Handler() T

+ func (d TxT) Prepare(ctx context.Context, name string, query litsql.Query) (*Stmt[T], error)

+ func (d TxT) Query(ctx context.Context, query litsql.Query, params any) (pgx.Rows, error)

+ func (d TxT) QueryRow(ctx context.Context, query litsql.Query, params any) (pgx.Row, error)

v0.11.2

Jun 11, 2024

v0.11.1

Jun 11, 2024

Changes in this version

+ type BaseQuerier struct

+ func NewBaseQuerier[T PGXQuerier](querier T, options ...Option) *BaseQuerier[T]

+ func (d *BaseQuerier[T]) Exec(ctx context.Context, query litsql.Query, params any) (pgconn.CommandTag, error)

+ func (d *BaseQuerier[T]) Handler() T

+ func (d *BaseQuerier[T]) Prepare(ctx context.Context, name string, query litsql.Query) (*Stmt[T], error)

+ func (d *BaseQuerier[T]) Query(ctx context.Context, query litsql.Query, params any) (pgx.Rows, error)

+ func (d *BaseQuerier[T]) QueryRow(ctx context.Context, query litsql.Query, params any) (pgx.Row, error)

+ type DB = DBT[*pgx.Conn]

+ func NewDB(db *pgx.Conn, options ...Option) *DB

+ type DBT struct

+ func NewDBT[T PGXQuerierDB](querier T, options ...Option) *DBT[T]

+ func (d *DBT[T]) BeginTx(ctx context.Context, txOptions pgx.TxOptions) (*TxT[pgx.Tx], error)

+ type Option func(options *dbOptions)

+ func WithQueryHandler(queryHandler sq.Handler) Option

+ type PGXQuerier interface

+ Exec func(ctx context.Context, sql string, args ...any) (commandTag pgconn.CommandTag, err error)

+ Prepare func(ctx context.Context, name, sql string) (sd *pgconn.StatementDescription, err error)

+ Query func(ctx context.Context, sql string, args ...any) (pgx.Rows, error)

+ QueryRow func(ctx context.Context, sql string, args ...any) pgx.Row

+ type PGXQuerierDB interface

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

+ type PGXQuerierTx interface

+ Begin func(ctx context.Context) (pgx.Tx, error)

+ Commit func(ctx context.Context) error

+ Rollback func(ctx context.Context) error

+ type QuerierDB = QuerierDBT[*pgx.Conn, pgx.Tx]

+ type QuerierDBT interface

+ BeginTx func(ctx context.Context, opts pgx.TxOptions) (*TxT[TT], error)

+ type QuerierStmt = QuerierStmtT

+ type QuerierStmtT interface

+ Exec func(ctx context.Context, params any) (pgconn.CommandTag, error)

+ Query func(ctx context.Context, params any) (pgx.Rows, error)

+ QueryRow func(ctx context.Context, params any) (pgx.Row, error)

+ type QuerierT interface

+ Exec func(ctx context.Context, query litsql.Query, params any) (pgconn.CommandTag, error)

+ Prepare func(ctx context.Context, name string, query litsql.Query) (*Stmt[ST], error)

+ Query func(ctx context.Context, query litsql.Query, params any) (pgx.Rows, error)

+ QueryRow func(ctx context.Context, query litsql.Query, params any) (pgx.Row, error)

+ type QuerierTx = QuerierTxT[pgx.Tx]

+ type QuerierTxT interface

+ Begin func(ctx context.Context) (*TxT[ST], error)

+ Commit func(ctx context.Context) error

+ Rollback func(ctx context.Context) error

+ type Stmt struct

+ func NewStmt[T PGXQuerier](querier T, desc *pgconn.StatementDescription, args []any, options ...Option) *Stmt[T]

+ func (d *Stmt[T]) Exec(ctx context.Context, params any) (pgconn.CommandTag, error)

+ func (d *Stmt[T]) Handler() PGXQuerier

+ func (d *Stmt[T]) Query(ctx context.Context, params any) (pgx.Rows, error)

+ func (d *Stmt[T]) QueryRow(ctx context.Context, params any) (pgx.Row, error)

+ type Tx = TxT[pgx.Tx]

+ func NewTx(tx pgx.Tx, options ...Option) *Tx

+ type TxT struct

+ func NewTxT[T PGXQuerierTx](querier T, options ...Option) *TxT[T]

+ func (d *TxT[T]) Begin(ctx context.Context) (*TxT[pgx.Tx], error)

+ func (d *TxT[T]) Commit(ctx context.Context) error

+ func (d *TxT[T]) Rollback(ctx context.Context) error

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL