database

Documentation

Index

• Constants
• Variables
• func NewMigrate(driver, dsn string) (*migrate.Migrate, error)
• func Open(driver, dsn string) (*sql.DB, error)
• func WithTx(ctx context.Context, tx *Tx) context.Context
• type Builder
  • func NewBuilder(driver string) Builder
  • func NewBuilderFromBase(base squirrel.StatementBuilderType) Builder
  • func (b Builder) RunWith(runner Runner) Builder
• type DB
  • func NewDB(driver, dsn string) (*DB, error)
  • func (d *DB) Begin() (*Tx, error)
  • func (d *DB) CommitFrom(ctx context.Context) error
  • func (d *DB) DriverName() string
  • func (d *DB) Exec(query string, args ...interface{}) (sql.Result, error)
  • func (d *DB) Query(query string, args ...interface{}) (*sql.Rows, error)
  • func (d *DB) RollbackFrom(ctx context.Context) error
  • func (d *DB) TxFrom(ctx context.Context) (*Tx, error)
  • func (d *DB) TxFunc(ctx context.Context, fn func(context.Context) bool) error
  • func (d *DB) WithTx(ctx context.Context) (context.Context, error)
• type Execer
• type Locker
  • func NewDriverLocker(driver string) Locker
• type NopLocker
  • func (n *NopLocker) Lock()
  • func (n *NopLocker) Unlock()
• type Queryer
• type RowScanner
• type Runner
• type Tx
  • func TxFrom(ctx context.Context) *Tx
  • func (t *Tx) Commit() error
  • func (t *Tx) Exec(query string, args ...interface{}) (sql.Result, error)
  • func (t *Tx) Query(query string, args ...interface{}) (*sql.Rows, error)
  • func (t *Tx) Rollback() error
• type Txer

Constants

const (
	TxKey ctxKey = iota
)

Variables

var (
	ErrNoTx = errors.New("Tx does not exist")
)

Functions

func NewMigrate

func NewMigrate(driver, dsn string) (*migrate.Migrate, error)

func Open

func Open(driver, dsn string) (*sql.DB, error)

func WithTx

func WithTx(ctx context.Context, tx *Tx) context.Context

Types

type Builder

type Builder struct {
	squirrel.StatementBuilderType
}

func NewBuilder

func NewBuilder(driver string) Builder

func NewBuilderFromBase

func NewBuilderFromBase(base squirrel.StatementBuilderType) Builder

func (Builder) RunWith

func (b Builder) RunWith(runner Runner) Builder

type DB

type DB struct {
	*sql.DB
	Locker

	Migrate *migrate.Migrate
	Builder Builder
	// contains filtered or unexported fields
}

func NewDB

func NewDB(driver, dsn string) (*DB, error)

func (*DB) Begin

func (d *DB) Begin() (*Tx, error)

func (*DB) CommitFrom

func (d *DB) CommitFrom(ctx context.Context) error

func (*DB) DriverName

func (d *DB) DriverName() string

func (*DB) Exec

func (d *DB) Exec(query string, args ...interface{}) (sql.Result, error)

func (*DB) Query

func (d *DB) Query(query string, args ...interface{}) (*sql.Rows, error)

func (*DB) RollbackFrom

func (d *DB) RollbackFrom(ctx context.Context) error

func (*DB) TxFrom

func (d *DB) TxFrom(ctx context.Context) (*Tx, error)

func (*DB) TxFunc

func (d *DB) TxFunc(ctx context.Context, fn func(context.Context) bool) error

func (*DB) WithTx

func (d *DB) WithTx(ctx context.Context) (context.Context, error)

type Execer

type Execer interface {
	Exec(query string, args ...interface{}) (sql.Result, error)
}

type Locker

type Locker interface {
	sync.Locker
}

func NewDriverLocker

func NewDriverLocker(driver string) Locker

type NopLocker

type NopLocker struct{}

func (*NopLocker) Lock

func (n *NopLocker) Lock()

func (*NopLocker) Unlock

func (n *NopLocker) Unlock()

type Queryer

type Queryer interface {
	Query(query string, args ...interface{}) (*sql.Rows, error)
}

type RowScanner

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

type Runner

type Runner interface {
	Queryer
	Execer
}

type Tx

type Tx struct {
	*sql.Tx
	Locker
}

func TxFrom

func TxFrom(ctx context.Context) *Tx

func (*Tx) Commit

func (t *Tx) Commit() error

func (*Tx) Exec

func (t *Tx) Exec(query string, args ...interface{}) (sql.Result, error)

func (*Tx) Query

func (t *Tx) Query(query string, args ...interface{}) (*sql.Rows, error)

func (*Tx) Rollback

func (t *Tx) Rollback() error

type Txer

type Txer interface {
	Begin() (*Tx, error)
	WithTx(context.Context) (context.Context, error)
	TxFrom(context.Context) (*Tx, error)
	TxFunc(context.Context, func(context.Context) bool) error
	CommitFrom(context.Context) error
	RollbackFrom(context.Context) error
}