sql

Documentation

Index

• 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) 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) GetDB() Querier
  • func (m *DBManager) WithTx(ctx context.Context, callback func(q Querier) error) error
• type Manager
• type Querier
• type Tx

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) 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) GetDB

func (m *DBManager) GetDB() Querier

func (*DBManager) WithTx

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

type Manager

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

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
}