pgx

README

pgx

PGX (github.com/jackc/pgx/v5) that implements github.com/gopsql/db.

Documentation

Index

• func MustOpen(conn string) db.DB
• func Open(conn string) (db.DB, error)
• type DB
  • func (d *DB) BeginTx(ctx context.Context, isolationLevel string, readOnly bool) (db.Tx, error)
  • func (d *DB) Close() error
  • func (d *DB) DriverName() string
  • func (d *DB) ErrGetCode(err error) string
  • func (d *DB) ErrNoRows() error
  • func (d *DB) Exec(query string, args ...interface{}) (db.Result, error)
  • func (d *DB) ExecContext(ctx context.Context, query string, args ...interface{}) (db.Result, error)
  • func (d *DB) Query(query string, args ...interface{}) (db.Rows, error)
  • func (d *DB) QueryContext(ctx context.Context, query string, args ...interface{}) (db.Rows, error)
  • func (d *DB) QueryRow(query string, args ...interface{}) db.Row
  • func (d *DB) QueryRowContext(ctx context.Context, query string, args ...interface{}) db.Row
• type Result
  • func (r Result) RowsAffected() (int64, error)
• type Rows
  • func (r *Rows) Close() error
  • func (r *Rows) Columns() ([]string, error)
• type Tx
  • func (t *Tx) Commit(ctx context.Context) error
  • func (t *Tx) ExecContext(ctx context.Context, query string, args ...interface{}) (db.Result, error)
  • func (t *Tx) QueryContext(ctx context.Context, query string, args ...interface{}) (db.Rows, error)
  • func (t *Tx) QueryRowContext(ctx context.Context, query string, args ...interface{}) db.Row
  • func (t *Tx) Rollback(ctx context.Context) error

Functions

func MustOpen

func MustOpen(conn string) db.DB

MustOpen is like Open but panics if connect operation fails.

func Open

func Open(conn string) (db.DB, error)

Open creates and establishes one connection to database.

Types

type DB

type DB struct {
	*pgxpool.Pool
}

func (*DB) BeginTx

func (d *DB) BeginTx(ctx context.Context, isolationLevel string, readOnly bool) (db.Tx, error)

func (*DB) Close

func (d *DB) Close() error

func (*DB) DriverName

func (d *DB) DriverName() string

func (*DB) ErrGetCode

func (d *DB) ErrGetCode(err error) string

func (*DB) ErrNoRows

func (d *DB) ErrNoRows() error

func (*DB) Exec

func (d *DB) Exec(query string, args ...interface{}) (db.Result, error)

func (*DB) ExecContext

func (d *DB) ExecContext(ctx context.Context, query string, args ...interface{}) (db.Result, error)

func (*DB) Query

func (d *DB) Query(query string, args ...interface{}) (db.Rows, error)

func (*DB) QueryContext

func (d *DB) QueryContext(ctx context.Context, query string, args ...interface{}) (db.Rows, error)

func (*DB) QueryRow

func (d *DB) QueryRow(query string, args ...interface{}) db.Row

func (*DB) QueryRowContext

func (d *DB) QueryRowContext(ctx context.Context, query string, args ...interface{}) db.Row

type Result

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

func (Result) RowsAffected

func (r Result) RowsAffected() (int64, error)

type Rows

type Rows struct {
	pgx.Rows
}

func (*Rows) Close

func (r *Rows) Close() error

func (*Rows) Columns

func (r *Rows) Columns() ([]string, error)

type Tx

type Tx struct {
	pgx.Tx
}

func (*Tx) Commit

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

func (*Tx) ExecContext

func (t *Tx) ExecContext(ctx context.Context, query string, args ...interface{}) (db.Result, error)

func (*Tx) QueryContext

func (t *Tx) QueryContext(ctx context.Context, query string, args ...interface{}) (db.Rows, error)

func (*Tx) QueryRowContext

func (t *Tx) QueryRowContext(ctx context.Context, query string, args ...interface{}) db.Row

func (*Tx) Rollback

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