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

bugfix

Browse Source
This commit is contained in:
yumoqing 2019-10-22 14:58:21 +08:00
parent 88909b1b01
commit 1ebf4836f1
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
sqlor/dbpools.py
View File

@ -222,7 +222,7 @@ class DBPools:
def inSqlor(self,func): def inSqlor(self,func):
@wraps(func) @wraps(func)
async def wrap_func(dbname,NS,*args,**kw): async def wrap_func(dbname,NS,*args,**kw):
sor, commit = self.useOrGetSor(dbname, **kw) sor, commit = await self.useOrGetSor(dbname, **kw)
kw['sor'] = sor kw['sor'] = sor
try: try:
ret = await func(dbname,NS,*args,**kw) ret = await func(dbname,NS,*args,**kw)
@ -251,7 +251,7 @@ class DBPools:
def runSQL(self,func): def runSQL(self,func):
@wraps(func) @wraps(func)
async def wrap_func(dbname,NS,*args,**kw): async def wrap_func(dbname,NS,*args,**kw):
sor, commit = self.useOrGetSor(dbname,**kw) sor, commit = await self.useOrGetSor(dbname,**kw)
kw['sor'] = sor kw['sor'] = sor
ret = None ret = None
try: try:
@ -286,7 +286,7 @@ class DBPools:
def runSQLPaging(self,func): def runSQLPaging(self,func):
@wraps(func) @wraps(func)
async def wrap_func(dbname,NS,*args,**kw): async def wrap_func(dbname,NS,*args,**kw):
sor, commit = self.useOrGetSor(dbname,**kw) sor, commit = await self.useOrGetSor(dbname,**kw)
kw['sor'] = sor kw['sor'] = sor
try: try:
desc = await func(dbname,NS,*args,**kw) desc = await func(dbname,NS,*args,**kw)
@ -308,7 +308,7 @@ class DBPools:
async def runSQLResultFields(self, func): async def runSQLResultFields(self, func):
@wraps(func) @wraps(func)
async def wrap_func(dbname,NS,*args,**kw): async def wrap_func(dbname,NS,*args,**kw):
sor, commit = self.useOrGetSor(dbname,**kw) sor, commit = await self.useOrGetSor(dbname,**kw)
kw['sor'] = sor kw['sor'] = sor
try: try:
desc = await func(dbname,NS,*args,**kw) desc = await func(dbname,NS,*args,**kw)