asyncpg是一个针对PostgreSQL数据库的异步驱动程序,不能直接用于MySQL。如果需要使用async/await异步操作MySQL数据库,可以使用aiomysql库。以下是使用aiomysql的示例代码:
import asyncio
import aiomysql
async def main():
# 连接MySQL数据库. Replace the parameters with your own values
conn_params = {'host': 'localhost', 'port': 3306, 'user': 'root', 'password': 'password',
'db': 'test', 'autocommit': True, 'charset': 'utf8mb4'}
async with aiomysql.create_pool(**conn_params) as pool:
async with pool.acquire() as conn:
async with conn.cursor() as cur:
# 查询数据库
await cur.execute("SELECT * FROM my_table;")
data = await cur.fetchall()
print(data)
# 运行异步函数
asyncio.run(main())
下一篇:Asyncpg连接池等待所有结果