[Zodb-checkins] CVS: Zope3/src/zodb/storage/tests - version.py:1.8 undo.py:1.12 test_memory.py:1.2 test_fsindex.py:1.3 test_file.py:1.11 packable.py:1.8 base.py:1.15

Jeremy Hylton jeremy at zope.com
Tue Apr 22 12:23:43 EDT 2003


Update of /cvs-repository/Zope3/src/zodb/storage/tests
In directory cvs.zope.org:/tmp/cvs-serv13741/tests

Modified Files:
	version.py undo.py test_memory.py test_fsindex.py test_file.py 
	packable.py base.py 
Log Message:
Merge the jeremy-new-pack-branch to the trunk.

The primary change is a completely new implementation of file storage pack.


=== Zope3/src/zodb/storage/tests/version.py 1.7 => 1.8 ===
--- Zope3/src/zodb/storage/tests/version.py:1.7	Thu Mar 20 18:01:41 2003
+++ Zope3/src/zodb/storage/tests/version.py	Tue Apr 22 11:23:12 2003
@@ -336,7 +336,51 @@
 
         snooze()
         self._storage.pack(time.time())
+        
+        db.commitVersion("testversion")
+        txn = get_transaction()
+        txn.note("commit version")
+        txn.commit()
+        
+        cn = db.open()
+        root = cn.root()
+        root["obj"] = "no version"
+
+        txn = get_transaction()
+        txn.note("modify obj")
+        txn.commit()
+
+        self._storage.pack(time.time())
+
+    def testPackVersionsInPast(self):
+        db = DB(self._storage)
+        cn = db.open(version="testversion")
+        root = cn.root()
+
+        obj = root["obj"] = MinPO("obj")
+        root["obj2"] = MinPO("obj2")
+        txn = get_transaction()
+        txn.note("create 2 objs in version")
+        txn.commit()
+
+        obj.value = "77"
+        txn = get_transaction()
+        txn.note("modify obj in version")
+        txn.commit()
 
+        t0 = time.time()
+        snooze()
+
+        # undo the modification to generate a mix of backpointers
+        # and versions for pack to chase
+        info = db.undoInfo()
+        db.undo(info[0]["id"])
+        txn = get_transaction()
+        txn.note("undo modification")
+        txn.commit()
+
+        self._storage.pack(t0)
+        
         db.commitVersion("testversion")
         txn = get_transaction()
         txn.note("commit version")
@@ -352,3 +396,64 @@
 
         self._storage.pack(time.time())
 
+    def testPackVersionReachable(self):
+        db = DB(self._storage)
+        cn = db.open()
+        root = cn.root()
+
+        names = "a", "b", "c"
+
+        for name in names:
+            root[name] = MinPO(name)
+            get_transaction().commit()
+
+        for name in names:
+            cn2 = db.open(version=name)
+            rt2 = cn2.root()
+            obj = rt2[name]
+            obj.value = MinPO("version")
+            get_transaction().commit()
+            cn2.close()
+
+        root["d"] = MinPO("d")
+        get_transaction().commit()
+
+        self._storage.pack(time.time())
+        cn.sync()
+        cn._cache.clear()
+
+        # make sure all the non-version data is there
+        for name, obj in root.items():
+            self.assertEqual(name, obj.value)
+
+        # make sure all the version-data is there,
+        # and create a new revision in the version
+        for name in names:
+            cn2 = db.open(version=name)
+            rt2 = cn2.root()
+            obj = rt2[name].value
+            self.assertEqual(obj.value, "version")
+            obj.value = "still version"
+            get_transaction().commit()
+            cn2.close()
+
+        db.abortVersion("b")
+        txn = get_transaction()
+        txn.note("abort version b")
+        txn.commit()
+
+        t = time.time()
+        snooze()
+        
+        L = db.undoInfo()
+        db.undo(L[0]["id"])
+        txn = get_transaction()
+        txn.note("undo abort")
+        txn.commit()
+        
+        self._storage.pack(t)
+
+        cn2 = db.open(version="b")
+        rt2 = cn2.root()
+        self.assertEqual(rt2["b"].value.value, "still version")
+            


