tornado 异步mysql

import aiomysql
import asyncio

async def main():
    pool = await aiomysql.create_pool(
        host='127.0.0.1',
        port=3306,
        user='root',
        password='password',
        db='test',
        loop=asyncio.get_event_loop(),
        maxsize=100  # 设置连接池大小
    )
    # 使用连接池进行数据库操作
    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(main())

async with pool.acquire() as conn:
    async with conn.cursor() as cur:
        await cur.execute("SELECT * FROM large_table;")
        while True:
            result = await cur.fetchone()
            if result is None:
                break
            # 处理查询结果
            print(result)