db

Documentation

Index

• type DBConn
  • func NewDBConn(ctx context.Context, c config.DB) (*DBConn, error)
  • func (conn *DBConn) ExecContext(ctx context.Context, query string, args ...any) (sql.Result, error)
  • func (conn *DBConn) NamedExecContext(ctx context.Context, query string, arg interface{}) (sql.Result, error)
  • func (conn *DBConn) QueryxContext(ctx context.Context, query string, args ...any) (*sqlx.Rows, error)
  • func (conn *DBConn) RunInTx(ctx context.Context, run func(ctx context.Context) error) error
  • func (conn *DBConn) SelectContext(ctx context.Context, dest interface{}, query string, args ...interface{}) error
• type Logger
• type Transactioner
• type Tx
  • func ExtractTransactionFromContext(ctx context.Context) *Tx

Types

type DBConn

type DBConn struct {
	*sqlx.DB
}

func NewDBConn

func NewDBConn(ctx context.Context, c config.DB) (*DBConn, error)

func (*DBConn) ExecContext

func (conn *DBConn) ExecContext(ctx context.Context, query string, args ...any) (sql.Result, error)

func (*DBConn) NamedExecContext

func (conn *DBConn) NamedExecContext(ctx context.Context, query string, arg interface{}) (sql.Result, error)

func (*DBConn) QueryxContext

func (conn *DBConn) QueryxContext(ctx context.Context, query string, args ...any) (*sqlx.Rows, error)

func (*DBConn) RunInTx

func (conn *DBConn) RunInTx(ctx context.Context, run func(ctx context.Context) error) error

func (*DBConn) SelectContext

func (conn *DBConn) SelectContext(ctx context.Context, dest interface{}, query string, args ...interface{}) error

type Logger

type Logger struct {
	*log.Logger
}

type Transactioner

type Transactioner interface {
	storage.Queryer
	RunInTx(context.Context, func(ctx context.Context) error) error
}

type Tx

type Tx struct {
	*sqlx.Tx
}

func ExtractTransactionFromContext

func ExtractTransactionFromContext(ctx context.Context) *Tx