bugfix
This commit is contained in:
parent
accd07844d
commit
89a9756b00
10
sqlor/sor.py
10
sqlor/sor.py
@ -172,7 +172,7 @@ class SQLor(object):
|
|||||||
return self.cur
|
return self.cur
|
||||||
|
|
||||||
def recordCnt(self,sql):
|
def recordCnt(self,sql):
|
||||||
ret = u"""select count(*) rcnt from (%s) rowcount_table""" % sql
|
ret = """select count(*) rcnt from (%s) rowcount_table""" % sql
|
||||||
return ret
|
return ret
|
||||||
|
|
||||||
def sortSQL(self, sql, NS):
|
def sortSQL(self, sql, NS):
|
||||||
@ -307,9 +307,13 @@ class SQLor(object):
|
|||||||
|
|
||||||
async def fetchone(self, cur):
|
async def fetchone(self, cur):
|
||||||
if inspect.iscoroutinefunction(cur.fetchone):
|
if inspect.iscoroutinefunction(cur.fetchone):
|
||||||
return await cur.fetchone()
|
ret = await cur.fetchone()
|
||||||
|
debug(f'coro:sor.fetchone()={ret}, {type(ret)}')
|
||||||
|
return ret
|
||||||
f = awaitify(cur.fetchone)
|
f = awaitify(cur.fetchone)
|
||||||
return await f()
|
ret = await f()
|
||||||
|
debug(f'func:sor.fetchone()={ret}, {type(ret)}')
|
||||||
|
return ret
|
||||||
|
|
||||||
async def execute(self, sql, value):
|
async def execute(self, sql, value):
|
||||||
sqltype = self.getSqlType(sql)
|
sqltype = self.getSqlType(sql)
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user