MySql教程
python：aiomysql 一个基于异步的数据库操作库
本文主要是介绍python：aiomysql 一个基于异步的数据库操作库，对大家解决编程问题具有一定的参考价值，需要的程序猿们随着小编来一起学习吧！
aiomysql是一个用于从asyncio框架访问MySQL数据库的 驱动程序。它依赖并重用了PyMySQL的大部分部分。
Installation
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)
上述代码中可以看到已经注释掉的# print(cur.description)，官方的解释是：这个只读属性是一个由 7 个项目组成的序列。
这些序列中的每一个都是一个 collections.namedtuple，其中包含描述一个结果列的信息：
- name：返回的列的名称。
- type_code：列的类型。
- display_size：列的实际长度（以字节为单位）。
- internal_size：服务器上与此列关联的列的大小（以字节为单位）。
- 精度：NUMERIC 类型的列中有效数字的总数。 其他类型无。
- scale：NUMERIC 类型的列中小数部分的小数位数。 其他类型无。
- null_ok：总是无。
对于不返回行的操作或游标尚未通过 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
这篇关于python：aiomysql 一个基于异步的数据库操作库的文章就介绍到这儿，希望我们推荐的文章对大家有所帮助，也希望大家多多支持为之网！
您可能喜欢
-
mysql ddl常用的方法和语句-icode9专业技术文章分享08-27
-
MySQL入门：轻松掌握数据库基础操作与技巧08-13
-
Seata和Mysql存储演示学习入门：初级开发者实战指南08-12
-
从 MySQL 迁移到 TiDB：使用 SQL-Replay 工具进行真实线上流量回放测试 SOP08-10
-
蔚来汽车 x TiDB丨单表超 20 亿条数据，从 MySQL 到 TiDB 的迁移思考与实践08-05
-
【Mysql】Docker下Mysql8数据备份与恢复07-22
-
MySQL报错Duplicate entry '0' for key 'PRIMARY'06-25
-
阿里 Canal 实时同步 MySQL 增量数据至 ClickHouse 数据库05-29
-
在Linux下管理MySQL的大小写敏感性05-24
-
MySQL查出时间比实际晚8小时的解决方案04-26
-
JPA不识别MySQL的枚举类型04-01
-
mysql数据库表卡死解决方法03-30
-
MySQL多数据源笔记5-ShardingJDBC实战03-15
-
natural join mysql03-11
-
关于VS2017，VS2015 中利用 EF使用Mysql 不显示数据源问题解决方案03-11
栏目导航
