异步读写mysql依赖pymysql (asyncio/ aiomysql)

代码

import asyncio
import aiomysql

settings = {
    "host": "127.0.0.1",
    "port": 3306,
    "user": "root",
    "password": "123456",
    "db": "test",
}

async def main():
    pool = await aiomysql.create_pool(
        host=settings["host"],
        port=settings["port"],
        user=settings["user"],
        password=settings["password"],
        db=settings["db"],
    )
    async with pool.acquire() as conn:
        async with conn.cursor() as cur:
            await cur.execute("SELECT id,user_name FROM user")
            # print(cur.description)
            data = await cur.fetchone()
            print(data)
    pool.close()
    await pool.wait_closed()

if __name__ == '__main__':
    loop = asyncio.get_event_loop()
    loop.run_until_complete(main())