Function cursorLifecycleFlow

tests/integration/cursor_test.go:108–129

cursorLifecycleFlow covers DECLARE → FETCH n → FETCH n (position advances) → FETCH ALL (drains the rest) → FETCH on exhausted cursor (zero rows) → CLOSE → FETCH after CLOSE (clean missing-cursor error).

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

// FETCH ALL (drains the rest) → FETCH on exhausted cursor (zero rows) →
// CLOSE → FETCH after CLOSE (clean missing-cursor error).
func cursorLifecycleFlow(t *testing.T, db *sql.DB) {
	tx := beginCursorTx(t, db)

	mustExecTx(t, tx, "DECLARE cur_lifecycle CURSOR FOR SELECT id, name FROM users ORDER BY id")

	assertCursorRows(t, "FETCH 3", fetchCursorRows(t, tx, "FETCH 3 FROM cur_lifecycle"), cursorUsers(1, 3))
	assertCursorRows(t, "FETCH 3 (resumes)", fetchCursorRows(t, tx, "FETCH 3 FROM cur_lifecycle"), cursorUsers(4, 6))
	assertCursorRows(t, "FETCH ALL", fetchCursorRows(t, tx, "FETCH ALL FROM cur_lifecycle"), cursorUsers(7, 10))
	// An exhausted cursor returns zero rows, not an error.
	assertCursorRows(t, "FETCH 3 (exhausted)", fetchCursorRows(t, tx, "FETCH 3 FROM cur_lifecycle"), nil)

	mustExecTx(t, tx, "CLOSE cur_lifecycle")

	rows, err := tx.Query("FETCH 3 FROM cur_lifecycle")
	if err == nil {
		_ = rows.Close()
		t.Fatal("FETCH after CLOSE succeeded, want missing-cursor error")
	}
	if !strings.Contains(err.Error(), `cursor "cur_lifecycle" does not exist`) {
		t.Errorf("FETCH after CLOSE: error = %q, want it to mention the missing cursor", err)
	}
}

// cursorMoveFlow covers MOVE n advancing the position without returning rows.
func cursorMoveFlow(t *testing.T, db *sql.DB) {