=== Zope3/src/zodb/storage/tests/undo.py 1.11 => 1.12 ===
--- Zope3/src/zodb/storage/tests/undo.py:1.11	Thu Apr 10 03:27:30 2003
+++ Zope3/src/zodb/storage/tests/undo.py	Tue Apr 22 11:23:12 2003
@@ -21,6 +21,14 @@
 class C(Persistent):
     pass
 
+def listeq(L1, L2):
+    """Return True if L1.sort() == L2.sort()"""
+    c1 = L1[:]
+    c2 = L2[:]
+    c1.sort()
+    c2.sort()
+    return c1 == c2
+
 class TransactionalUndoStorage:
 
     def _transaction_begin(self):
@@ -389,7 +397,6 @@
         eq(zodb_unpickle(data), MinPO(54))
         self._iterate()
 
-
     def testNotUndoable(self):
         eq = self.assertEqual
         # Set things up so we've got a transaction that can't be undone
@@ -540,6 +547,98 @@
         eq(o1.obj, o2)
         eq(o1.obj.obj, o3)
         self._iterate()
+
+    def testPackAfterUndoDeletion(self):
+        db = DB(self._storage)
+        cn = db.open()
+        root = cn.root()
+
+        pack_times = []
+        def set_pack_time():
+            snooze()
+            pack_times.append(time.time())
+
+        root["key0"] = MinPO(0)
+        root["key1"] = MinPO(1)
+        root["key2"] = MinPO(2)
+        txn = get_transaction()
+        txn.note("create 3 keys")
+        txn.commit()
+
+        set_pack_time()
+
+        del root["key1"]
+        txn = get_transaction()
+        txn.note("delete 1 key")
+        txn.commit()
+
+        set_pack_time()
+        
+        root._p_deactivate()
+        cn.sync()
+        self.assert_(listeq(root.keys(), ["key0", "key2"]))
+        
+        L = db.undoInfo()
+        db.undo(L[0]["id"])
+        txn = get_transaction()
+        txn.note("undo deletion")
+        txn.commit()
+
+        set_pack_time()
+
+        root._p_deactivate()
+        cn.sync()
+        self.assert_(listeq(root.keys(), ["key0", "key1", "key2"]))
+        
+        for t in pack_times:
+            self._storage.pack(t)
+
+            root._p_deactivate()
+            cn.sync()
+            self.assert_(listeq(root.keys(), ["key0", "key1", "key2"]))
+            for i in range(3):
+                obj = root["key%d" % i]
+                self.assertEqual(obj.value, i)
+            root.items()
+
+    def testPackAfterUndoManyTimes(self):
+        db = DB(self._storage)
+        cn = db.open()
+        rt = cn.root()
+
+        rt["test"] = MinPO(1)
+        get_transaction().commit()
+        rt["test2"] = MinPO(2)
+        get_transaction().commit()
+        rt["test"] = MinPO(3)
+        txn = get_transaction()
+        txn.note("root of undo")
+        txn.commit()
+
+        packtimes = []
+        for i in range(10):
+            L = db.undoInfo()
+            db.undo(L[0]["id"])
+            txn = get_transaction()
+            txn.note("undo %d" % i)
+            txn.commit()
+            rt._p_deactivate()
+            cn.sync()
+
+            self.assertEqual(rt["test"].value, i % 2 and 3 or 1)
+            self.assertEqual(rt["test2"].value, 2)
+            
+            packtimes.append(time.time())
+            snooze()
+
+        for t in packtimes:
+            self._storage.pack(t)
+            cn.sync()
+            cn._cache.clear()
+            # The last undo set the value to 3 and pack should
+            # never change that.
+            self.assertEqual(rt["test"].value, 3)
+            self.assertEqual(rt["test2"].value, 2)
 
     def testTransactionalUndoIterator(self):
         # check that data_txn set in iterator makes sense


