db

Documentation

Index

• Variables
• func StoreTx(ctx context.Context, tx *sql.Tx) context.Context
• type App
  • func New(config Config) (App, error)
  • func NewFromSQL(db *sql.DB) App
• type Config
  • func Flags(fs *flag.FlagSet, prefix string, overrides ...flags.Override) Config

Variables

var (
	// ErrNoHost occurs when host is not provided in configuration
	ErrNoHost = errors.New("no host for database connection")

	// ErrNoTransaction occurs when no transaction is provided but needed
	ErrNoTransaction = errors.New("no transaction in context, please wrap with DoAtomic()")

	// ErrBulkEnded occurs when bulk creation is over
	ErrBulkEnded = errors.New("no more data to copy")

	// SQLTimeout when running queries
	SQLTimeout = time.Second * 5
)

Functions

func StoreTx

func StoreTx(ctx context.Context, tx *sql.Tx) context.Context

StoreTx stores given transaction in context

Types

type App

type App interface {
	Ping() error
	Close() error
	DoAtomic(ctx context.Context, action func(context.Context) error) error
	List(ctx context.Context, scanner func(*sql.Rows) error, query string, args ...interface{}) error
	Get(ctx context.Context, scanner func(*sql.Row) error, query string, args ...interface{}) error
	Create(ctx context.Context, query string, args ...interface{}) (uint64, error)
	Exec(ctx context.Context, query string, args ...interface{}) error
	Bulk(ctx context.Context, feeder func(*sql.Stmt) error, schema, table string, columns ...string) error
}

App of package

func New

func New(config Config) (App, error)

New creates new App from Config

func NewFromSQL

func NewFromSQL(db *sql.DB) App

NewFromSQL creates a db wrapper

type Config

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

Config of package

func Flags

func Flags(fs *flag.FlagSet, prefix string, overrides ...flags.Override) Config

Flags adds flags for configuring package