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