python：aiomysql 一个基于异步的数据库操作库

Black

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中异步处理相对比较好的一个第三方库了

https://blog.csdn.net/LIFENG0402/article/details/121276150

Related Posts

“狗屁不通”文章生成器

前几天，GitHub 有个开源项目特别火，只要输入标题就可以生成一篇长长的文章。 背后实现代码一定很复杂吧，里 […]

python列表去重

在Python中，可以使用set数据类型来去除列表中的重复元素。将列表转换为集合时，会自动去除重复元素。 以下 […]