mysql

Documentation

Index

• func NewCustomerRepository(db *sql.DB) repository.CustomerRepository
• func NewMySQLDB(ctx context.Context) (*sql.DB, error)
• func NewTransactionRepository(db *sql.DB) repository.TransactionRepository
• func TxFromCtx(ctx context.Context) *sql.Tx
• type SQLExecutor
• type TxKey
  • func CtxTxKey() TxKey

Functions

func NewCustomerRepository

func NewCustomerRepository(db *sql.DB) repository.CustomerRepository

func NewMySQLDB

func NewMySQLDB(ctx context.Context) (*sql.DB, error)

func NewTransactionRepository

func NewTransactionRepository(db *sql.DB) repository.TransactionRepository

func TxFromCtx

func TxFromCtx(ctx context.Context) *sql.Tx

Types

type SQLExecutor

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

type TxKey

type TxKey string

func CtxTxKey

func CtxTxKey() TxKey