postgres

Documentation

Index

• func NewPgx(conn PgxConn) *pgxConn
• func NewSQL(conn SQLConn) *dbSQL
• type Conn
• type Engine
  • func New(conn Conn, options ...Option) *Engine
  • func (pg *Engine) Build(fixtures populator.Fixtures) ([]populator.Command, error)
  • func (pg *Engine) Exec(cmds []populator.Command) error
• type Option
  • func DisableForeignKeyCheck() Option
• type PgxConn
• type Rows
• type SQLConn

Functions

func NewPgx

func NewPgx(conn PgxConn) *pgxConn

func NewSQL

func NewSQL(conn SQLConn) *dbSQL

Types

type Conn

type Conn interface {
	BeginFunc(ctx context.Context, f func(Conn) error) (err error)
	Exec(ctx context.Context, sql string, arguments ...interface{}) (int, error)
	Query(ctx context.Context, sql string, optionsAndArgs ...interface{}) (Rows, error)
}

type Engine

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

func New

func New(conn Conn, options ...Option) *Engine

func (*Engine) Build

func (pg *Engine) Build(fixtures populator.Fixtures) ([]populator.Command, error)

func (*Engine) Exec

func (pg *Engine) Exec(cmds []populator.Command) error

type Option

type Option func(*Engine)

Option defines options for Engine.

func DisableForeignKeyCheck

func DisableForeignKeyCheck() Option

type PgxConn

type PgxConn interface {
	Begin(context.Context) (pgx.Tx, error)
	Exec(ctx context.Context, sql string, arguments ...interface{}) (pgconn.CommandTag, error)
	Query(ctx context.Context, sql string, optionsAndArgs ...interface{}) (pgx.Rows, error)
}

type Rows

type Rows interface {
	Close()
	Err() error
	Next() bool
	Scan(dest ...interface{}) error
}

type SQLConn

type SQLConn interface {
	BeginTx(context.Context, *sql.TxOptions) (*sql.Tx, error)
	ExecContext(ctx context.Context, sql string, arguments ...interface{}) (sql.Result, error)
	QueryContext(ctx context.Context, sql string, optionsAndArgs ...interface{}) (*sql.Rows, error)
}