Documentation
¶
Index ¶
- type DatabaseWrapper
- func (w *DatabaseWrapper) Begin(ctx context.Context) (TransactionWrapper, error)
- func (w *DatabaseWrapper) DB() *sql.DB
- func (w *DatabaseWrapper) ExecContext(ctx context.Context, query string, args ...any) (velum.Result, error)
- func (w *DatabaseWrapper) InTx(ctx context.Context, fn func(tx velum.Transaction) error) error
- func (w *DatabaseWrapper) IsNotFound(err error) bool
- func (w *DatabaseWrapper) QueryContext(ctx context.Context, sql string, args ...any) (velum.Rows, error)
- func (w *DatabaseWrapper) QueryRowContext(ctx context.Context, sql string, args ...any) velum.Row
- type ResultWrapper
- type RowWrapper
- type RowsWrapper
- type TransactionWrapper
- func (tx *TransactionWrapper) Commit(ctx context.Context) error
- func (tw *TransactionWrapper) ExecContext(ctx context.Context, sql string, args ...any) (velum.Result, error)
- func (tw *TransactionWrapper) QueryContext(ctx context.Context, sql string, args ...any) (velum.Rows, error)
- func (tw *TransactionWrapper) QueryRowContext(ctx context.Context, sql string, args ...any) velum.Row
- func (tx *TransactionWrapper) Rollback(ctx context.Context) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type DatabaseWrapper ¶
type DatabaseWrapper struct {
// contains filtered or unexported fields
}
func NewDatabaseWrapper ¶
func NewDatabaseWrapper(db *sql.DB) *DatabaseWrapper
func (*DatabaseWrapper) Begin ¶
func (w *DatabaseWrapper) Begin(ctx context.Context) (TransactionWrapper, error)
func (*DatabaseWrapper) DB ¶
func (w *DatabaseWrapper) DB() *sql.DB
func (*DatabaseWrapper) ExecContext ¶
func (*DatabaseWrapper) InTx ¶
func (w *DatabaseWrapper) InTx(ctx context.Context, fn func(tx velum.Transaction) error) error
func (*DatabaseWrapper) IsNotFound ¶ added in v0.0.2
func (w *DatabaseWrapper) IsNotFound(err error) bool
func (*DatabaseWrapper) QueryContext ¶
func (*DatabaseWrapper) QueryRowContext ¶
type ResultWrapper ¶
type ResultWrapper struct {
// contains filtered or unexported fields
}
func (*ResultWrapper) RowsAffected ¶
func (r *ResultWrapper) RowsAffected() (int64, error)
type RowWrapper ¶
func (*RowWrapper) Err ¶
func (rw *RowWrapper) Err() error
type RowsWrapper ¶
func (*RowsWrapper) Close ¶
func (rw *RowsWrapper) Close() error
type TransactionWrapper ¶
type TransactionWrapper struct {
// contains filtered or unexported fields
}
func (*TransactionWrapper) ExecContext ¶
func (*TransactionWrapper) QueryContext ¶
func (*TransactionWrapper) QueryRowContext ¶
Click to show internal directories.
Click to hide internal directories.