aimysql的简单框架
aiomysql-core的Python项目详细描述
AimySQL核心
aimysql
的简单框架介绍
包装简单，使用方便
文件
安装
pip install aiomysql-core
简单用途
^{pr2}$简单的SQLAlchemy用法
importasynciofromaiomysql.saimportcreate_enginefromaiomysql_coreimportAioMysqlAlchemyCorefromsqlalchemyimportColumn,Integer,String,MetaData,Tablemetadata=MetaData()Test=Table('test',metadata,Column('id',Integer,primary_key=True),Column('content',String(255),server_default=""))asyncdeftest_example(loop):config={'user':'','password':'','db':'','host':'','port':3306,'autocommit':True,'charset':'utf8mb4'}engine=awaitcreate_engine(loop=loop,**config)core=AioMysqlAlchemyCore(engine=engine)# insertdoc={'content':'insert'}clause=Test.insert().values(**doc)rowcount=awaitcore.execute_rowcount(clause)print(rowcount)# searchclause=Test.select().where(Test.c.id==1).limit(1)row=awaitcore.get(clause)print(row.id,row.content)clause=Test.select().where(Test.c.id>1)rows=awaitcore.query(clause)asyncforrowinrows:print(row.id,row.content)# updatedoc={'content':'update'}clause=Test.update().values(**doc).where(Test.c.id==1)rowcount=awaitcore.execute_rowcount(clause)print(rowcount)# deleteclause=Test.delete().where(Test.c.id==1)rowcount=awaitcore.execute_rowcount(clause)print(rowcount)awaitengine.wait_closed()loop=asyncio.get_event_loop()loop.run_until_complete(test_example(loop))
- 项目
标签：
欢迎加入QQ群-->： 979659372
