From 1ebf4836f1848497f4eb06d2ac7b42e548c67711 Mon Sep 17 00:00:00 2001 From: yumoqing Date: Tue, 22 Oct 2019 14:58:21 +0800 Subject: [PATCH] bugfix --- sqlor/dbpools.py | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/sqlor/dbpools.py b/sqlor/dbpools.py index 8ef140a..03fa1cb 100644 --- a/sqlor/dbpools.py +++ b/sqlor/dbpools.py @@ -222,7 +222,7 @@ class DBPools: def inSqlor(self,func): @wraps(func) async def wrap_func(dbname,NS,*args,**kw): - sor, commit = self.useOrGetSor(dbname, **kw) + sor, commit = await self.useOrGetSor(dbname, **kw) kw['sor'] = sor try: ret = await func(dbname,NS,*args,**kw) @@ -251,7 +251,7 @@ class DBPools: def runSQL(self,func): @wraps(func) async def wrap_func(dbname,NS,*args,**kw): - sor, commit = self.useOrGetSor(dbname,**kw) + sor, commit = await self.useOrGetSor(dbname,**kw) kw['sor'] = sor ret = None try: @@ -286,7 +286,7 @@ class DBPools: def runSQLPaging(self,func): @wraps(func) async def wrap_func(dbname,NS,*args,**kw): - sor, commit = self.useOrGetSor(dbname,**kw) + sor, commit = await self.useOrGetSor(dbname,**kw) kw['sor'] = sor try: desc = await func(dbname,NS,*args,**kw) @@ -308,7 +308,7 @@ class DBPools: async def runSQLResultFields(self, func): @wraps(func) async def wrap_func(dbname,NS,*args,**kw): - sor, commit = self.useOrGetSor(dbname,**kw) + sor, commit = await self.useOrGetSor(dbname,**kw) kw['sor'] = sor try: desc = await func(dbname,NS,*args,**kw)