equal
deleted
inserted
replaced
288 print 'exec', query, args |
288 print 'exec', query, args |
289 cursor = session.cnxset[self.uri] |
289 cursor = session.cnxset[self.uri] |
290 try: |
290 try: |
291 # str(query) to avoid error if it's an unicode string |
291 # str(query) to avoid error if it's an unicode string |
292 cursor.execute(str(query), args) |
292 cursor.execute(str(query), args) |
293 except Exception, ex: |
293 except Exception as ex: |
294 self.critical("sql: %r\n args: %s\ndbms message: %r", |
294 self.critical("sql: %r\n args: %s\ndbms message: %r", |
295 query, args, ex.args[0]) |
295 query, args, ex.args[0]) |
296 try: |
296 try: |
297 session.cnxset.connection(self.uri).rollback() |
297 session.cnxset.connection(self.uri).rollback() |
298 self.critical('transaction has been rollbacked') |
298 self.critical('transaction has been rollbacked') |