Function dbExecError

rivermigrate/river_migrate_test.go:1019–1023

A command returning an error aborts the transaction. This is a shortcut to execute a command in a subtransaction so that we can verify an error, but continue to use the original transaction.

(ctx context.Context, exec riverdriver.Executor, sql string)

// execute a command in a subtransaction so that we can verify an error, but
// continue to use the original transaction.
func dbExecError(ctx context.Context, exec riverdriver.Executor, sql string) error {
	return dbutil.WithTx(ctx, exec, func(ctx context.Context, exec riverdriver.ExecutorTx) error {
		return exec.Exec(ctx, sql)
	})
}

func driverMigrationToInt(r *riverdriver.Migration) int { return r.Version }
func migrationToInt(migration Migration) int            { return migration.Version }