From ac338642c63c93c1052b233f5cf9db5501f42e66 Mon Sep 17 00:00:00 2001 From: yumoqing Date: Sat, 16 May 2026 16:26:03 +0800 Subject: [PATCH] bugfix --- sqlor/sor.py | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/sqlor/sor.py b/sqlor/sor.py index 761161a..ec03544 100644 --- a/sqlor/sor.py +++ b/sqlor/sor.py @@ -608,13 +608,13 @@ class SQLor(object): sql = 'insert into %s.%s (%s) values (%s)' % (self.dbname, tablename,fns,vfns) rf = RegisterFunction() rfname = f'{self.dbname}:{tablename}:c:before' - self.dbpools.dispatch(rfname, ns) + await self.dbpools.dispatch(rfname, ns) ret = await rf.exe(rfname, ns) if isinstance(ret, dict): ns.update(ret) r = await self.execute(sql,ns.copy()) rfname = f'{self.dbname}:{tablename}:c:after' - self.dbpools.dispatch(rfname, ns) + await self.dbpools.dispatch(rfname, ns) await rf.exe(rfname, ns) return r @@ -660,13 +660,13 @@ class SQLor(object): u_str,c_str) rf = RegisterFunction() rfname = f'{self.dbname}:{tablename}:u:before' - self.dbpools.dispatch(rfname, ns) + await self.dbpools.dispatch(rfname, ns) ret = await rf.exe(rfname, ns) if isinstance(ret, dict): ns.update(ret) r = await self.execute(sql, ns.copy()) rfname = f'{self.dbname}:{tablename}:u:after' - self.dbpools.dispatch(rfname, ns) + await self.dbpools.dispatch(rfname, ns) await rf.exe(rfname, ns) return r @@ -684,7 +684,7 @@ class SQLor(object): ns.update(ret) r = await self.execute(sql, ns) rfname = f'{self.dbname}:{tablename}:d:after' - self.dbpools.dispatch(rfname, ns) + await self.dbpools.dispatch(rfname, ns) ns = await rf.exe(rfname, ns) return r