如何在 Python 中异步操作数据库？

import asyncioimport aiomysql.sa as aio_saasync def main():# 创建一个异步引擎engine = await aio_sa.create_engine(host="xx.xxx.xx.xxx",port=3306,user="root",password="root",db="_hanser",connect_timeout=10)# 通过 engine.acquire() 获取一个连接async with engine.acquire() as conn:# 异步执行, 返回一个 <class> 对象result = await conn.execute("SELECT * FROM girl")# 通过 await result.fetchone() 可以获取满足条件的第一条记录, 一个 <class> 对象data = await result.fetchone()# 可以将 <class> 对象想象成一个字典print(data.keys())# KeysView((1, '古明地觉', 16, '地灵殿'))print(list(data.keys()))# ['id', 'name', 'age', 'place']print(data.values())# ValuesView((1, '古明地觉', 16, '地灵殿'))print(list(data.values()))# [1, '古明地觉', 16, '地灵殿']print(data.items())# ItemsView((1, '古明地觉', 16, '地灵殿'))print(list(data.items()))# [('id', 1), ('name', '古明地觉'), ('age', 16), ('place', '地灵殿')]# 直接转成字典也是可以的print(dict(data))# {'id': 1, 'name': '古明地觉', 'age': 16, 'place': '地灵殿'}# 最后别忘记关闭引擎, 当然你在创建引擎的时候也可以通过 async with aio_sa.create_engine 的方式创建# async with 语句结束后会自动执行下面两行代码engine.close()await engine.wait_closed() loop = asyncio.get_event_loop()loop.run_until_complete(main())loop.close()</class></class></class>

import asynciofrom pprint import pprintimport aiomysql.sa as aio_saasync def main():# 通过异步上下文管理器的方式创建, 会自动帮我们关闭引擎async with aio_sa.create_engine(host="xx.xxx.xx.xxx",port=3306,user="root",password="root",db="_hanser",connect_timeout=10) as engine:async with engine.acquire() as conn:result = await conn.execute("SELECT * FROM girl")# 此时的 data 是一个列表, 列表里面是 <class> 对象data = await result.fetchall()# 将里面的元素转成字典pprint(list(map(dict, data)))"""[{'age': 16, 'id': 1, 'name': '古明地觉', 'place': '地灵殿'}, {'age': 16, 'id': 2, 'name': '雾雨魔理沙', 'place': '魔法森林'}, {'age': 400, 'id': 3, 'name': '芙兰朵露', 'place': '红魔馆'}]"""loop = asyncio.get_event_loop()loop.run_until_complete(main())loop.close()</class>

import asynciofrom pprint import pprintimport aiomysql.sa as aio_saasync def main():# 通过异步上下文管理器的方式创建, 会自动帮我们关闭引擎async with aio_sa.create_engine(host="xx.xxx.xx.xxx",port=3306,user="root",password="root",db="_hanser",connect_timeout=10) as engine:async with engine.acquire() as conn:result = await conn.execute("SELECT * FROM girl")# 默认是获取一条, 得到的仍然是一个列表data = await result.fetchmany(2)pprint(list(map(dict, data)))"""[{'age': 16, 'id': 1, 'name': '古明地觉', 'place': '地灵殿'}, {'age': 16, 'id': 2, 'name': '雾雨魔理沙', 'place': '魔法森林'}]"""loop = asyncio.get_event_loop()loop.run_until_complete(main())loop.close()