Function TestTxPgxDriver

riverdbtest/riverdbtest.go:454–469

TestTxPgxDriver starts a test transaction that's rolled back automatically as the test case is cleaning itself up. Unlike TestTxPgx, this variant takes a driver and options for greater flexibility, including allowing for Pro drivers, while still sharing common setup like schema search path.

(ctx context.Context, tb testing.TB, driver riverdriver.Driver[pgx.Tx], opts *TestTxOpts)

// driver and options for greater flexibility, including allowing for Pro
// drivers, while still sharing common setup like schema search path.
func TestTxPgxDriver(ctx context.Context, tb testing.TB, driver riverdriver.Driver[pgx.Tx], opts *TestTxOpts) (pgx.Tx, string) {
	tb.Helper()

	var optsCopy TestTxOpts
	if opts != nil {
		optsCopy = *opts
	}
	optsCopy.IsTestTxHelper = true

	tx, schema := TestTx(ctx, tb, driver, &optsCopy)

	_, err := tx.Exec(ctx, "SET search_path TO '"+schema+"'")
	require.NoError(tb, err)

	return tx, schema
}

// TestTxOpts are options for TestTx. Most of the time these can be left as nil.
type TestTxOpts struct {