equal
deleted
inserted
replaced
450 self.warning("trying to reconnect") |
450 self.warning("trying to reconnect") |
451 session.pool.reconnect(self) |
451 session.pool.reconnect(self) |
452 cursor = self.doexec(session, sql, args) |
452 cursor = self.doexec(session, sql, args) |
453 else: |
453 else: |
454 raise |
454 raise |
455 |
455 results = self.process_result(cursor, cbs, session=session) |
456 results = self.process_result(cursor, cbs) |
|
457 assert dbg_results(results) |
456 assert dbg_results(results) |
458 return results |
457 return results |
459 |
458 |
460 def flying_insert(self, table, session, union, args=None, varmap=None): |
459 def flying_insert(self, table, session, union, args=None, varmap=None): |
461 """similar as .syntax_tree_search, but inserts data in the |
460 """similar as .syntax_tree_search, but inserts data in the |