Async Cursors, Iteration, and Transactions

import aiosqlite

async def write_chunk(conn, rows):
    async with conn:                        # BEGIN/COMMIT/ROLLBACK context
        await conn.executemany(
            'INSERT INTO notes(body) VALUES (?)',
            rows,
        )

async def stream_all(conn):
    async with conn.execute('SELECT id, body FROM notes ORDER BY id') as cur:
        async for row in cur:
            yield row

async def main():
    async with aiosqlite.connect('demo.db') as conn:
        conn.row_factory = aiosqlite.Row
        await write_chunk(conn, [(f'note{i}',) for i in range(1000)])
        async for row in stream_all(conn):
            print(dict(row))