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

2021/11/12 2:10:59

本文主要是介绍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 。

运行出来就是这样的结果(因为的表就两列,所以就只有idname):

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 一个基于异步的数据库操作库的文章就介绍到这儿,希望我们推荐的文章对大家有所帮助,也希望大家多多支持为之网!


扫一扫关注最新编程教程