anysqlite_async_connection_table_creation_insert_fetch_with_anyio.py

1import anyio
2import anysqlite
3
4async def main():
5    async with anysqlite.connect("test.db") as db:
6        await db.execute("CREATE TABLE IF NOT EXISTS stocks (date text, price real)")
7        await db.execute("INSERT INTO stocks VALUES ('2020-01-01', 42.0)")
8        await db.commit()
9
10        async with db.execute("SELECT * FROM stocks") as cursor:
11            async for row in cursor:
12                print(row)
13
14if __name__ == "__main__":
15    anyio.run(main)