Function fetchCursorRows

tests/integration/cursor_test.go:67–86

fetchCursorRows runs a FETCH/MOVE statement on the transaction's connection (lib/pq sends it via the simple query protocol) and collects any rows it returned. Statements that return no result set yield an empty slice.

(t *testing.T, tx *sql.Tx, stmt string)

// (lib/pq sends it via the simple query protocol) and collects any rows it
// returned. Statements that return no result set yield an empty slice.
func fetchCursorRows(t *testing.T, tx *sql.Tx, stmt string) []cursorRow {
	t.Helper()
	rows, err := tx.Query(stmt)
	if err != nil {
		t.Fatalf("%s: %v", stmt, err)
	}
	defer func() { _ = rows.Close() }()
	var out []cursorRow
	for rows.Next() {
		var r cursorRow
		if err := rows.Scan(&r.id, &r.name); err != nil {
			t.Fatalf("%s: scan: %v", stmt, err)
		}
		out = append(out, r)
	}
	if err := rows.Err(); err != nil {
		t.Fatalf("%s: rows: %v", stmt, err)
	}
	return out
}

func mustExecTx(t *testing.T, tx *sql.Tx, stmt string) {
	t.Helper()