Async support

[openlegis-br]

Is there any possibility to support async ?

"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."

aiomysql based on PyMySQL , and provides same api, you just need to use await conn.f() or yield from conn.f() instead of calling conn.f() for every method.

Properties are unchanged, so conn.prop is correct as well as conn.prop = val.

[dataflake]

Pull requests are welcome.

[d-maurer]

OpenLegis wrote at 2023-8-9 08:04 -0700:

Is there any possibility to support async ?

`Products.*DA` is a family of database adapters for the web application framework `Zope`. `Zope` is based on multi threading (not `asyncio`). Therefore, `async` support might be possible but not in `Products.SQLAlchemyDA`. Ask in an `sqlalchemy` mailing list.

[openlegis-br]

sqlalchemy already supports this feature:

Example of SQLAlchemy optional integration

Sqlalchemy support has been ported from aiopg so api should be very familiar for aiopg user.:

import asyncio
import sqlalchemy as sa

from aiomysql.sa import create_engine

metadata = sa.MetaData()

tbl = sa.Table('tbl', metadata,
sa.Column('id', sa.Integer, primary_key=True),
sa.Column('val', sa.String(255)))

async def go(loop):
engine = await create_engine(user='root', db='test_pymysql',
host='127.0.0.1', password='', loop=loop)
async with engine.acquire() as conn:
await conn.execute(tbl.insert().values(val='abc'))
await conn.execute(tbl.insert().values(val='xyz'))

    async for row in conn.execute(tbl.select()):
        print(row.id, row.val)

engine.close()
await engine.wait_closed()

loop = asyncio.get_event_loop()
loop.run_until_complete(go(loop))