pgxwrapper

package module

Go to main page

Versions in this module

v1

v1.0.7

Sep 19, 2023

Changes in this version

type PgDatabase

+ Close func() error

v1.0.6

Sep 10, 2023

Changes in this version

type DB

+ func (d *DB) DeleteSqTx(tx *sqlx.Tx, ctx context.Context, sqlizer sq.Sqlizer) error

+ func (d *DB) DeleteTx(tx *sqlx.Tx, ctx context.Context, query string, args ...interface{}) error

+ func (d *DB) ExecSqTx(tx *sqlx.Tx, ctx context.Context, sqlizer sq.Sqlizer) error

+ func (d *DB) ExecTx(tx *sqlx.Tx, ctx context.Context, query string, args ...interface{}) error

+ func (d *DB) GetSqTx(tx *sqlx.Tx, ctx context.Context, dest interface{}, sqlizer sq.Sqlizer) error

+ func (d *DB) GetTx(tx *sqlx.Tx, ctx context.Context, dest interface{}, query string, ...) error

+ func (d *DB) InsertSqTx(tx *sqlx.Tx, ctx context.Context, sqlizer sq.Sqlizer) error

+ func (d *DB) InsertTx(tx *sqlx.Tx, ctx context.Context, query string, args ...interface{}) error

+ func (d *DB) SelectSqTx(tx *sqlx.Tx, ctx context.Context, dest interface{}, sqlizer sq.Sqlizer) error

+ func (d *DB) SelectToMapSqTx(tx *sqlx.Tx, ctx context.Context, dest map[string]interface{}, ...) error

+ func (d *DB) SelectTx(tx *sqlx.Tx, ctx context.Context, dest interface{}, query string, ...) error

+ func (d *DB) UpdateSqTx(tx *sqlx.Tx, ctx context.Context, sqlizer sq.Sqlizer) error

+ func (d *DB) UpdateTx(tx *sqlx.Tx, ctx context.Context, query string, args ...interface{}) error

type PgDatabase

+ DeleteSqTx func(tx *sqlx.Tx, ctx context.Context, sqlizer sq.Sqlizer) error

+ DeleteTx func(tx *sqlx.Tx, ctx context.Context, query string, args ...interface{}) error

+ ExecSqTx func(tx *sqlx.Tx, ctx context.Context, sqlizer sq.Sqlizer) error

+ ExecTx func(tx *sqlx.Tx, ctx context.Context, query string, args ...interface{}) error

+ GetSqTx func(tx *sqlx.Tx, ctx context.Context, dest interface{}, sqlizer sq.Sqlizer) error

+ GetTx func(tx *sqlx.Tx, ctx context.Context, dest interface{}, query string, ...) error

+ InsertSqTx func(tx *sqlx.Tx, ctx context.Context, sqlizer sq.Sqlizer) error

+ InsertTx func(tx *sqlx.Tx, ctx context.Context, query string, args ...interface{}) error

+ SelectSqTx func(tx *sqlx.Tx, ctx context.Context, dest interface{}, sqlizer sq.Sqlizer) error

+ SelectToMapSqTx func(tx *sqlx.Tx, ctx context.Context, dest map[string]interface{}, ...) error

+ SelectTx func(tx *sqlx.Tx, ctx context.Context, dest interface{}, query string, ...) error

+ UpdateSqTx func(tx *sqlx.Tx, ctx context.Context, sqlizer sq.Sqlizer) error

+ UpdateTx func(tx *sqlx.Tx, ctx context.Context, query string, args ...interface{}) error

v1.0.5

Jun 14, 2023

v1.0.4

Jun 13, 2023

v1.0.3

Jun 13, 2023

Changes in this version

+ var ErrEmptyDSN = errors.New("empty dsn")

+ var ErrInvalidAttempts = errors.New("invalid attempts number, must be > 0")

+ func OptionErrorChannel(ch chan error) option

v1.0.2

Jun 8, 2023

Changes in this version

+ func OptionStartedChannel(ch chan bool) option

v1.0.1

May 21, 2023

Changes in this version

type PgDatabase

+ GetDB func() *sql.DB

+ IsActive func() bool

v1.0.0

Apr 29, 2023

Changes in this version

+ var ErrDBIsNotActive = errors.New("connect not active")

+ var ErrTooMuchAttempts = errors.New("database closed: too much attempts")

+ func OptionAttempts(a int) option

+ func OptionDSN(dsn string) option

+ func OptionEnableLogs(el bool) option

+ func OptionTicker(d time.Duration) option

+ type DB struct

+ func Open(opts ...option) *DB

+ func (d *DB) Close()

+ func (d *DB) Delete(ctx context.Context, query string, args ...interface{}) error

+ func (d *DB) DeleteSq(ctx context.Context, sqlizer sq.Sqlizer) error

+ func (d *DB) Exec(ctx context.Context, query string, args ...interface{}) error

+ func (d *DB) ExecSq(ctx context.Context, sqlizer sq.Sqlizer) error

+ func (d *DB) Get(ctx context.Context, dest interface{}, query string, args ...interface{}) error

+ func (d *DB) GetDB() *sql.DB

+ func (d *DB) GetSq(ctx context.Context, dest interface{}, sqlizer sq.Sqlizer) error

+ func (d *DB) Insert(ctx context.Context, query string, args ...interface{}) error

+ func (d *DB) InsertSq(ctx context.Context, sqlizer sq.Sqlizer) error

+ func (d *DB) IsActive() bool

+ func (d *DB) Select(ctx context.Context, dest interface{}, query string, args ...interface{}) error

+ func (d *DB) SelectSq(ctx context.Context, dest interface{}, sqlizer sq.Sqlizer) error

+ func (d *DB) SelectToMapSq(ctx context.Context, dest map[string]interface{}, sqlizer sq.Sqlizer) error

+ func (d *DB) Tx(ctx context.Context, opts *sql.TxOptions) (*sqlx.Tx, error)

+ func (d *DB) Update(ctx context.Context, query string, args ...interface{}) error

+ func (d *DB) UpdateSq(ctx context.Context, sqlizer sq.Sqlizer) error

+ type PgDatabase interface

+ Delete func(ctx context.Context, query string, args ...interface{}) error

+ DeleteSq func(ctx context.Context, sqlizer sq.Sqlizer) error

+ Exec func(ctx context.Context, query string, args ...interface{}) error

+ ExecSq func(ctx context.Context, sqlizer sq.Sqlizer) error

+ Get func(ctx context.Context, dest interface{}, query string, args ...interface{}) error

+ GetSq func(ctx context.Context, dest interface{}, sqlizer sq.Sqlizer) error

+ Insert func(ctx context.Context, query string, args ...interface{}) error

+ InsertSq func(ctx context.Context, sqlizer sq.Sqlizer) error

+ Select func(ctx context.Context, dest interface{}, query string, args ...interface{}) error

+ SelectSq func(ctx context.Context, dest interface{}, sqlizer sq.Sqlizer) error

+ SelectToMapSq func(ctx context.Context, dest map[string]interface{}, sqlizer sq.Sqlizer) error

+ Tx func(ctx context.Context, opts *sql.TxOptions) (*sqlx.Tx, error)

+ Update func(ctx context.Context, query string, args ...interface{}) error

+ UpdateSq func(ctx context.Context, sqlizer sq.Sqlizer) error

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