aiomysql_async_connection_pool_with_cursor_query.py

1import asyncio
2import aiomysql
3
4loop = asyncio.get_event_loop()
5
6async def test_example():
7    pool = await aiomysql.create_pool(host='127.0.0.1', port=3306,
8                                      user='root', password='',
9                                      db='mysql', loop=loop)
10    async with pool.acquire() as conn:
11        async with conn.cursor() as cur:
12            await cur.execute("SELECT 42;")
13            print(cur.description)
14            (r,) = await cur.fetchone()
15            assert r == 42
16            print(r)
17    pool.close()
18    await pool.wait_closed()
19
20loop.run_until_complete(test_example())