python import asyncio import aiomysql async def create_pool(): pool = await aiomysql.create_pool(host='localhost', port=3306, user='root', password='password', db='mydb') return pool async def execute_query(pool): async with pool.acquire() as conn: async with conn.cursor() as cur: await cur.execute('SELECT * FROM mytable') result = await cur.fetchall() return result async def main(): pool = await create_pool() result = await execute_query(pool) print(result) loop = asyncio.get_event_loop() loop.run_until_complete(main())