database

package

Go to main page

Versions in this module

v0

v0.0.7

Dec 7, 2023

v0.0.6

Jun 16, 2023

v0.0.5

Jun 9, 2023

Changes in this version

+ func QueryRow(db Db, ctx context.Context, sql string, ...) (*T, error)

v0.0.4

Jun 8, 2023

v0.0.3

Jun 1, 2023

Changes in this version

type Dummy

+ Tx *DummyTx

+ type DummyTx struct

+ CalledCommit bool

+ CalledRollback bool

+ ExecError error

+ QueryRowResponse pgx.Row

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

+ func (td *DummyTx) Commit(ctx context.Context) error

+ func (td *DummyTx) Conn() *pgx.Conn

+ func (td *DummyTx) CopyFrom(ctx context.Context, tableName pgx.Identifier, columnNames []string, ...) (int64, error)

+ func (td *DummyTx) Exec(ctx context.Context, sql string, arguments ...any) (commandTag pgconn.CommandTag, err error)

+ func (td *DummyTx) LargeObjects() pgx.LargeObjects

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

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

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

+ func (td *DummyTx) Rollback(ctx context.Context) error

+ func (td *DummyTx) SendBatch(ctx context.Context, b *pgx.Batch) pgx.BatchResults

v0.0.2

May 30, 2023

Changes in this version

+ func Query(db Db, ctx context.Context, sql string, f func(row pgx.Rows) (*T, error), ...) ([]*T, error)

v0.0.1

May 22, 2023

Changes in this version

+ type Db interface

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

+ Close func()

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

+ Ping func(ctx context.Context) error

+ Pool func() *pgxpool.Pool

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

+ QueryInt func(ctx context.Context, sql string, args ...interface{}) (int64, error)

+ QueryRow func(ctx context.Context, sql string, args ...interface{}) pgx.Row

+ func New(ctx context.Context, host, port, user, password, dbName string, opts ...Option) Db

+ type Dummy struct

+ ExecCalls int

+ QueryCalls int

+ QueryRowCalls int

+ Responses []*Resp

+ func NewDummy() *Dummy

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

+ func (d *Dummy) Close()

+ func (d *Dummy) Exec(ctx context.Context, sql string, args ...interface{}) (pgconn.CommandTag, error)

+ func (d *Dummy) Ping(ctx context.Context) error

+ func (d *Dummy) Pool() *pgxpool.Pool

+ func (d *Dummy) Query(ctx context.Context, sql string, args ...interface{}) (pgx.Rows, error)

+ func (d *Dummy) QueryInt(ctx context.Context, sql string, args ...interface{}) (int64, error)

+ func (d *Dummy) QueryRow(ctx context.Context, sql string, args ...interface{}) pgx.Row

+ type Option func(db *Postgres)

+ func WithConnectionTimeout(timeout time.Duration) Option

+ func WithHealthCheckPeriod(period time.Duration) Option

+ func WithMaxConnections(maxConnections int32) Option

+ func WithTLSConfig(tlsConf *tls.Config) Option

+ type Postgres struct

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

+ func (d *Postgres) Close()

+ func (d *Postgres) Exec(ctx context.Context, sql string, args ...interface{}) (pgconn.CommandTag, error)

+ func (d *Postgres) Ping(ctx context.Context) error

+ func (d *Postgres) Pool() *pgxpool.Pool

+ func (d *Postgres) Query(ctx context.Context, sql string, args ...interface{}) (pgx.Rows, error)

+ func (d *Postgres) QueryInt(ctx context.Context, sql string, args ...interface{}) (int64, error)

+ func (d *Postgres) QueryRow(ctx context.Context, sql string, args ...interface{}) pgx.Row

+ type Resp struct

+ Data interface{}

+ Err error

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