yumoqing/tenant
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix: use get_sor_context(env, 'tenant') — proper sqlor/dspy cross-db pattern

Browse Source
This commit is contained in:
yumoqing 2026-07-09 13:19:55 +08:00
parent 3be62ba01c
commit 3a5b9068d9
4 changed files with 8 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
wwwroot/api/tenant_domain_create.dspy
View File

@ -4,7 +4,7 @@ for k,v in ns.items():
ns[k] = None ns[k] = None
if not ns.get("id"): if not ns.get("id"):
ns["id"] = getID() ns["id"] = getID()
db = DBPools() env = request._run_ns
async with db.sqlorContext("pipeline") as sor: async with get_sor_context(env, "tenant") as sor:
await sor.C("tenant_domain", ns) await sor.C("tenant_domain", ns)
return {"status": "ok"} return {"status": "ok"}

4
wwwroot/api/tenant_domain_delete.dspy
View File

@ -3,7 +3,7 @@ rid = ns.get("id")
if not rid: if not rid:
return {"status": "error", "message": "id required"} return {"status": "error", "message": "id required"}
ns["rid"] = rid ns["rid"] = rid
db = DBPools() env = request._run_ns
async with db.sqlorContext("pipeline") as sor: async with get_sor_context(env, "tenant") as sor:
await sor.sqlExe("DELETE FROM tenant_domain WHERE id=${rid}$", ns) await sor.sqlExe("DELETE FROM tenant_domain WHERE id=${rid}$", ns)
return {"status": "ok"} return {"status": "ok"}

4
wwwroot/api/tenant_domain_get.dspy
View File

@ -7,8 +7,8 @@ pagerows = int(ns.get("rows", 20))
offset = (page - 1) * pagerows offset = (page - 1) * pagerows
ns["pagerows"] = pagerows ns["pagerows"] = pagerows
ns["offset"] = offset ns["offset"] = offset
db = DBPools() env = request._run_ns
async with db.sqlorContext("pipeline") as sor: async with get_sor_context(env, "tenant") as sor:
recs = await sor.sqlExe("SELECT count(*) as total FROM tenant_domain", {}) recs = await sor.sqlExe("SELECT count(*) as total FROM tenant_domain", {})
total = recs[0].total if recs else 0 total = recs[0].total if recs else 0
recs = await sor.sqlExe("SELECT * FROM tenant_domain ORDER BY created_at desc LIMIT ${pagerows}$ OFFSET ${offset}$", ns) recs = await sor.sqlExe("SELECT * FROM tenant_domain ORDER BY created_at desc LIMIT ${pagerows}$ OFFSET ${offset}$", ns)

4
wwwroot/api/tenant_domain_update.dspy
View File

@ -6,7 +6,7 @@ rid = ns.get("id")
if not rid: if not rid:
return {"status": "error", "message": "id required"} return {"status": "error", "message": "id required"}
ns["rid"] = rid ns["rid"] = rid
db = DBPools() env = request._run_ns
async with db.sqlorContext("pipeline") as sor: async with get_sor_context(env, "tenant") as sor:
await sor.sqlExe("UPDATE tenant_domain SET domain=${domain}$, resellerid=${resellerid}$, orgid=${orgid}$, status=${status}$ WHERE id=${rid}$", ns) await sor.sqlExe("UPDATE tenant_domain SET domain=${domain}$, resellerid=${resellerid}$, orgid=${orgid}$, status=${status}$ WHERE id=${rid}$", ns)
return {"status": "ok"} return {"status": "ok"}