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

bugfix

Browse Source
This commit is contained in:
yumoqing 2025-10-19 11:42:14 +08:00
parent 9f12e041ce
commit 91e717d80f
1 changed files with 1 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
sqlor/sor.py
View File

@ -311,20 +311,9 @@ class SQLor(object):
sqltype = self.getSqlType(sql) sqltype = self.getSqlType(sql)
cur = self.cursor() cur = self.cursor()
ret = await self.runVarSQL(cur,sql,value) ret = await self.runVarSQL(cur,sql,value)
if sqltype == 'qry' and callback is not None:
fields = [ i[0].lower() for i in cur.description ]
while True:
rec = await self.fetchone(cur)
if rec is None:
break
dic = {}
for i in range(len(fields)):
dic.update({fields[i] : db_type_2_py_type(rec[i])})
dic = DictObject(**dic)
yield dic
if sqltype == 'dml': if sqltype == 'dml':
self.dataChanged = True self.dataChanged = True
return ret return ret
async def _get_data(self, sql, ns): async def _get_data(self, sql, ns):
sqltype = self.getSqlType(sql) sqltype = self.getSqlType(sql)