Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ( // ErrDuplicateTransaction is the canonical error value when a Querier already has a transaction but // another transaction is being created ErrDuplicateTransaction = errors.New("Querier already has a transaction") // ErrDbMismatch is the canonical error value when a Querier's DB doesn't match the DB for creating a transaction ErrDbMismatch = errors.New("Querier DB doesn't match DB for transaction creation") )
Functions ¶
This section is empty.
Types ¶
type Querier ¶
type Querier interface {
satomic.Querier
// sqlx methods (common between sqlx.DB and sqlx.Tx)
Get(interface{}, string, ...interface{}) error
GetContext(context.Context, interface{}, string, ...interface{}) error
Select(interface{}, string, ...interface{}) error
SelectContext(context.Context, interface{}, string, ...interface{}) error
Queryx(query string, args ...interface{}) (*sqlx.Rows, error)
QueryxContext(ctx context.Context, query string, args ...interface{}) (*sqlx.Rows, error)
QueryRowx(query string, args ...interface{}) *sqlx.Row
QueryRowxContext(ctx context.Context, query string, args ...interface{}) *sqlx.Row
}
Querier provides an interface to interact with a SQL DB within an atomic transaction or savepoint
func NewQuerier ¶
func NewQuerier(ctx context.Context, db *sqlx.DB, savepointer savepointers.Savepointer, txOpts sql.TxOptions) (Querier, error)
NewQuerier creates a new Querier
Source Files
Click to show internal directories.
Click to hide internal directories.