sql

Documentation

Index

• func Exec(ctx context.Context, q Querier, qb squirrel.Sqlizer) (int64, error)
• func Get[T any](ctx context.Context, q Querier, qb squirrel.Sqlizer) (T, error)
• func Select[T any](ctx context.Context, q Querier, qb squirrel.Sqlizer) ([]T, error)
• type DB
• type DBConn
  • func NewDB(ctx context.Context, config config) (*DBConn, error)
  • func NewDBFromSqlx(db *sqlx.DB) (*DBConn, error)
  • func NewDBWithOTel(ctx context.Context, cfg config) (*DBConn, error)
  • func (db *DBConn) BeginTx(ctx context.Context, opts *sql.TxOptions) (Tx, error)
  • func (db *DBConn) Close() error
  • func (db *DBConn) ExecContext(ctx context.Context, query string, args ...any) (sql.Result, error)
  • func (db *DBConn) GetContext(ctx context.Context, dest any, query string, args ...any) error
  • func (db *DBConn) GetSQLX() *sqlx.DB
  • func (db *DBConn) SelectContext(ctx context.Context, dest any, query string, args ...any) error
• type DBManager
  • func NewManager(db DB) *DBManager
  • func (m *DBManager) GetQuerier(ctx context.Context) Querier
  • func (m *DBManager) WithTx(ctx context.Context, callback func(context.Context) error) error
• type Manager
• type Querier
• type Tx

Functions

func Exec

func Exec(ctx context.Context, q Querier, qb squirrel.Sqlizer) (int64, error)

func Get

func Get[T any](ctx context.Context, q Querier, qb squirrel.Sqlizer) (T, error)

func Select

func Select[T any](ctx context.Context, q Querier, qb squirrel.Sqlizer) ([]T, error)

Types

type DB

type DB interface {
	Querier
	GetSQLX() *sqlx.DB
	BeginTx(ctx context.Context, opts *sql.TxOptions) (Tx, error)
}

type DBConn

type DBConn struct {
	// contains filtered or unexported fields
}

func NewDB

func NewDB(ctx context.Context, config config) (*DBConn, error)

func NewDBFromSqlx

func NewDBFromSqlx(db *sqlx.DB) (*DBConn, error)

func NewDBWithOTel

func NewDBWithOTel(ctx context.Context, cfg config) (*DBConn, error)

func (*DBConn) BeginTx

func (db *DBConn) BeginTx(ctx context.Context, opts *sql.TxOptions) (Tx, error)

func (*DBConn) Close

func (db *DBConn) Close() error

func (*DBConn) ExecContext

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

func (*DBConn) GetContext

func (db *DBConn) GetContext(ctx context.Context, dest any, query string, args ...any) error

func (*DBConn) GetSQLX

func (db *DBConn) GetSQLX() *sqlx.DB

func (*DBConn) SelectContext

func (db *DBConn) SelectContext(ctx context.Context, dest any, query string, args ...any) error

type DBManager

type DBManager struct {
	// contains filtered or unexported fields
}

func NewManager

func NewManager(db DB) *DBManager

func (*DBManager) GetQuerier

func (m *DBManager) GetQuerier(ctx context.Context) Querier

func (*DBManager) WithTx

func (m *DBManager) WithTx(ctx context.Context, callback func(context.Context) error) error

type Manager

type Manager interface {
	WithTx(ctx context.Context, callback func(context.Context) error) error
	GetQuerier(ctx context.Context) Querier
}

type Querier

type Querier interface {
	GetContext(ctx context.Context, dest any, query string, args ...any) error
	SelectContext(ctx context.Context, dest any, query string, args ...any) error
	ExecContext(ctx context.Context, query string, args ...any) (sql.Result, error)
}

type Tx

type Tx interface {
	Querier
	Commit() error
	Rollback() error
}