Changeset 1764 in products

Timestamp:

Feb 17, 2010 8:08:50 PM (14 years ago)

Author:

mylan

Message:

Added subtransaction support to utility

File:

• quintagroup.catalogupdater/trunk/quintagroup/catalogupdater/utility.py (modified) (3 diffs)

quintagroup.catalogupdater/trunk/quintagroup/catalogupdater/utility.py

@@ -1 +1 @@
 import logging, types
+import transaction
 from zope.interface import implements
 from zope.component import queryMultiAdapter
@@ -72 +73 @@
         schema = _catalog.schema
         paths = _catalog.paths
+        # For subtransaction support
+        threshold = getattr(catalog, 'threshold', 10000)
+        _v_total = 0
+        _v_transaction = None
 
         # For each catalog record update metadata
@@ -97 +102 @@
             data[rid] = tuple(mdlist)
 
+            # Steeled from ZCatalog
+            if threshold is not None:
+                # figure out whether or not to commit a subtransaction.
+                t = id(transaction.get())
+                if t != _v_transaction:
+                    _v_total = 0
+                _v_transaction = t
+                _v_total = _v_total + 1
+                if _v_total > threshold:
+                    transaction.savepoint(optimistic=True)
+                    catalog._p_jar.cacheGC()
+                    _v_total = 0
+                    LOG.info('commiting subtransaction')
+