bugfix
This commit is contained in:
parent
d47ae51269
commit
74c3b0dc29
@ -213,11 +213,17 @@ class DBPools:
|
|||||||
sor = await self.getSqlor(dbname)
|
sor = await self.getSqlor(dbname)
|
||||||
try:
|
try:
|
||||||
ret = await func(sor,dbname,*args,**kw)
|
ret = await func(sor,dbname,*args,**kw)
|
||||||
|
try:
|
||||||
await sor.conn.commit()
|
await sor.conn.commit()
|
||||||
|
except:
|
||||||
|
pass
|
||||||
return ret
|
return ret
|
||||||
except Exception as e:
|
except Exception as e:
|
||||||
print('error',sor)
|
print('error',sor)
|
||||||
sor.conn.rollback()
|
try:
|
||||||
|
await sor.conn.rollback()
|
||||||
|
except:
|
||||||
|
pass
|
||||||
raise e
|
raise e
|
||||||
finally:
|
finally:
|
||||||
await self.freeSqlor(sor)
|
await self.freeSqlor(sor)
|
||||||
@ -232,14 +238,20 @@ class DBPools:
|
|||||||
try:
|
try:
|
||||||
desc = await func(dbname,NS,callback=callback,**kw)
|
desc = await func(dbname,NS,callback=callback,**kw)
|
||||||
ret = await sor.runSQL(desc,NS,callback,**kw)
|
ret = await sor.runSQL(desc,NS,callback,**kw)
|
||||||
|
try:
|
||||||
await sor.conn.commit()
|
await sor.conn.commit()
|
||||||
|
except:
|
||||||
|
pass
|
||||||
if NS.get('dummy'):
|
if NS.get('dummy'):
|
||||||
return NS['dummy']
|
return NS['dummy']
|
||||||
else:
|
else:
|
||||||
return []
|
return []
|
||||||
except Exception as e:
|
except Exception as e:
|
||||||
print('error:',e)
|
print('error:',e)
|
||||||
|
try:
|
||||||
await sor.conn.rollback()
|
await sor.conn.rollback()
|
||||||
|
except:
|
||||||
|
pass
|
||||||
raise e
|
raise e
|
||||||
finally:
|
finally:
|
||||||
await self.freeSqlor(sor)
|
await self.freeSqlor(sor)
|
||||||
|
Loading…
Reference in New Issue
Block a user