equal
deleted
inserted
replaced
427 self.critical("sql: %r\n args: %s\ndbms message: %r", |
427 self.critical("sql: %r\n args: %s\ndbms message: %r", |
428 query, args, ex.args[0]) |
428 query, args, ex.args[0]) |
429 if rollback: |
429 if rollback: |
430 try: |
430 try: |
431 session.pool.connection(self.uri).rollback() |
431 session.pool.connection(self.uri).rollback() |
432 self.critical('transaction has been rollbacked') |
432 if self.repo.config.mode != 'test': |
|
433 self.critical('transaction has been rollbacked') |
433 except: |
434 except: |
434 pass |
435 pass |
435 raise |
436 raise |
436 return cursor |
437 return cursor |
437 |
438 |
451 # db schema |
452 # db schema |
452 self.critical("sql many: %r\n args: %s\ndbms message: %r", |
453 self.critical("sql many: %r\n args: %s\ndbms message: %r", |
453 query, args, ex.args[0]) |
454 query, args, ex.args[0]) |
454 try: |
455 try: |
455 session.pool.connection(self.uri).rollback() |
456 session.pool.connection(self.uri).rollback() |
456 self.critical('transaction has been rollbacked') |
457 if self.repo.config.mode != 'test': |
|
458 self.critical('transaction has been rollbacked') |
457 except: |
459 except: |
458 pass |
460 pass |
459 raise |
461 raise |
460 |
462 |
461 # short cut to method requiring advanced db helper usage ################## |
463 # short cut to method requiring advanced db helper usage ################## |