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 Value[T any](txFunc Transaction, cb func(tx *sqlx.Tx) (T, error)) (T, error)
• type Config
• type DB
• type DBConfiger
• 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

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 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
	SetDialect()
}

type DB

type DB interface {
	sqlx.QueryerContext
	sqlx.ExecerContext
}

type DBConfiger

type DBConfiger interface {
	DBConfig() Config
}

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