equal
deleted
inserted
replaced
408 assert isinstance(sql, basestring), repr(sql) |
408 assert isinstance(sql, basestring), repr(sql) |
409 try: |
409 try: |
410 cursor = self.doexec(session, sql, args) |
410 cursor = self.doexec(session, sql, args) |
411 except (self.OperationalError, self.InterfaceError): |
411 except (self.OperationalError, self.InterfaceError): |
412 # FIXME: better detection of deconnection pb |
412 # FIXME: better detection of deconnection pb |
413 self.info("request failed '%s' ... retry with a new cursor", sql) |
413 self.warning("trying to reconnect") |
414 session.pool.reconnect(self) |
414 session.pool.reconnect(self) |
415 cursor = self.doexec(session, sql, args) |
415 cursor = self.doexec(session, sql, args) |
416 results = self.process_result(cursor, cbs) |
416 results = self.process_result(cursor, cbs) |
417 assert dbg_results(results) |
417 assert dbg_results(results) |
418 return results |
418 return results |