aiomysql是一个用于从asyncio框架访问MySQL数据库的 驱动程序。它依赖并重用了PyMySQL的大部分部分。
C:\Users\lifeng>pip install aiomysql Collecting aiomysql Downloading aiomysql-0.0.21-py3-none-any.whl (41 kB) |████████████████████████████████| 41 kB 31 kB/s Requirement already satisfied: PyMySQL<=0.9.3,>=0.9 in d:\python\python37\lib\site-packages (from aiomysql) (0.9.3) Installing collected packages: aiomysql Successfully installed aiomysql-0.0.21
从基本的例子开始:
import asyncio import aiomysql # 返回一个asyncio事件循环。 loop = asyncio.get_event_loop() @asyncio.coroutine def test_example(): conn = yield from aiomysql.connect(host='8.136.250.157', port=33306, user='root', password='123456', db='testing', loop=loop, cursorclass=aiomysql.DictCursor) cur = yield from conn.cursor() yield from cur.execute("SELECT * FROM hotel_ranking;") # print(cur.description) r = yield from cur.fetchall() for i in r: print(i) yield from cur.close() conn.close() loop.run_until_complete(test_example())
运行结果如下:
F:\project_gitee\Test\pythonScripts>D:/Python/Python37/python.exe f:/project_gitee/Test/pythonScripts/pythonLibrary/pythonModule1.py {'id': 1, 'name': '欢迎关注”就用python“公众号,登录验证码是:565251 !'} {'id': 2, 'name': '欢迎关注”就用python“公众号,登录验证码是:525653 !'} {'id': 3, 'name': '欢迎关注”就用python“公众号,登录验证码是:999666 !'}
连接是通过调用connect()
建立的,参数列表是关键字参数,几乎与PyMySQL中对应的方法相同(指定的连接参数)。使用root用户名和密码连接到服务器上的MySQL服务器并访问MySQL数据库。
如果connect()
成功,它将返回一个Connection实例作为与MySQL进一步交互的基础。
在获得连接对象之后,示例中的代码调用connection.cursor()
方法是来创建用于处理语句的游标对象。示例使用游标发出一个SELECT * FROM hotel_ranking;
语句,从MySQL系统表hotel_ranking中返回数据:
cur = yield from conn.cursor() yield from cur.execute("SELECT * FROM hotel_ranking;") # print(cur.description) r = yield from cur.fetchall()
游标对象的cursor.execute()
方法将查询发送给服务器,而cursor.fetchall()
则检索行。
最后,脚本调用Cursor.close()
方法和连接对象的connection.close()
方法来断开与服务器的连接:
yield from cur.close() conn.close()
在此之后,conn将无效,不应用于访问服务器。
以Cursor.execute()
方法为例:
import asyncio import aiomysql async def test_example_execute(loop): conn = await aiomysql.connect(host='8.136.250.157', port=33306, user='root', password='123456', db='testing', loop=loop, cursorclass=aiomysql.DictCursor) cur = await conn.cursor() async with conn.cursor() as cur: # insert 3 rows one by one await cur.execute("INSERT INTO hotel_ranking(name) VALUES('欢迎关注”就用python“公众号,登录验证码是:565251 !')") await cur.execute("INSERT INTO hotel_ranking(name) VALUES('欢迎关注”就用python“公众号,登录验证码是:565251 !')") await cur.execute("INSERT INTO hotel_ranking(name) VALUES('欢迎关注”就用python“公众号,登录验证码是:565251 !')") await conn.commit() await cur.execute("SELECT * FROM hotel_ranking;") r = await cur.fetchall() for i in r: print(i) conn.close() loop = asyncio.get_event_loop() loop.run_until_complete(test_example_execute(loop))
运行结果如下:
F:\project_gitee\Test\pythonScripts>D:/Python/Python37/python.exe f:/project_gitee/Test/pythonScripts/pythonLibrary/pythonModule1.py {'id': 1, 'name': '欢迎关注”就用python“公众号,登录验证码是:565251 !'} {'id': 2, 'name': '欢迎关注”就用python“公众号,登录验证码是:525653 !'} {'id': 3, 'name': '欢迎关注”就用python“公众号,登录验证码是:999666 !'} {'id': 4, 'name': '欢迎关注”就用python“公众号,登录验证码是:565251 !'} {'id': 5, 'name': '欢迎关注”就用python“公众号,登录验证码是:565251 !'} {'id': 6, 'name': '欢迎关注”就用python“公众号,登录验证码是:565251 !'} {'id': 7, 'name': '欢迎关注”就用python“公众号,登录验证码是:565251 !'} {'id': 8, 'name': '欢迎关注”就用python“公众号,登录验证码是:565251 !'} {'id': 9, 'name': '欢迎关注”就用python“公众号,登录验证码是:565251 !'} {'id': 10, 'name': '欢迎关注”就用python“公众号,登录验证码是:565251 !'} {'id': 11, 'name': '欢迎关注”就用python“公众号,登录验证码是:565251 !'} {'id': 12, 'name': '欢迎关注”就用python“公众号,登录验证码是:565251 !'} {'id': 13, 'name': '欢迎关注”就用python“公众号,登录验证码是:565251 !'} {'id': 14, 'name': '欢迎关注”就用python“公众号,登录验证码是:565251 !'} {'id': 15, 'name': '欢迎关注”就用python“公众号,登录验证码是:565251 !'} {'id': 16, 'name': '欢迎关注”就用python“公众号,登录验证码是:565251 !'}
请注意,您需要手动调用绑定到Connection
对象的commit()
,因为默认情况下它被设置为False,或者在aiomysql.connect()
中,您可以转移添加关键字参数autocommit=True
。
autocommit = True示例:
import asyncio import aiomysql async def test_example_execute(loop): conn = await aiomysql.connect(host='8.136.250.157', port=33306, user='root', password='123456', db='testing', loop=loop, autocommit=True, cursorclass=aiomysql.DictCursor) cur = await conn.cursor() async with conn.cursor() as cur: # 依次插入三条数据 await cur.execute("INSERT INTO hotel_ranking(name) VALUES('欢迎关注”就用python“公众号,登录验证码是:565251 !')") await cur.execute("INSERT INTO hotel_ranking(name) VALUES('欢迎关注”就用python“公众号,登录验证码是:565251 !')") await cur.execute("INSERT INTO hotel_ranking(name) VALUES('欢迎关注”就用python“公众号,登录验证码是:565251 !')") # 查询全部数据 await cur.execute("SELECT * FROM hotel_ranking;") r = await cur.fetchall() for i in r: print(i) conn.close() loop = asyncio.get_event_loop() loop.run_until_complete(test_example_execute(loop))
运行结果如下:
F:\project_gitee\Test\pythonScripts>D:/Python/Python37/python.exe f:/project_gitee/Test/pythonScripts/pythonLibrary/pythonModule1.py {'id': 1, 'name': '欢迎关注”就用python“公众号,登录验证码是:565251 !'} {'id': 2, 'name': '欢迎关注”就用python“公众号,登录验证码是:525653 !'} {'id': 3, 'name': '欢迎关注”就用python“公众号,登录验证码是:999666 !'} {'id': 4, 'name': '欢迎关注”就用python“公众号,登录验证码是:565251 !'} {'id': 5, 'name': '欢迎关注”就用python“公众号,登录验证码是:565251 !'} {'id': 6, 'name': '欢迎关注”就用python“公众号,登录验证码是:565251 !'} {'id': 7, 'name': '欢迎关注”就用python“公众号,登录验证码是:565251 !'} {'id': 8, 'name': '欢迎关注”就用python“公众号,登录验证码是:565251 !'} {'id': 9, 'name': '欢迎关注”就用python“公众号,登录验证码是:565251 !'} {'id': 10, 'name': '欢迎关注”就用python“公众号,登录验证码是:565251 !'} {'id': 11, 'name': '欢迎关注”就用python“公众号,登录验证码是:565251 !'} {'id': 12, 'name': '欢迎关注”就用python“公众号,登录验证码是:565251 !'} {'id': 13, 'name': '欢迎关注”就用python“公众号,登录验证码是:565251 !'} {'id': 14, 'name': '欢迎关注”就用python“公众号,登录验证码是:565251 !'} {'id': 15, 'name': '欢迎关注”就用python“公众号,登录验证码是:565251 !'} {'id': 16, 'name': '欢迎关注”就用python“公众号,登录验证码是:565251 !'} {'id': 17, 'name': '欢迎关注”就用python“公众号,登录验证码是:565251 !'} {'id': 18, 'name': '欢迎关注”就用python“公众号,登录验证码是:565251 !'} {'id': 19, 'name': '欢迎关注”就用python“公众号,登录验证码是:565251 !'}
上述代码中可以看到已经注释掉的# print(cur.description)
,官方的解释是:这个只读属性是一个由 7 个项目组成的序列。
这些序列中的每一个都是一个 collections.namedtuple,其中包含描述一个结果列的信息:
对于不返回行的操作或游标尚未通过 Cursor.execute() 方法调用的操作,此属性将为 None 。
运行出来就是这样的结果(因为的表就两列,所以就只有id
和name
):
F:\project_gitee\Test\pythonScripts>D:/Python/Python37/python.exe f:/project_gitee/Test/pythonScripts/pythonLibrary/pythonModule1.py (('id', 3, None, 11, 11, 0, False), ('name', 253, None, 1020, 1020, 0, False))
它也提供了连接池对象,基本用法是:
import asyncio import aiomysql # 返回一个asyncio事件循环。 loop = asyncio.get_event_loop() @asyncio.coroutine def test_example(): pool = yield from aiomysql.create_pool(host='8.136.250.157', port=33306, user='root', password='123456', db='testing', loop=loop, cursorclass=aiomysql.DictCursor) with (yield from pool) as conn: cur = yield from conn.cursor() yield from cur.execute("SELECT * FROM hotel_ranking;") # print(cur.description) r = yield from cur.fetchall() for i in r: print(i) yield from cur.close() pool.close() yield from pool.wait_closed() loop.run_until_complete(test_example())
运行结果:
F:\project_gitee\Test\pythonScripts>D:/Python/Python37/python.exe f:/project_gitee/Test/pythonScripts/pythonLibrary/pythonModule1.py {'id': 1, 'name': '欢迎关注”就用python“公众号,登录验证码是:565251 !'} {'id': 2, 'name': '欢迎关注”就用python“公众号,登录验证码是:525653 !'} {'id': 3, 'name': '欢迎关注”就用python“公众号,登录验证码是:999666 !'} {'id': 4, 'name': '欢迎关注”就用python“公众号,登录验证码是:565251 !'} {'id': 5, 'name': '欢迎关注”就用python“公众号,登录验证码是:565251 !'} {'id': 6, 'name': '欢迎关注”就用python“公众号,登录验证码是:565251 !'} {'id': 7, 'name': '欢迎关注”就用python“公众号,登录验证码是:565251 !'} {'id': 8, 'name': '欢迎关注”就用python“公众号,登录验证码是:565251 !'} {'id': 9, 'name': '欢迎关注”就用python“公众号,登录验证码是:565251 !'} {'id': 10, 'name': '欢迎关注”就用python“公众号,登录验证码是:565251 !'} {'id': 11, 'name': '欢迎关注”就用python“公众号,登录验证码是:565251 !'} {'id': 12, 'name': '欢迎关注”就用python“公众号,登录验证码是:565251 !'} {'id': 13, 'name': '欢迎关注”就用python“公众号,登录验证码是:565251 !'} {'id': 14, 'name': '欢迎关注”就用python“公众号,登录验证码是:565251 !'} {'id': 15, 'name': '欢迎关注”就用python“公众号,登录验证码是:565251 !'} {'id': 16, 'name': '欢迎关注”就用python“公众号,登录验证码是:565251 !'} {'id': 17, 'name': '欢迎关注”就用python“公众号,登录验证码是:565251 !'} {'id': 18, 'name': '欢迎关注”就用python“公众号,登录验证码是:565251 !'} {'id': 19, 'name': '欢迎关注”就用python“公众号,登录验证码是:565251 !'}
以上知识简单的使用,它还提供了SQL查询构建器等,算是python中异步处理相对比较好的一个第三方库了
以上总结或许能帮助到你,或许帮助不到你,但还是希望能帮助到你,如有疑问、歧义,直接私信留言会及时修正发布;非常期待你的点赞和分享哟,谢谢!
未完,待续…
一直都在努力,希望您也是!
微信搜索公众号:就用python