异步操作mysql


记录异步操作mysql 的方法

异步操作mysql

因为比较简单, 只要会使用pymysql 就会使用这个 aiomysql , 直接上代码.

import aiomysql
import asyncio

async def execute(address, user, pwd, database):
    # IO 操作, 连接mysql
    # coon = await aiomysql.connect(host='127.0.0.1', port=3306, user='root', password='123456', db='test')
    coon = await aiomysql.connect(host=address, port=3306, user=user, password=pwd, db=database)
    # io操作, 创建游标
    cur = await coon.cursor()
    # IO 操作, 执行sql
    await cur.execute("show tables;")
    # IO 操作, 获取sql 结果
    result = await cur.fetchall()
    print(result)
    # io 操作 
    await cur.close()
    coon.close()
address, user, pwd, database = '127.0.0.1', 'root', '123456', 'test'
# 本地并不存在这个mysql
address1, user1, pwd1, database1 = '127.0.0.2', 'root', '123456', 'test'
task = [
execute(address, user, pwd, database),
# execute(address1, user1, pwd1, database1)
]
loop = asyncio.get_event_loop()
loop.run_until_complete(asyncio.wait(task))

文章作者: 陌上人如玉
版权声明: 本博客所有文章除特別声明外,均采用 CC BY 4.0 许可协议。转载请注明来源 陌上人如玉 !
 上一篇
爬虫和异步学习总结 爬虫和异步学习总结
耗时一个半月的时间, 学完了B站路飞学城的一个爬虫入门视频, 算是颇有收获吧,简单记录一下自己的收获.
2021-01-15
下一篇 
Redis的搭建和使用 Redis的搭建和使用
前段时间,学习 scrapy 框架入门的时候, 连接Redis 没有连接成功, 但是还不知道怎么弄, 留下了疑问.昨晚学习异步编程的时候, 异步操作Redis 的时候, 发现了问题, 总算是解决了之前遗留下来的连接问题.
  目录