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

bugfix

Browse Source
This commit is contained in:
yumoqing 2026-05-16 16:26:03 +08:00
parent 132c11ae8f
commit ac338642c6
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
sqlor/sor.py
View File

@ -608,13 +608,13 @@ class SQLor(object):
sql = 'insert into %s.%s (%s) values (%s)' % (self.dbname, tablename,fns,vfns) sql = 'insert into %s.%s (%s) values (%s)' % (self.dbname, tablename,fns,vfns)
rf = RegisterFunction() rf = RegisterFunction()
rfname = f'{self.dbname}:{tablename}:c:before' rfname = f'{self.dbname}:{tablename}:c:before'
self.dbpools.dispatch(rfname, ns) await self.dbpools.dispatch(rfname, ns)
ret = await rf.exe(rfname, ns) ret = await rf.exe(rfname, ns)
if isinstance(ret, dict): if isinstance(ret, dict):
ns.update(ret) ns.update(ret)
r = await self.execute(sql,ns.copy()) r = await self.execute(sql,ns.copy())
rfname = f'{self.dbname}:{tablename}:c:after' rfname = f'{self.dbname}:{tablename}:c:after'
self.dbpools.dispatch(rfname, ns) await self.dbpools.dispatch(rfname, ns)
await rf.exe(rfname, ns) await rf.exe(rfname, ns)
return r return r
@ -660,13 +660,13 @@ class SQLor(object):
u_str,c_str) u_str,c_str)
rf = RegisterFunction() rf = RegisterFunction()
rfname = f'{self.dbname}:{tablename}:u:before' rfname = f'{self.dbname}:{tablename}:u:before'
self.dbpools.dispatch(rfname, ns) await self.dbpools.dispatch(rfname, ns)
ret = await rf.exe(rfname, ns) ret = await rf.exe(rfname, ns)
if isinstance(ret, dict): if isinstance(ret, dict):
ns.update(ret) ns.update(ret)
r = await self.execute(sql, ns.copy()) r = await self.execute(sql, ns.copy())
rfname = f'{self.dbname}:{tablename}:u:after' rfname = f'{self.dbname}:{tablename}:u:after'
self.dbpools.dispatch(rfname, ns) await self.dbpools.dispatch(rfname, ns)
await rf.exe(rfname, ns) await rf.exe(rfname, ns)
return r return r
@ -684,7 +684,7 @@ class SQLor(object):
ns.update(ret) ns.update(ret)
r = await self.execute(sql, ns) r = await self.execute(sql, ns)
rfname = f'{self.dbname}:{tablename}:d:after' rfname = f'{self.dbname}:{tablename}:d:after'
self.dbpools.dispatch(rfname, ns) await self.dbpools.dispatch(rfname, ns)
ns = await rf.exe(rfname, ns) ns = await rf.exe(rfname, ns)
return r return r