Commit 33203331 authored by Jeremy Hylton's avatar Jeremy Hylton

Use an explicit transaction manager instead of setLocalTransaction().

parent 5d014c8f
...@@ -259,23 +259,23 @@ class ZODBTests(unittest.TestCase): ...@@ -259,23 +259,23 @@ class ZODBTests(unittest.TestCase):
# error because the object state read is not necessarily # error because the object state read is not necessarily
# consistent with the objects read earlier in the transaction. # consistent with the objects read earlier in the transaction.
conn = self._db.open(mvcc=False) tm1 = transaction.TransactionManager()
conn.setLocalTransaction() conn = self._db.open(mvcc=False, txn_mgr=tm1)
r1 = conn.root() r1 = conn.root()
r1["p"] = self.obj r1["p"] = self.obj
self.obj.child1 = P() self.obj.child1 = P()
conn.getTransaction().commit() tm1.get().commit()
# start a new transaction with a new connection # start a new transaction with a new connection
cn2 = self._db.open(mvcc=False) tm2 = transaction.TransactionManager()
cn2 = self._db.open(mvcc=False, txn_mgr=tm2)
# start a new transaction with the other connection # start a new transaction with the other connection
cn2.setLocalTransaction()
r2 = cn2.root() r2 = cn2.root()
self.assertEqual(r1._p_serial, r2._p_serial) self.assertEqual(r1._p_serial, r2._p_serial)
self.obj.child2 = P() self.obj.child2 = P()
conn.getTransaction().commit() tm1.get().commit()
# resume the transaction using cn2 # resume the transaction using cn2
obj = r2["p"] obj = r2["p"]
...@@ -287,7 +287,7 @@ class ZODBTests(unittest.TestCase): ...@@ -287,7 +287,7 @@ class ZODBTests(unittest.TestCase):
else: else:
# make sure that accessing the object succeeds # make sure that accessing the object succeeds
obj.child1 obj.child1
cn2.getTransaction().abort() tm2.get().abort()
def checkReadConflictIgnored(self): def checkReadConflictIgnored(self):
# Test that an application that catches a read conflict and # Test that an application that catches a read conflict and
...@@ -303,8 +303,8 @@ class ZODBTests(unittest.TestCase): ...@@ -303,8 +303,8 @@ class ZODBTests(unittest.TestCase):
get_transaction().commit() get_transaction().commit()
# load some objects from one connection # load some objects from one connection
cn2 = self._db.open(mvcc=False) tm = transaction.TransactionManager()
cn2.setLocalTransaction() cn2 = self._db.open(mvcc=False, txn_mgr=tm)
r2 = cn2.root() r2 = cn2.root()
real_data2 = r2["real_data"] real_data2 = r2["real_data"]
index2 = r2["index"] index2 = r2["index"]
...@@ -331,7 +331,7 @@ class ZODBTests(unittest.TestCase): ...@@ -331,7 +331,7 @@ class ZODBTests(unittest.TestCase):
self.assert_(not index2[0]._p_changed) self.assert_(not index2[0]._p_changed)
self.assert_(not index2[1]._p_changed) self.assert_(not index2[1]._p_changed)
self.assertRaises(ConflictError, cn2.getTransaction().commit) self.assertRaises(ConflictError, tm.get().commit)
get_transaction().abort() get_transaction().abort()
def checkIndependent(self): def checkIndependent(self):
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment