asyncmy_mysql_async_connection_with_single_row_fetch.py

1import asyncio
2import asyncmy
3
4async def run():
5    conn = await asyncmy.connect(
6        host="127.0.0.1",
7        port=3306,
8        user="root",
9        password="password",
10        database="test",
11    )
12    async with conn.cursor() as cursor:
13        await cursor.execute("SELECT 1")
14        result = await cursor.fetchone()
15        print(result)
16    conn.close()
17
18if __name__ == "__main__":
19    asyncio.run(run())