Function TestCursorSimpleQuery

tests/integration/cursor_test.go:191–213

TestCursorSimpleQuery exercises the simple-query-protocol cursor path against Duckgres.

(t *testing.T)

// TestCursorSimpleQuery exercises the simple-query-protocol cursor path
// against Duckgres.
func TestCursorSimpleQuery(t *testing.T) {
	db := testHarness.DuckgresDB

	t.Run("lifecycle_fetch_close", func(t *testing.T) { cursorLifecycleFlow(t, db) })
	t.Run("move_advances_position", func(t *testing.T) { cursorMoveFlow(t, db) })
	t.Run("backward_fetch_rejected", func(t *testing.T) { cursorBackwardFlow(t, db) })
	t.Run("missing_cursor_errors", func(t *testing.T) { cursorMissingFlow(t, db) })

	t.Run("redeclare_replaces_cursor", func(t *testing.T) {
		tx := beginCursorTx(t, db)

		mustExecTx(t, tx, "DECLARE cur_redeclare CURSOR FOR SELECT id, name FROM users ORDER BY id")
		assertCursorRows(t, "FETCH 2", fetchCursorRows(t, tx, "FETCH 2 FROM cur_redeclare"), cursorUsers(1, 2))

		// Re-DECLARE with the same name replaces the cursor: the next FETCH
		// reads the new query from the start. Deliberate divergence: real
		// PostgreSQL raises 42P03 duplicate_cursor here.
		mustExecTx(t, tx, "DECLARE cur_redeclare CURSOR FOR SELECT id, name FROM users WHERE id >= 9 ORDER BY id")
		assertCursorRows(t, "FETCH ALL after re-DECLARE", fetchCursorRows(t, tx, "FETCH ALL FROM cur_redeclare"), cursorUsers(9, 10))

		mustExecTx(t, tx, "CLOSE cur_redeclare")
	})
}

// TestCursorPostgresParity runs the shared cursor flows against the
// comparison PostgreSQL 16 instance, keeping the expectations in the flows