db

Documentation

Index

• func Placeholders(tableFields []string) string
• func Revision(object interface{}) uint64
• func Start(host string, port int, user, password, name string) error
• type Database
• type Row
• type SQLer
• type Transaction

Functions

func Placeholders

func Placeholders(tableFields []string) string

func Revision

func Revision(object interface{}) uint64

func Start

func Start(host string, port int, user, password, name string) error

Types

type Database

type Database interface {
	Begin() (Transaction, error)
	Close() error
	Driver() driver.Driver
	Exec(query string, args ...interface{}) (sql.Result, error)
	Ping() error
	Prepare(query string) (*sql.Stmt, error)
	Query(query string, args ...interface{}) (*sql.Rows, error)
	QueryRow(query string, args ...interface{}) *sql.Row
	SetMaxIdleConns(n int)
	SetMaxOpenConns(n int)
}

We are using an interface to allow overwriting DB with a custom type. Useful for the integration tests where we don't want to open many transactions

var (
	DB Database

	Driver = "postgres"
)

type Row

type Row interface {
	Scan(dest ...interface{}) error
}

type SQLer

type SQLer interface {
	Exec(query string, args ...interface{}) (sql.Result, error)
	Query(query string, args ...interface{}) (*sql.Rows, error)
	QueryRow(query string, args ...interface{}) *sql.Row
}

Could be a connection or a transaction

type Transaction

type Transaction interface {
	Exec(query string, args ...interface{}) (sql.Result, error)
	Query(query string, args ...interface{}) (*sql.Rows, error)
	QueryRow(query string, args ...interface{}) *sql.Row
	Rollback() error
	Commit() error
}

We are using this transaction to avoid commiting twice when reusing a transaction for the integration tests