aiomysql模块

import asyncio
import aiomysql

async def test_connection():
    pool = await aiomysql.create_pool(
        host='127.0.0.1',
        port=3306,
        user='your_user',
        password='your_password',
        db='your_db',
        loop=asyncio.get_event_loop()
    )
    async with pool.acquire() as conn:
        async with conn.cursor() as cur:
            await cur.execute("SELECT 42;")
            value = await cur.fetchone()
            print(value)
    pool.close()
    await pool.wait_closed()

asyncio.run(test_connection())

async def fetch_data():
    pool = await aiomysql.create_pool(
        host='127.0.0.1',
        port=3306,
        user='your_user',
        password='your_password',
        db='your_db',
        loop=asyncio.get_event_loop()
    )
    async with pool.acquire() as conn:
        async with conn.cursor() as cur:
            await cur.execute("SELECT * FROM your_table WHERE some_condition;")
            result = await cur.fetchall()
            if not result:
                print("No data found")
            else:
                print(result)
    pool.close()
    await pool.wait_closed()

asyncio.run(fetch_data())