anysqlite_async_crud_quickstart_connect_create_insert_query.py

1import asyncio
2import anysqlite
3
4async def main():
5    # Connect to the database
6    async with anysqlite.connect("example.db") as db:
7        # Create a table
8        await db.execute("CREATE TABLE IF NOT EXISTS users (id INTEGER PRIMARY KEY, name TEXT)")
9        
10        # Insert a row
11        await db.execute("INSERT INTO users (name) VALUES (?)", ("Alice",))
12        await db.commit()
13
14        # Query the database
15        async with db.execute("SELECT id, name FROM users") as cursor:
16            async for row in cursor:
17                print(row)
18
19if __name__ == "__main__":
20    asyncio.run(main())