281             self.mode = 'write'

   281             self.mode = 'write'

   282         source = self.pool.source('system')

   282         source = self.pool.source('system')

   283         try:

   283         try:

   284             return source.doexec(self, sql, args, rollback=rollback_on_failure)

   284             return source.doexec(self, sql, args, rollback=rollback_on_failure)

   285         except (source.OperationalError, source.InterfaceError):

   285         except (source.OperationalError, source.InterfaceError):

   286             source.warning("trying to reconnect")

   288             source.warning("trying to reconnect")

   287             self.pool.reconnect(source)

   289             self.pool.reconnect(source)

   288             return source.doexec(self, sql, args, rollback=rollback_on_failure)

   290             return source.doexec(self, sql, args, rollback=rollback_on_failure)

   289 

   291 

   290     def set_language(self, language):

   292     def set_language(self, language):