equal
deleted
inserted
replaced
749 if rollback: |
749 if rollback: |
750 try: |
750 try: |
751 session.cnxset.connection(self.uri).rollback() |
751 session.cnxset.connection(self.uri).rollback() |
752 if self.repo.config.mode != 'test': |
752 if self.repo.config.mode != 'test': |
753 self.critical('transaction has been rollbacked') |
753 self.critical('transaction has been rollbacked') |
754 except: |
754 except Exception, ex: |
755 pass |
755 pass |
756 if ex.__class__.__name__ == 'IntegrityError': |
756 if ex.__class__.__name__ == 'IntegrityError': |
757 # need string comparison because of various backends |
757 # need string comparison because of various backends |
758 for arg in ex.args: |
758 for arg in ex.args: |
759 mo = re.search('unique_cw_[^ ]+_idx', arg) |
759 mo = re.search('unique_cw_[^ ]+_idx', arg) |
1625 * the table name |
1625 * the table name |
1626 * a tuple of column names |
1626 * a tuple of column names |
1627 * a list of rows (as tuples with one element per column) |
1627 * a list of rows (as tuples with one element per column) |
1628 |
1628 |
1629 Tables are saved in chunks in different files in order to prevent |
1629 Tables are saved in chunks in different files in order to prevent |
1630 a too high memory consumption. |
1630 a too high memory consumption. |
1631 """ |
1631 """ |
1632 def __init__(self, source): |
1632 def __init__(self, source): |
1633 """ |
1633 """ |
1634 :param: source an instance of the system source |
1634 :param: source an instance of the system source |
1635 """ |
1635 """ |