assert list(stream) == recs
-@pytest.mark.parametrize("count", [1])
-def test_results_after_execute(conn, count):
- with conn.cursor() as cur:
- cur.execute(";".join(["select 1"] * count))
- assert list(cur.results()) == [cur] * count
+def test_results_after_execute(conn):
+ with conn.cursor("test") as cur:
+ cur.execute("select 1")
+ assert list(cur.results()) == [cur]
assert await alist(stream) == recs
-@pytest.mark.parametrize("count", [1])
-async def test_results_after_execute(aconn, count):
- async with aconn.cursor() as cur:
- await cur.execute(";".join(["select 1"] * count))
- assert await alist(cur.results()) == [cur] * count
+async def test_results_after_execute(aconn):
+ async with aconn.cursor("test") as cur:
+ await cur.execute("select 1")
+ assert await alist(cur.results()) == [cur]