aiomysql官方文档一

2017-09-25  本文已影响1000人  ikaroskun

aiomysql-API Rederence

连接

这个库提供了一种通过简洁的工厂级别的函数aiomysql.connect()去连接MySQL数据库的一种方式。如果你只想要存在一个连接,可以使用这种方式。对于多个连接可以考虑连接池。

示例:


"""
    Just a demo for test the aiomysql.
"""
import asyncio
import aiomysql

loop = asyncio.get_event_loop()


@asyncio.coroutine
def test_example():
    conn = yield from aiomysql.connect(host="127.0.0.1", port=3306,
                                       user="root", password="123456",
                                       db="mysql", loop=loop
                                       )

    cur = yield from conn.cursor()
    yield from cur.execute("select Host, User from user")
    print(cur.description)
    result = yield from cur.fetchall()
    print(result)
    yield from cur.close()
    conn.close()


loop.run_until_complete(test_example())

connect()函数的参数解析:

**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=None, autocommit=False, echo=False,
local_infile=False, loop=None):
**

一个连接MySQL的协程。

这个方法接受了所有来自pymsql.connect()的参数,并加上了关键字循环参数和超时参数。

MySQL服务器的socket的标志,获取链接实例的正确方法是调用aiomysql.connect()

它的实例等同于pymsql.connection除了他的所有方法都是使用了协程。

最重要的方法是:

aiomysql.cursor(cursor=None)

一个使用连接创建新游标对象的协程。

默认情况下, Cursor将被返回。也可以通过cursor参数给定一个自定义的cursor,但是他需要一个Cursor的子类。

Parameters: cursor- Cursor的子类,或者指定为None使用默认的cursor。

Returns: Cursor实例。

aiomysql.close()

立即关闭连接。

立即关闭连接,(除非del操作在执行)。从这之后连接将无法使用。

aiomysql.ensure_closed()

协程退出指令,然后会关闭socket连接。

aiomysql.autocommit(value)

指定当前session会话的自动提交模式是否可用的协程

Params:布尔值
value: 切换自动提交模式

aiomysql.get_autocommit()

返回当前会话的自动提交模式的状态。

Reuturn: 布尔值 自动提交模式的状态

aiomysql.begin()

开启一个事务的协程。

aiomysql.commt()

提交更改到存储器的协程

aiomysql.rollback()

当前事务的rollback的协程

aiomysql.select_db(db)

选择当前数据库的协程

Paramters: 数据库(字符串)-- 数据库的名字

aiomysql.closed()

如果连接关闭,返回一个只读的属性 True。

aiomysql.host

MySQL服务器的IP地址或者主机名

aiomysql.port

MySQL服务器的TCP/IP通信端口

aiomysql.unix_socket

MySQL套接字文件的位置

aiomysql.db

当前数据库的名字

aiomysql.user

连接MySQL服务器的用户

aiomysql.echo

返回echo模式的状态(是否打印出SQL语句)

aiomysql.encoding

当前连接使用的编码格式

aiomysql.charset

返回当前连接的字符集。

上一篇 下一篇

猜你喜欢

热点阅读