tx

type Closure func(context.Context, *sql.Tx) error

type Middleware func(Closure) Closure

type Opener interface {
	BeginTx(context.Context, *sql.TxOptions) (*sql.Tx, error)
}

type Transactor interface {
	// InTx executes the given closure within a transaction. The transaction is
	// committed if the closure returns nil, otherwise it is rolled back. It is
	// important that the closure does not commit or rollback the transaction as
	// this is handled by the transactor automatically. Recursively calling InTx
	// will re-use the same transaction.
	InTx(context.Context, Closure) error
}

type TransactorOptions struct {
	// sql.TxOptions to pass the opener when it begins a transaction. This does
	// not apply to new savepoint transactions (only the root transaction).
	BeginOptions *sql.TxOptions
	// Middlewares to execute before and after the closure. The middlewares are
	// executed in the order they are passed. The middlewares are executed only
	// once per opened transaction, not for each recursive call to InTx.
	BeginMiddlewares []Middleware
	// If true, the transactor will use savepoints to create nested transactions.
	// Make sure the database supports savepoints before enabling this option.
	EnableSavepoints bool
}