Method test_cursor_iterable_06

tests/test_cursor.py:83–101

(self)

                        pass

    async def test_cursor_iterable_06(self):
        recs = []

        async with self.con.transaction():
            await self.con.execute('''
                CREATE TABLE cursor_iterable_06 (id int);
                INSERT INTO cursor_iterable_06 VALUES (0), (1);
            ''')
            try:
                cur = self.con.cursor('SELECT * FROM cursor_iterable_06')
                async for rec in cur:
                    recs.append(rec)
            finally:
                # Check that after iteration has exhausted the cursor,
                # its associated portal is closed properly, unlocking
                # the table.
                await self.con.execute('DROP TABLE cursor_iterable_06')

        self.assertEqual(recs, [(i,) for i in range(2)])


class TestCursor(tb.ConnectedTestCase):