Function beginCursorTx

tests/integration/cursor_test.go:95–103

(t *testing.T, db *sql.DB)

}

func beginCursorTx(t *testing.T, db *sql.DB) *sql.Tx {
	t.Helper()
	tx, err := db.Begin()
	if err != nil {
		t.Fatalf("BEGIN: %v", err)
	}
	t.Cleanup(func() { _ = tx.Rollback() })
	return tx
}

// cursorLifecycleFlow covers DECLARE → FETCH n → FETCH n (position advances) →
// FETCH ALL (drains the rest) → FETCH on exhausted cursor (zero rows) →