postgres

Documentation

Index

• func NewDB(pool *pgxpool.Pool) db.Conn
• type CopyFromTx
• type DB
  • func (p *DB) Begin(ctx context.Context) (db.Tx, error)
  • func (p *DB) Exec(ctx context.Context, sql string, args ...any) (db.Result, error)
  • func (p *DB) Ping(ctx context.Context) error
  • func (p *DB) Query(ctx context.Context, sql string, args ...any) (db.Rows, error)
  • func (p *DB) QueryRow(ctx context.Context, sql string, args ...any) db.Row
• type Row
  • func (r *Row) Scan(dest ...any) error
• type Rows
  • func (r *Rows) Close() error
  • func (r *Rows) Err() error
  • func (r *Rows) Next() bool
  • func (r *Rows) Scan(dest ...any) error
• type Tx
  • func (t *Tx) Commit(ctx context.Context) error
  • func (t *Tx) CopyFrom(ctx context.Context, tableName pgx.Identifier, columnNames []string, ...) (int64, error)
  • func (t *Tx) Exec(ctx context.Context, sql string, args ...any) (db.Result, error)
  • func (t *Tx) Query(ctx context.Context, sql string, args ...any) (db.Rows, error)
  • func (t *Tx) QueryRow(ctx context.Context, sql string, args ...any) db.Row
  • func (t *Tx) Rollback(ctx context.Context) error

Functions

func NewDB

func NewDB(pool *pgxpool.Pool) db.Conn

Types

type CopyFromTx

type CopyFromTx interface {
	db.Tx
	CopyFrom(ctx context.Context, table pgx.Identifier, columns []string, source pgx.CopyFromSource) (int64, error)
}

type DB

type DB struct {
	// contains filtered or unexported fields
}

func (*DB) Begin

func (p *DB) Begin(ctx context.Context) (db.Tx, error)

func (*DB) Exec

func (p *DB) Exec(ctx context.Context, sql string, args ...any) (db.Result, error)

func (*DB) Ping

func (p *DB) Ping(ctx context.Context) error

func (*DB) Query

func (p *DB) Query(ctx context.Context, sql string, args ...any) (db.Rows, error)

func (*DB) QueryRow

func (p *DB) QueryRow(ctx context.Context, sql string, args ...any) db.Row

type Row

type Row struct {
	// contains filtered or unexported fields
}

func (*Row) Scan

func (r *Row) Scan(dest ...any) error

type Rows

type Rows struct {
	// contains filtered or unexported fields
}

func (*Rows) Close

func (r *Rows) Close() error

func (*Rows) Err

func (r *Rows) Err() error

func (*Rows) Next

func (r *Rows) Next() bool

func (*Rows) Scan

func (r *Rows) Scan(dest ...any) error

type Tx

type Tx struct {
	// contains filtered or unexported fields
}

func (*Tx) Commit

func (t *Tx) Commit(ctx context.Context) error

func (*Tx) CopyFrom

func (t *Tx) CopyFrom(
	ctx context.Context,
	tableName pgx.Identifier,
	columnNames []string,
	rowSrc pgx.CopyFromSource,
) (int64, error)

func (*Tx) Exec

func (t *Tx) Exec(ctx context.Context, sql string, args ...any) (db.Result, error)

func (*Tx) Query

func (t *Tx) Query(ctx context.Context, sql string, args ...any) (db.Rows, error)

func (*Tx) QueryRow

func (t *Tx) QueryRow(ctx context.Context, sql string, args ...any) db.Row

func (*Tx) Rollback

func (t *Tx) Rollback(ctx context.Context) error