(aconn)
| 325 | |
| 326 | |
| 327 | async def test_fetchmany(aconn): |
| 328 | async with aconn.cursor("foo") as cur: |
| 329 | await cur.execute(ph(cur, "select generate_series(1, %s) as bar"), (5,)) |
| 330 | assert await cur.fetchmany(3) == [(1,), (2,), (3,)] |
| 331 | assert await cur.fetchone() == (4,) |
| 332 | assert await cur.fetchmany(3) == [(5,)] |
| 333 | assert await cur.fetchmany(3) == [] |
| 334 | |
| 335 | |
| 336 | async def test_fetchall(aconn): |