简单的异步MySQL ORM类。
aio-ormsql的Python项目详细描述
aio\U或MSQL
简单的异步MySQL ORM类。在
易于安装
pip3 install aio_ormsql
必需的
pip3 install asyncio aiomysql
- Python 3.6+
示例用法
- 进口产品:
fromaio_ormsql.dbimportDataBasefromaio_ormsql.classesTable,Column,WHERE
其中:
DataBase
-用于使用MySQL的类Table
-用于创建新表的类Column
-用于创建列的类WHERE
-用于创建where语句的类
- 以下示例并查看其输出:
示例
创建表格
^{pr2}$连接到数据库
db=DataBase('admin','admin','tests')awaitdb.connect()
简单WHERE语句
where=WHERE(tbl.tname=='admin')print(where)# Output:# WHERE `tname`='admin'
另一个WHERE语句
where2=WHERE((tbl.id>=20)|(tbl.tname=='admin'))print(where2)# Output:# WHERE `id`>=20 OR `tname`='admin'
选择示例
statement=awaitdb.select([tbl.id,tbl.tname],where=where,table=tbl,back=True)print(statement)# Output:# SELECT DISTINCT `id`, `tname` FROM `tests` WHERE `tname`='admin'
选择示例2
statement2=awaitdb.select([tbl.id,tbl.tname],False,where2,table=tbl,back=True)print(statement2)# Output:# SELECT`id`, `tname` FROM `tests` WHERE `id`>=20 OR `tname`='admin'
插入示例
statement3=awaitdb.insert({tbl.id:123,tbl.tname:'Johan'},tbl,back=True)print(statement3)# Output:# INSERT INTO `tests` (`id`, `tname`) VALUES (123, 'Johan')
插入示例2
statement4=awaitdb.update({tbl.id:'123',tbl.tname:'Admin'},WHERE(tbl.tname=='Johan'),tbl,back=True)print(statement4)# Output:# UPDATE `tests` SET `id`=123, `tname`='Admin' WHERE `tname`='Johan'
使用大DB
array=db.fetch_gen(awaitdb.select([tbl.id,tbl.tname],back=True))asyncforiteminarray:print('New pair:',item)# And you can see row-by-row output
关闭连接并等待完成任务
awaitdb.close()
- 项目
标签: