aiomysql库常用接口

[aiomysql官网]

Connection

连接MySQL的协程：

aiomysql.connect(host="localhost", user=None, password="", db=None, port=3306,
unix_socket=None, charset='', sql_mode=None, read_default_file=None, conv=decoders,
use_unicode=None, client_flag=0, cursorclass=Cursor, init_command=None,
connect_timeout=None, read_default_group=None, no_delay=False, autocommit=False,
echo=False, loop=None)

使用连接创建游标的协程：

aiomysql.cursor(cursor=None)

参数:

cursor ：Cursor的子类 或者 None 表示默认cursor.

返回:

Cursor实例.

开始数据库操作的协程：

aiomysql.begin()

提交数据库修改的协程：

aiomysql.commit()

回退到当前状态的协程：

aiomysql.rollback()

---

class Cursor

获取指向连接的cursor:

Connection.cursor()

返回被影响的行数(只读):

Cursor.rowcount

执行指定操作的协程：

Cursor.execute(query, args=None)

参数:

query (str) ： sql 语句
args (list) ： 元组或者列表

返回：

int：被影响的行数

协程，获取下一行:

Cursor.fetchone()

协程，获取指定size行数据，以列表或者元组返回

Cursor.fetchmany(size=None)

协程，返回所有行：

Cursor.fetchall()

---

class DictCursor

一个返回字典的cursor。所有的方法和参数都与类Cursor一样。

---

class Pool

创建一个MySQL的连接池：

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

参数:

minsize (int) ： 连接池的最小连接数.
maxsize (int) ： 连接池的最大连接数.
loop ： 可选，事件循环实例, 如果loop没有指定则默认使用asyncio.get_event_loop().
echo (bool) ：执行SQL查询日志 (默认False).
kwargs ： 该函数接收aiomysql.connect()函数的所有参数，还有关键字参数loop, minsize, maxsize.

返回:

Pool 实例.