这里气候宜人，物产丰富，风景优美，是中国重点风景旅游城市。多明媚的秋天哪，这里，再也不是焦土和灰烬，这是千万座山风都披着红毯的旺盛的国土。那满身嵌着弹皮的红松，仍然活着，傲立在高高的山岩上，山谷中汽笛欢腾，白望在稻田里缓缓飞翔。秋天的美是成熟的——它不像春那么羞涩，夏那么坦露，冬那么内向。
本文实例讲述了Python异步操作MySQL。分享给大家供大家参考，具体如下：
安装aiomysql
依赖
- Python3.4+
- asyncio
- PyMySQL
安装
pip install aiomysql
应用
基本的异步连接connection
import asyncio
from aiomysql import create_pool
loop = 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())
异步的连接池 pool
import asyncio
import aiomysql
async 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))
对象关系映射SQLAlchemy - Object Relationship Mapping
可以随意定义表结构，轻松调用查询、插入等操作方法。
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))
希望本文所述对大家Python程序设计有所帮助。
本文Python异步操作MySQL示例【使用aiomysql】到此结束。淡忘仇恨，春暖花开。心有多大，舞台就有多大。小编再次感谢大家对我们的支持！
