database

Documentation

Index

• func ClosePool() error
• func InitPool() error
• type Conn
  • func Pool() Conn
• type ConnPool
  • func New(driver string, conn string) (*ConnPool, error)
  • func (c ConnPool) Begin() (TxConn, error)
  • func (c ConnPool) Transaction(f func(TxConn) error) error
• type TxConn
• type TxDatabase
  • func (db TxDatabase) ExecContext(ctx context.Context, query string, args ...interface{}) *sql.Row

Functions

func ClosePool

func ClosePool() error

func InitPool

func InitPool() error

Types

type Conn

type Conn interface {
	GetContext(ctx context.Context, dest interface{}, query string, args ...interface{}) error
	SelectContext(ctx context.Context, dest interface{}, query string, args ...interface{}) error
	Begin() (TxConn, error)
	Transaction(func(TxConn) error) error
	Close() error
}

func Pool

func Pool() Conn

type ConnPool

type ConnPool struct {
	*sqlx.DB
}

func New

func New(driver string, conn string) (*ConnPool, error)

func (ConnPool) Begin

func (c ConnPool) Begin() (TxConn, error)

func (ConnPool) Transaction

func (c ConnPool) Transaction(f func(TxConn) error) error

type TxConn

type TxConn interface {
	Conn
	ExecContext(ctx context.Context, query string, args ...interface{}) *sql.Row
	Commit() error
	Rollback() error
}

type TxDatabase

type TxDatabase struct {
	ConnPool
	*sqlx.Tx
}

func (TxDatabase) ExecContext

func (db TxDatabase) ExecContext(ctx context.Context, query string, args ...interface{}) *sql.Row