postgresdb

README

postgresdb: utility library to manage a PostgreSQL database

Documentation

Index

• func OpenRawDB(ctx context.Context, rawConnstring, password string) (*sql.DB, error)
• func SequentialUpgrades(upgrades ...[]string) map[int]SchemaUpgrade
• func Transactor(transactionName string) func(context.Context, *Database, func(context.Context, *sql.Tx) error) error
• type Database
  • func (d *Database) Close() error
  • func (d *Database) PrepareExec(outErr *error, queryName, querySQL string, paramNames ...string) *PreparedExec
  • func (d *Database) PrepareInsertExec(outErr *error, tableName string, fieldNames []string) *PreparedExec
  • func (d *Database) PrepareQuery(outErr *error, queryName, querySQL string, paramNames ...string) *PreparedQuery
• type PreparedExec
  • func (p *PreparedExec) Exec(ctx context.Context, tx *sql.Tx, argmap map[string]interface{}) error
  • func (p *PreparedExec) ExecWithResult(ctx context.Context, tx *sql.Tx, argmap map[string]interface{}) (sql.Result, error)
• type PreparedQuery
  • func (p *PreparedQuery) Query(ctx context.Context, tx *sql.Tx, argmap map[string]interface{}, ...) error
• type QueryFailed
  • func (q QueryFailed) Error() string
• type Queryer
• type Schema
  • func (s *Schema) Open(ctx context.Context, rawConnstring, password string) (*Database, error)
• type SchemaUpgrade

Functions

func OpenRawDB

func OpenRawDB(ctx context.Context, rawConnstring, password string) (*sql.DB, error)

func SequentialUpgrades

func SequentialUpgrades(upgrades ...[]string) map[int]SchemaUpgrade

func Transactor

func Transactor(transactionName string) func(context.Context, *Database, func(context.Context, *sql.Tx) error) error

Types

type Database

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

func (*Database) Close

func (d *Database) Close() error

func (*Database) PrepareExec

func (d *Database) PrepareExec(outErr *error, queryName, querySQL string, paramNames ...string) *PreparedExec

func (*Database) PrepareInsertExec

func (d *Database) PrepareInsertExec(outErr *error, tableName string, fieldNames []string) *PreparedExec

func (*Database) PrepareQuery

func (d *Database) PrepareQuery(outErr *error, queryName, querySQL string, paramNames ...string) *PreparedQuery

type PreparedExec

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

func (*PreparedExec) Exec

func (p *PreparedExec) Exec(ctx context.Context, tx *sql.Tx, argmap map[string]interface{}) error

func (*PreparedExec) ExecWithResult

func (p *PreparedExec) ExecWithResult(ctx context.Context, tx *sql.Tx, argmap map[string]interface{}) (sql.Result, error)

type PreparedQuery

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

func (*PreparedQuery) Query

func (p *PreparedQuery) Query(ctx context.Context, tx *sql.Tx, argmap map[string]interface{}, dest interface{}, onrow func() (bool, error)) error

type QueryFailed

type QueryFailed struct {
	QueryName string
	Err       error
}

func (QueryFailed) Error

func (q QueryFailed) Error() string

type Queryer

type Queryer interface {
	ExecContext(ctx context.Context, query string, args ...interface{}) (sql.Result, error)
	QueryRowContext(ctx context.Context, query string, args ...interface{}) *sql.Row
	QueryContext(ctx context.Context, query string, args ...interface{}) (*sql.Rows, error)
}

type Schema

type Schema struct {
	Name           string
	Upgrades       map[int]SchemaUpgrade
	CurrentVersion int
}

func (*Schema) Open

func (s *Schema) Open(ctx context.Context, rawConnstring, password string) (*Database, error)

type SchemaUpgrade

type SchemaUpgrade struct {
	Next int
	Sql  []string
}