Python异步操作MySQL示例【使用aiomysql】

pip install aiomysql

import asynciofrom aiomysql import create_poolloop = asyncio.get_event_loop()async def go():  async with create_pool(host='127.0.0.1', port=3306,              user='root', password='',              db='mysql', loop=loop) as pool:    async with pool.get() as conn:      async with conn.cursor() as cur:        await cur.execute("SELECT 42;")        value = await cur.fetchone()        print(value)loop.run_until_complete(go())

import asyncioimport aiomysqlasync def test_example(loop):  pool = await aiomysql.create_pool(host='127.0.0.1', port=3306,                   user='root', password='',                   db='mysql', loop=loop)  async with pool.acquire() as conn:    async with conn.cursor() as cur:      await cur.execute("SELECT 42;")      print(cur.description)      (r,) = await cur.fetchone()      assert r == 42  pool.close()  await pool.wait_closed()loop = asyncio.get_event_loop()loop.run_until_complete(test_example(loop))

import asyncioimport sqlalchemy as safrom aiomysql.sa import create_enginemetadata = 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))