=== Zope3/src/zodb/storage/tests/test_memory.py 1.1 => 1.2 ===
--- Zope3/src/zodb/storage/tests/test_memory.py:1.1	Thu Mar 20 18:02:10 2003
+++ Zope3/src/zodb/storage/tests/test_memory.py	Tue Apr 22 11:23:12 2003
@@ -45,7 +45,7 @@
     def open(self, read_only=False):
         config = BerkeleyConfig()
         config.read_only = read_only
-        self._storage = MemoryFullStorage(config)
+        self._storage = MemoryFullStorage('memory', config=config)
 
     def setUp(self):
         self.open()
@@ -70,7 +70,7 @@
     def open(self, read_only=False):
         config = BerkeleyConfig()
         config.read_only = read_only
-        self._storage = MemoryMinimalStorage(config)
+        self._storage = MemoryMinimalStorage('memory', config=config)
 
     def setUp(self):
         self.open()


=== Zope3/src/zodb/storage/tests/test_fsindex.py 1.2 => 1.3 ===
--- Zope3/src/zodb/storage/tests/test_fsindex.py:1.2	Wed Dec 25 09:12:20 2002
+++ Zope3/src/zodb/storage/tests/test_fsindex.py	Tue Apr 22 11:23:12 2003
@@ -13,7 +13,7 @@
 ##############################################################################
 
 import unittest, sys
-from zodb.storage.fsindex import fsIndex
+from zodb.storage.file.index import fsIndex
 from zodb.utils import p64
 
 


=== Zope3/src/zodb/storage/tests/test_file.py 1.10 => 1.11 ===
--- Zope3/src/zodb/storage/tests/test_file.py:1.10	Thu Mar 20 18:01:41 2003
+++ Zope3/src/zodb/storage/tests/test_file.py	Tue Apr 22 11:23:12 2003
@@ -67,8 +67,8 @@
             copy = zodb.storage.file.FileStorage('FileStorageTests.fs',
                                                  read_only=True)
         except:
-            from zodb.storage.fsdump import Dumper
-            Dumper("FileStorageTests.fs").dump()
+            from zodb.storage.file.dump import dump
+            dump("FileStorageTests.fs")
             raise
 
         L1 = copy._index.items()


=== Zope3/src/zodb/storage/tests/packable.py 1.7 => 1.8 ===
--- Zope3/src/zodb/storage/tests/packable.py:1.7	Thu Mar 20 18:01:41 2003
+++ Zope3/src/zodb/storage/tests/packable.py	Tue Apr 22 11:23:12 2003
@@ -23,7 +23,7 @@
 from zodb.ztransaction import Transaction
 from zodb.storage.tests.minpo import MinPO
 from zodb.storage.tests.base import zodb_unpickle, snooze
-from zodb.storage.fsdump import dump
+from zodb.storage.file.dump import dump
 
 
 


=== Zope3/src/zodb/storage/tests/base.py 1.14 => 1.15 ===
--- Zope3/src/zodb/storage/tests/base.py:1.14	Wed Apr 16 18:06:21 2003
+++ Zope3/src/zodb/storage/tests/base.py	Tue Apr 22 11:23:12 2003
@@ -32,6 +32,7 @@
 
 from zodb.db import DB
 from zodb.serialize import ConnectionObjectReader, ObjectWriter, findrefs
+from zodb.conflict import ResolveObjectReader
 from zodb.ztransaction import Transaction
 from zodb.storage.tests.minpo import MinPO
 from zodb.storage.base import ZERO, BerkeleyConfig
@@ -61,7 +62,9 @@
 
 def zodb_unpickle(data):
     """Unpickle an object stored using the format expected by ZODB."""
-    u = ConnectionObjectReader(None, FakeCache())
+    # Use a ResolveObjectReader because we don't want to load any
+    # object referenced by this one.
+    u = ResolveObjectReader()
     return u.getObject(data)
 
 def handle_all_serials(oid, *args):




More information about the Zodb-checkins mailing list