aiomysql is a “driver” for accessing a MySQL database from the asyncio (PEP-3156/tulip) framework. It depends on and reuses most parts of PyMySQL . aiomysql tries to be like awesome aiopg library and preserve same api, look and feel.
Internally aiomysql is copy of PyMySQL, underlying io calls switched to async, basically yield from and asyncio.coroutine added in proper places)). sqlalchemy support ported from aiopg.
Documentation
Basic Example
aiomysql based on PyMySQL , and provides same api, you just need to use yield from conn.f() instead of just call conn.f() for every method.
Properties are unchanged, so conn.prop is correct as well as conn.prop = val.
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='', db='mysql',
loop=loop)
cur = yield from conn.cursor()
yield from cur.execute("SELECT Host,User FROM user")
print(cur.description)
r = yield from cur.fetchall()
print(r)
yield from cur.close()
conn.close()
loop.run_until_complete(test_example())Connection Pool
Connection pooling ported from aiopg :
import asyncio
import aiomysql
loop = asyncio.get_event_loop()
@asyncio.coroutine
def test_example():
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(test_example())Example of SQLAlchemy optional integration
Sqlalchemy support has been ported from aiopg so api should be very familiar for aiopg user.:
import asyncio
from aiomysql.sa import create_engine
import sqlalchemy as sa
metadata = sa.MetaData()
tbl = sa.Table('tbl', metadata,
sa.Column('id', sa.Integer, primary_key=True),
sa.Column('val', sa.String(255)))
@asyncio.coroutine
def go():
engine = yield from create_engine(user='root',
db='aiomysql',
host='127.0.0.1',
password='')
with (yield from engine) as conn:
yield from conn.execute(tbl.insert().values(val='abc'))
res = yield from conn.execute(tbl.select())
for row in res:
print(row.id, row.val)
asyncio.get_event_loop().run_until_complete(go())Requirements
Changes
0.0.4 (2015-05-23)
Allow to call connection.wait_closed twice.
Fixed sqlalchemy 1.0.0 support.
Fix #11: Rename Connection.wait_closed() to .ensure_closed()
Raise ResourceWarning on non-closed Connection
Rename Connection.connect to _connect
0.0.3 (2015-03-10)
Added support for PyMySQL up to 0.6.6.
Ported improvements from PyMySQL.
Added basic documentation.
Fixed and added more examples.
0.0.2 (2015-02-17)
Added MANIFEST.in.
0.0.1 (2015-02-17)
Initial release.
Implemented plain connections: connect, Connection, Cursor.
Implemented database pools.
Ported sqlalchemy optional support.
5 maintainers
Metadata
5 maintainers
Release files for aiomysql 0.0.4
For a detailed explanation of source distributions (sdists) and built distributions (wheels), please see the package formats documentation.
Source distribution (sdist)
| File | Size | Uploaded | |
|---|---|---|---|
| aiomysql-0.0.4.tar.gz | 46.0 kB | Details |
Release files / aiomysql-0.0.4.tar.gz
| Download URL | aiomysql-0.0.4.tar.gz |
|---|---|
| Size | 46.0 kB |
| Tags | Source |
|
SHA-256 checksum How to use checksums |
e5ed07034289d325ec1bfea6d9dd51de344a105793d8fb3b2962c2d3aafb54f5
|
|
BLAKE2b-256 checksum How to use checksums |
33b5eb40bd17587cb341efdb1906fb2ab4d5d43090f74e367aceccd9b1500f4f
|
| Upload date | |
|
Uploaded using Trusted Publishing? What is trusted publishing? |
No |
