diff --git a/sqlor/sor.py b/sqlor/sor.py index 74d7e21..717c495 100755 --- a/sqlor/sor.py +++ b/sqlor/sor.py @@ -14,7 +14,7 @@ from appPublic.unicoding import uDict from appPublic.myTE import MyTemplateEngine from appPublic.objectAction import ObjectAction from appPublic.argsConvert import ArgsConvert,ConditionConvert -from appPublic.registerfunction import RegisterCoroutine +from appPublic.registerfunction import RegisterFunction from appPublic.log import info from .filter import DBFilter @@ -607,7 +607,7 @@ class SQLor(object): fns = ','.join(fields) vfns = ','.join(['${%s}$' % n for n in fields ]) sql = 'insert into %s.%s (%s) values (%s)' % (self.dbname, tablename,fns,vfns) - rf = RegisterCoroutine() + rf = RegisterFunction() rfname = f'{self.dbname}:{tablename}:c:before' ns = await rf.exe(rfname, ns) r = await self.runSQL({'sql_string':sql},ns,None) @@ -657,7 +657,7 @@ class SQLor(object): u_str = ','.join(u) sql = 'update %s.%s set %s where %s' % (self.dbname, tablename, u_str,c_str) - rf = RegisterCoroutine() + rf = RegisterFunction() ns = await rf.exe(f'{self.dbname}:{tablename}:u:before',ns) if func: ns = func(ns) @@ -672,7 +672,7 @@ class SQLor(object): c = [ '%s = ${%s}$' % (i,i) for i in condi ] c_str = ' and '.join(c) sql = 'delete from %s.%s where %s' % (self.dbname, tablename,c_str) - rf = RegisterCoroutine() + rf = RegisterFunction() ns = await rf.exe(f'{self.dbname}:{tablename}:d:before', ns) r = await self.runSQL({'sql_string':sql},ns,None) ns = await rf.get(f'{self.dbname}:{tablename}:d:after', ns)