Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func WithIsolationLevel ¶
WithIsolationLevel set sql.TxOptions isolation level.
Look at sql.TxOptions.Isolation.
func WithReadOnly ¶
WithReadOnly set `ReadOnly` sql.TxOptions option.
Look at sql.TxOptions.ReadOnly.
Types ¶
type Executor ¶
type Executor interface {
Exec(query string, args ...any) (sql.Result, error)
ExecContext(ctx context.Context, query string, args ...any) (sql.Result, error)
Query(query string, args ...any) (*sql.Rows, error)
QueryContext(ctx context.Context, query string, args ...any) (*sql.Rows, error)
QueryRow(query string, args ...any) *sql.Row
QueryRowContext(ctx context.Context, query string, args ...any) *sql.Row
Prepare(query string) (*sql.Stmt, error)
PrepareContext(ctx context.Context, query string) (*sql.Stmt, error)
}
type Transactor ¶
type Transactor struct {
*oniontx.Transactor[*dbWrapper, *txWrapper, *sql.TxOptions]
}
Transactor manage a transaction for single [pgx.Conn] instance.
func NewTransactor ¶
func NewTransactor(db *sqlx.DB) *Transactor
NewTransactor returns new Transactor (sqlx implementation).
func (*Transactor) GetExecutor ¶
func (t *Transactor) GetExecutor(ctx context.Context) Executor
GetExecutor returns Executor implementation (*sqlx.DB or *sqlx.Tx default wrappers).
func (*Transactor) TryGetTx ¶
TryGetTx returns pointer of sqlx.Tx and "true" from context.Context or return `false`.
func (*Transactor) TxBeginner ¶
func (t *Transactor) TxBeginner() *sqlx.DB
TxBeginner returns pointer of sqlx.DB.
Source Files
Click to show internal directories.
Click to hide internal directories.