16翻译aiomysql-Pool

Posted 2020-10-30 Hello _ world

本文翻译自：Pool-aiomysql 0.0.9 documentation

 

Pool

该库提供连接池以及普通连接对象。

基本用法是：

import asyncio
import aiomysql

loop = asyncio.get_event_loop()

@asyncio.coroutine
def go()
    pool = yield from aiomysql.create_pool(host=‘127.0.0.1‘, port=3306,
                                           user=‘root‘, password=‘‘,
                                           db=‘mysql‘, loop=loop)

    with (yield from pool) as conn:
        cur = yield from conn.cursor()
        yield from cur.execute("SELECT 10")
        # print(cur.description)
        (r,) = yield from cur.fetchone()
       assert r == 10
    pool.close()
    yield from pool.wait_closed()

loop.run_until_complete(go())

 

create_pool(minsize=1, maxsize=10, loop=None, **kwargs)

——创建与MySQL数据库的连接池的协程。

参数：

• minsize (int) – 连接池的最少连接数目
• maxsize (int) – 连接池的最大连接数据
• loop – 是一个可选的事件循环实例，如果未指定loop，则使用asyncio.get_event_loop（）
• echo (bool) – – 执行日志SQL查询（默认为False）
• kwargs – 该函数接受aiomysql.connect（）所需的所有参数，以及可选的关键字参数loop，minsize，maxsize。

返回：

　　Pool实例

 

Pool类