36 lines
1.2 KiB
Python
36 lines
1.2 KiB
Python
## 使用sqlor模块操作数据库
|
||
日期数据,在数据库中用date类型，日期格式：YYYY-MM-DD
|
||
时间戳数据，在数据库中用timestamp类型，格式：YYYY-MM-DD hh:mm:ss.999
|
||
sor.R()
|
||
sor.sqlExe() 的select语句
|
||
如果ns中有'page'属性，返回数据格式如下
|
||
{
|
||
"total" # 查询结果总记录数
|
||
"rows": page指定的页数据， 缺省每页返回80条记录，pagerows属性可设置每页记录数
|
||
}
|
||
否则返回全部记录的数组
|
||
```
|
||
from sqlor.dbpools import DBPools
|
||
from ahserver.serverenv import ServerEnv
|
||
# 假设当前模块名称为"mymodule"
|
||
|
||
async def subcoro(sor, pid):
|
||
sql = "select * from appcoodes_kw where parentid=${pid}$"
|
||
r = await sor.sqlExe(sql, {'pid': pid})
|
||
return r
|
||
|
||
async def sqlor_op():
|
||
db = DBPools()
|
||
env = ServerEnv()
|
||
dbname = env.get_module_dbname()
|
||
async with db.sqlorContext(dbname) as sor:
|
||
id = env.uuid()
|
||
# 事务中，如果代码或sql失败全部滚回，正常结束自动提交
|
||
await sor.C('user', {'id':id, 'username':'john'})
|
||
# 添加数据表“user”数据
|
||
await sor.D('user', {'id': 'yuewfiuwe'})
|
||
# await sor.U('user', {'id', 'email':'test@abc.com'})
|
||
# await sor.R('user', {'id': 'yuewfiuwe'})
|
||
return subcoro(sor, 'test_data')
|
||
```
|