database

Documentation

Index

• func Exec(ctx context.Context, db DB, query string, args []interface{}) (sql.Result, error)
• func GetTable(m any) string
• func GetTableSingular(m any) string
• func Register(ctx context.Context, config Config, migrations Upper)
• func RegisterDB(ctx context.Context, db *sqlx.DB)
• func RegisterTransactions(ctx context.Context, mtx sync.Locker)
• func Value[T any](txFunc Transaction, cb func(tx *sqlx.Tx) (T, error)) (T, error)
• type Config
• type DB
• type Read
  • func NewRead(ctx context.Context, mtx sync.Locker, db DB) Read
  • func (f Read) Run(cb func(tx *sqlx.Tx) error) error
• type Tabler
• type Transaction
• type Update
  • func NewUpdate(ctx context.Context, mtx sync.Locker, db DB) Update
  • func (f Update) Run(cb func(tx *sqlx.Tx) error) error
• type Upper

Functions

func Exec

func Exec(ctx context.Context, db DB, query string, args []interface{}) (sql.Result, error)

func GetTable

func GetTable(m any) string

func GetTableSingular

func GetTableSingular(m any) string

func Register

func Register(ctx context.Context, config Config, migrations Upper)

func RegisterDB

func RegisterDB(ctx context.Context, db *sqlx.DB)

func RegisterTransactions

func RegisterTransactions(ctx context.Context, mtx sync.Locker)

func Value

func Value[T any](txFunc Transaction, cb func(tx *sqlx.Tx) (T, error)) (T, error)

Types

type Config

type Config interface {
	DriverName() string
	DataSourceName() string
}

type DB

type DB interface {
	sqlx.QueryerContext
	sqlx.ExecerContext
	DriverName() string
}

type Read

type Read func(func(tx *sqlx.Tx) error) error

func NewRead

func NewRead(ctx context.Context, mtx sync.Locker, db DB) Read

func (Read) Run

func (f Read) Run(cb func(tx *sqlx.Tx) error) error

type Tabler

type Tabler interface {
	Table() string
}

type Transaction

type Transaction interface {
	Run(func(tx *sqlx.Tx) error) error
}

type Update

type Update func(func(tx *sqlx.Tx) error) error

func NewUpdate

func NewUpdate(ctx context.Context, mtx sync.Locker, db DB) Update

func (Update) Run

func (f Update) Run(cb func(tx *sqlx.Tx) error) error

type Upper

type Upper interface {
	Up(ctx context.Context, db DB) error
}