dbpgx

Documentation

Index

• Variables
• func NewMigrator(db *pgx.Conn) schemadance.Migrator
• func TestMigrations(t *testing.T)
• type Checker
  • func (c Checker) Fingerprint() (string, error)
  • func (c Checker) Version(prefix string) (int, error)
• type Db
  • func (d Db) Begin(ctx context.Context) (schemadance.Tx, error)
  • func (d Db) Close(ctx context.Context) error
  • func (d Db) Initialize(ctx context.Context) error
• type Tx
  • func (t Tx) Commit(ctx context.Context) error
  • func (t Tx) Exec(ctx context.Context, sql string) error
  • func (t Tx) Rollback(ctx context.Context) error
  • func (t Tx) SetVersion(ctx context.Context, prefix string, version int) error
  • func (t Tx) Version(ctx context.Context, prefix string) (int, error)

Variables

var CreateDbUrl = "postgresqql://localhost/postgres"

var ScratchDatabaseUrl = "postgresql://localhost/scratch_db"

Functions

func NewMigrator

func NewMigrator(db *pgx.Conn) schemadance.Migrator

func TestMigrations

func TestMigrations(t *testing.T)

Types

type Checker

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

func (Checker) Fingerprint

func (c Checker) Fingerprint() (string, error)

func (Checker) Version

func (c Checker) Version(prefix string) (int, error)

type Db

type Db struct {
	*pgx.Conn
}

func (Db) Begin

func (d Db) Begin(ctx context.Context) (schemadance.Tx, error)

func (Db) Close

func (d Db) Close(ctx context.Context) error

func (Db) Initialize

func (d Db) Initialize(ctx context.Context) error

type Tx

type Tx struct {
	pgx.Tx
}

func (Tx) Commit

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

func (Tx) Exec

func (t Tx) Exec(ctx context.Context, sql string) error

func (Tx) Rollback

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

func (Tx) SetVersion

func (t Tx) SetVersion(ctx context.Context, prefix string, version int) error

func (Tx) Version

func (t Tx) Version(ctx context.Context, prefix string) (int, error)