Ñò
4äKc @ s+ d Z d d k Z d d k Z d d k Z d d k Z d d k l Z d e i d ƒ Z d „ Z d e i
f d „ ƒ YZ d d d
„ ƒ YZ d e
f d „ ƒ YZ d
d d „ ƒ YZ d e f d „ ƒ YZ d „ Z d „ Z d „ Z d „ Z d „ Z e Z e d j o e i ƒ i e ƒ ƒ n d S( s½ Test transaction behavior for variety of cases.
I wrote these unittests to investigate some odd transaction
behavior when doing unittests of integrating non sub transaction
aware objects, and to insure proper txn behavior. these
tests test the transaction system independent of the rest of the
zodb.
you can see the method calls to a jar by passing the
keyword arg tracing to the modify method of a dataobject.
the value of the arg is a prefix used for tracing print calls
to that objects jar.
the number of times a jar method was called can be inspected
by looking at an attribute of the jar that is the method
name prefixed with a c (count/check).
i've included some tracing examples for tests that i thought
were illuminating as doc strings below.
TODO
add in tests for objects which are modified multiple times,
for example an object that gets modified in multiple sub txns.
$Id: test_transaction.py 112144 2010-05-07 15:35:15Z tseaver $
iÿÿÿÿN( t WarningsHooki t Pc C s? t | ƒ } | d j o" | t 7} | d j p t ‚ n | S( s) Return id(obj) as a non-negative integer.i ( t idt
_ADDRESS_MASKt AssertionError( t objt result( ( sF /usr/lib/python2.6/site-packages/transaction/tests/test_transaction.pyt positive_id2 s
t TransactionTestsc B sk e Z d „ Z d „ Z d „ Z d „ Z d „ Z d „ Z d „ Z d „ Z d „ Z
d „ Z d
„ Z RS( c C sY t i ƒ } | _ t | ƒ | _ t | ƒ | _ t | ƒ | _ t | d d ƒ| _ d S( Nt nosti ( t transactiont TransactionManagert transaction_managert
DataObjectt sub1t sub2t sub3t nosub1( t selft mgr( ( sF /usr/lib/python2.6/site-packages/transaction/tests/test_transaction.pyt setUp= s
c C se | i i ƒ | i i ƒ | i i ƒ | i i i d j p t ‚ | i i i d j p t ‚ d S( Ni i ( R t modifyR R t committ _p_jart ccommit_subR t ctpc_finish( R ( ( sF /usr/lib/python2.6/site-packages/transaction/tests/test_transaction.pyt testTransactionCommitG s
c C sH | i i ƒ | i i ƒ | i i ƒ | i i i d j p t ‚ d S( Ni ( R R R R t abortR t cabortR ( R ( ( sF /usr/lib/python2.6/site-packages/transaction/tests/test_transaction.pyt testTransactionAbortQ s
c C s] | i i ƒ } | i d ƒ | i | i d ƒ | i d ƒ | i | i d ƒ | i ƒ d S( Ns This is a note.s Another.s This is a note.
Another.( R t gett notet assertEqualt descriptionR ( R t t( ( sF /usr/lib/python2.6/site-packages/transaction/tests/test_transaction.pyt testTransactionNoteZ s
c C s; | i i ƒ | i i ƒ | i i i d j p t ‚ d S( Ni ( R R R R R R R ( R ( ( sF /usr/lib/python2.6/site-packages/transaction/tests/test_transaction.pyt testNSJTransactionCommith s
c C sX | i i ƒ | i i ƒ | i i i d j p t ‚ | i i i d j p t ‚ d S( Ni i ( R R R R R R R R ( R ( ( sF /usr/lib/python2.6/site-packages/transaction/tests/test_transaction.pyt testNSJTransactionAbortp s
c C s§ t d d ƒ | i _ | i i ƒ | i i d d ƒ | i i ƒ y | i i ƒ Wn t j
o n X| i i i d j p t
‚ | i i i d j p t
‚ d S( Nt errorsR t nojari ( t BasicJarR R R R R R R t TestTxnExceptionR R ( R ( ( sF /usr/lib/python2.6/site-packages/transaction/tests/test_transaction.pyt testExceptionInAbort„ s
c C s· t d d ƒ | i _ | i i ƒ | i i d d ƒ y | i i ƒ Wn t j
o n X| i i i d j p t ‚ | i i i
d j p t ‚ | i i i d j p t ‚ d S( NR& R R' i i ( R( R R R R R R R) R R t ccommitt
ctpc_abort( R ( ( sF /usr/lib/python2.6/site-packages/transaction/tests/test_transaction.pyt testExceptionInCommit“ s
c C sÔ t d d ƒ | i _ | i i ƒ | i i d d ƒ y | i i ƒ Wn t j
o n X| i i i d j p t ‚ | i i i
d j p t ‚ | i i i d j p t ‚ | i i i d j p t ‚ d S( NR& t tpc_voteR' i i ( R( R R R R R R R) R R R+ R, ( R ( ( sF /usr/lib/python2.6/site-packages/transaction/tests/test_transaction.pyt testExceptionInTpcVote¢ s
c C sš t d d ƒ | i _ | i i ƒ | i i d d ƒ y | i i ƒ Wn t j
o n X| i i i d j p t ‚ | i i i d j p t ‚ d S( sH
ok this test reveals a bug in the TM.py
as the nosub tpc_abort there is ignored.
nosub calling method tpc_begin
nosub calling method commit
sub calling method tpc_begin
sub calling method abort
sub calling method tpc_abort
nosub calling method tpc_abort
R& t tpc_beginR' i N(
R( R R R R R R R) R, R ( R ( ( sF /usr/lib/python2.6/site-packages/transaction/tests/test_transaction.pyt testExceptionInTpcBegin² s
c C s} t d d ƒ | i _ | i i ƒ | i i d d ƒ y | i i ƒ Wn t j
o n X| i i i d j p t ‚ d S( NR& t tpc_abortR. R' i ( s tpc_aborts tpc_vote(
R( R R R R R R R) R, R ( R ( ( sF /usr/lib/python2.6/site-packages/transaction/tests/test_transaction.pyt testExceptionInTpcAbortË s
(
t __name__t
__module__R R R R# R$ R% R* R- R/ R1 R3 ( ( ( sF /usr/lib/python2.6/site-packages/transaction/tests/test_transaction.pyR ; s
R
c B s# e Z d d „ Z d d d „ Z RS( i c C s | | _ | | _ d | _ d S( N( R R t NoneR ( R R R ( ( sF /usr/lib/python2.6/site-packages/transaction/tests/test_transaction.pyt __init__ú s c C sZ | p6 | i o t d | ƒ | _ q= t d | ƒ | _ n | i i ƒ i | i ƒ d S( Nt tracing( R R( R R R t join( R R' R8 ( ( sF /usr/lib/python2.6/site-packages/transaction/tests/test_transaction.pyR ÿ s
( R4 R5 R7 R ( ( ( sF /usr/lib/python2.6/site-packages/transaction/tests/test_transaction.pyR
ø s R) c B s e Z RS( ( R4 R5 ( ( ( sF /usr/lib/python2.6/site-packages/transaction/tests/test_transaction.pyR) s R( c B sk e Z d d d „ Z d „ Z d „ Z d „ Z d „ Z d „ Z d d „ Z d „ Z d „ Z
d
„ Z RS( i c C s{ t | t ƒ p
| f } n | | _ | | _ d | _ d | _ d | _ d | _ d | _ d | _ d | _
d | _ d S( Ni ( t
isinstancet tupleR& R8 R R+ t
ctpc_beginR, t ctpc_voteR t
cabort_subR ( R R& R8 ( ( sF /usr/lib/python2.6/site-packages/transaction/tests/test_transaction.pyR7 s
c C s d | i i t | ƒ | i f S( Ns
<%s %X %s>( t __class__R4 R R& ( R ( ( sF /usr/lib/python2.6/site-packages/transaction/tests/test_transaction.pyt __repr__ s c C s
| i i S( N( R? R4 ( R ( ( sF /usr/lib/python2.6/site-packages/transaction/tests/test_transaction.pyt sortKey s c C sN | i o d t | i ƒ | f GHn | | i j o t d | ƒ ‚ n d S( Ns %s calling method %ss error %s( R8 t strR& R) ( R t method( ( sF /usr/lib/python2.6/site-packages/transaction/tests/test_transaction.pyt check$ s
c G s | i d ƒ | i d 7_ d S( NR i ( RD R ( R t args( ( sF /usr/lib/python2.6/site-packages/transaction/tests/test_transaction.pyR - s
c G s | i d ƒ | i d 7_ d S( NR i ( RD R+ ( R RE ( ( sF /usr/lib/python2.6/site-packages/transaction/tests/test_transaction.pyR 1 s
c C s | i d ƒ | i d 7_ d S( NR0 i ( RD R< ( R t txnt sub( ( sF /usr/lib/python2.6/site-packages/transaction/tests/test_transaction.pyR0 5 s
c G s | i d ƒ | i d 7_ d S( NR. i ( RD R= ( R RE ( ( sF /usr/lib/python2.6/site-packages/transaction/tests/test_transaction.pyR. 9 s
c G s | i d ƒ | i d 7_ d S( NR2 i ( RD R, ( R RE ( ( sF /usr/lib/python2.6/site-packages/transaction/tests/test_transaction.pyR2 = s
c G s | i d ƒ | i d 7_ d S( Nt
tpc_finishi ( RD R ( R RE ( ( sF /usr/lib/python2.6/site-packages/transaction/tests/test_transaction.pyRH A s
( ( R4 R5 R7 R@ RA RD R R R0 R. R2 RH ( ( ( sF /usr/lib/python2.6/site-packages/transaction/tests/test_transaction.pyR(
s t HoserJarc B s) e Z d Z d „ Z d „ Z d „ Z RS( i c C s
d t _ d S( Ni ( RI t committed( R ( ( sF /usr/lib/python2.6/site-packages/transaction/tests/test_transaction.pyt resetM s c C s( t i d j o t i | | ƒ n d S( Ni ( RI RJ R( RD ( R RC ( ( sF /usr/lib/python2.6/site-packages/transaction/tests/test_transaction.pyRD Q s c G s/ | i d ƒ | i d 7_ t i d 7_ d S( NRH i ( RD R RI RJ ( R RE ( ( sF /usr/lib/python2.6/site-packages/transaction/tests/test_transaction.pyRH U s
( R4 R5 RJ RK RD RH ( ( ( sF /usr/lib/python2.6/site-packages/transaction/tests/test_transaction.pyRI E s c C s d S( s‡ White-box test of the join method
The join method is provided for "backward-compatability" with ZODB 4
data managers.
The argument to join must be a zodb4 data manager,
transaction.interfaces.IDataManager.
>>> from transaction.tests.sampledm import DataManager
>>> from transaction._transaction import DataManagerAdapter
>>> t = transaction.Transaction()
>>> dm = DataManager()
>>> t.join(dm)
The end result is that a data manager adapter is one of the
transaction's objects:
>>> isinstance(t._resources[0], DataManagerAdapter)
True
>>> t._resources[0]._datamanager is dm
True
N( ( ( ( sF /usr/lib/python2.6/site-packages/transaction/tests/test_transaction.pyt test_join[ s c C s d S( N( ( ( ( sF /usr/lib/python2.6/site-packages/transaction/tests/test_transaction.pyt hookt s c C s d S( s Test addBeforeCommitHook.
Let's define a hook to call, and a way to see that it was called.
>>> log = []
>>> def reset_log():
... del log[:]
>>> def hook(arg='no_arg', kw1='no_kw1', kw2='no_kw2'):
... log.append("arg %r kw1 %r kw2 %r" % (arg, kw1, kw2))
Now register the hook with a transaction.
>>> import transaction
>>> t = transaction.begin()
>>> t.addBeforeCommitHook(hook, '1')
We can see that the hook is indeed registered.
>>> [(hook.func_name, args, kws)
... for hook, args, kws in t.getBeforeCommitHooks()]
[('hook', ('1',), {})]
When transaction commit starts, the hook is called, with its
arguments.
>>> log
[]
>>> t.commit()
>>> log
["arg '1' kw1 'no_kw1' kw2 'no_kw2'"]
>>> reset_log()
A hook's registration is consumed whenever the hook is called. Since
the hook above was called, it's no longer registered:
>>> len(list(t.getBeforeCommitHooks()))
0
>>> transaction.commit()
>>> log
[]
The hook is only called for a full commit, not for a savepoint.
>>> t = transaction.begin()
>>> t.addBeforeCommitHook(hook, 'A', dict(kw1='B'))
>>> dummy = t.savepoint()
>>> log
[]
>>> t.commit()
>>> log
["arg 'A' kw1 'B' kw2 'no_kw2'"]
>>> reset_log()
If a transaction is aborted, no hook is called.
>>> t = transaction.begin()
>>> t.addBeforeCommitHook(hook, ["OOPS!"])
>>> transaction.abort()
>>> log
[]
>>> transaction.commit()
>>> log
[]
The hook is called before the commit does anything, so even if the
commit fails the hook will have been called. To provoke failures in
commit, we'll add failing resource manager to the transaction.
>>> class CommitFailure(Exception):
... pass
>>> class FailingDataManager:
... def tpc_begin(self, txn, sub=False):
... raise CommitFailure
... def abort(self, txn):
... pass
>>> t = transaction.begin()
>>> t.join(FailingDataManager())
>>> t.addBeforeCommitHook(hook, '2')
>>> t.commit()
Traceback (most recent call last):
...
CommitFailure
>>> log
["arg '2' kw1 'no_kw1' kw2 'no_kw2'"]
>>> reset_log()
Let's register several hooks.
>>> t = transaction.begin()
>>> t.addBeforeCommitHook(hook, '4', dict(kw1='4.1'))
>>> t.addBeforeCommitHook(hook, '5', dict(kw2='5.2'))
They are returned in the same order by getBeforeCommitHooks.
>>> [(hook.func_name, args, kws) #doctest: +NORMALIZE_WHITESPACE
... for hook, args, kws in t.getBeforeCommitHooks()]
[('hook', ('4',), {'kw1': '4.1'}),
('hook', ('5',), {'kw2': '5.2'})]
And commit also calls them in this order.
>>> t.commit()
>>> len(log)
2
>>> log #doctest: +NORMALIZE_WHITESPACE
["arg '4' kw1 '4.1' kw2 'no_kw2'",
"arg '5' kw1 'no_kw1' kw2 '5.2'"]
>>> reset_log()
While executing, a hook can itself add more hooks, and they will all
be called before the real commit starts.
>>> def recurse(txn, arg):
... log.append('rec' + str(arg))
... if arg:
... txn.addBeforeCommitHook(hook, '-')
... txn.addBeforeCommitHook(recurse, (txn, arg-1))
>>> t = transaction.begin()
>>> t.addBeforeCommitHook(recurse, (t, 3))
>>> transaction.commit()
>>> log #doctest: +NORMALIZE_WHITESPACE
['rec3',
"arg '-' kw1 'no_kw1' kw2 'no_kw2'",
'rec2',
"arg '-' kw1 'no_kw1' kw2 'no_kw2'",
'rec1',
"arg '-' kw1 'no_kw1' kw2 'no_kw2'",
'rec0']
>>> reset_log()
N( ( ( ( sF /usr/lib/python2.6/site-packages/transaction/tests/test_transaction.pyt test_addBeforeCommitHookw s c C s d S( sì Test addAfterCommitHook.
Let's define a hook to call, and a way to see that it was called.
>>> log = []
>>> def reset_log():
... del log[:]
>>> def hook(status, arg='no_arg', kw1='no_kw1', kw2='no_kw2'):
... log.append("%r arg %r kw1 %r kw2 %r" % (status, arg, kw1, kw2))
Now register the hook with a transaction.
>>> import transaction
>>> t = transaction.begin()
>>> t.addAfterCommitHook(hook, '1')
We can see that the hook is indeed registered.
>>> [(hook.func_name, args, kws)
... for hook, args, kws in t.getAfterCommitHooks()]
[('hook', ('1',), {})]
When transaction commit is done, the hook is called, with its
arguments.
>>> log
[]
>>> t.commit()
>>> log
["True arg '1' kw1 'no_kw1' kw2 'no_kw2'"]
>>> reset_log()
A hook's registration is consumed whenever the hook is called. Since
the hook above was called, it's no longer registered:
>>> len(list(t.getAfterCommitHooks()))
0
>>> transaction.commit()
>>> log
[]
The hook is only called after a full commit, not for a savepoint.
>>> t = transaction.begin()
>>> t.addAfterCommitHook(hook, 'A', dict(kw1='B'))
>>> dummy = t.savepoint()
>>> log
[]
>>> t.commit()
>>> log
["True arg 'A' kw1 'B' kw2 'no_kw2'"]
>>> reset_log()
If a transaction is aborted, no hook is called.
>>> t = transaction.begin()
>>> t.addAfterCommitHook(hook, ["OOPS!"])
>>> transaction.abort()
>>> log
[]
>>> transaction.commit()
>>> log
[]
The hook is called after the commit is done, so even if the
commit fails the hook will have been called. To provoke failures in
commit, we'll add failing resource manager to the transaction.
>>> class CommitFailure(Exception):
... pass
>>> class FailingDataManager:
... def tpc_begin(self, txn):
... raise CommitFailure
... def abort(self, txn):
... pass
>>> t = transaction.begin()
>>> t.join(FailingDataManager())
>>> t.addAfterCommitHook(hook, '2')
>>> t.commit()
Traceback (most recent call last):
...
CommitFailure
>>> log
["False arg '2' kw1 'no_kw1' kw2 'no_kw2'"]
>>> reset_log()
Let's register several hooks.
>>> t = transaction.begin()
>>> t.addAfterCommitHook(hook, '4', dict(kw1='4.1'))
>>> t.addAfterCommitHook(hook, '5', dict(kw2='5.2'))
They are returned in the same order by getAfterCommitHooks.
>>> [(hook.func_name, args, kws) #doctest: +NORMALIZE_WHITESPACE
... for hook, args, kws in t.getAfterCommitHooks()]
[('hook', ('4',), {'kw1': '4.1'}),
('hook', ('5',), {'kw2': '5.2'})]
And commit also calls them in this order.
>>> t.commit()
>>> len(log)
2
>>> log #doctest: +NORMALIZE_WHITESPACE
["True arg '4' kw1 '4.1' kw2 'no_kw2'",
"True arg '5' kw1 'no_kw1' kw2 '5.2'"]
>>> reset_log()
While executing, a hook can itself add more hooks, and they will all
be called before the real commit starts.
>>> def recurse(status, txn, arg):
... log.append('rec' + str(arg))
... if arg:
... txn.addAfterCommitHook(hook, '-')
... txn.addAfterCommitHook(recurse, (txn, arg-1))
>>> t = transaction.begin()
>>> t.addAfterCommitHook(recurse, (t, 3))
>>> transaction.commit()
>>> log #doctest: +NORMALIZE_WHITESPACE
['rec3',
"True arg '-' kw1 'no_kw1' kw2 'no_kw2'",
'rec2',
"True arg '-' kw1 'no_kw1' kw2 'no_kw2'",
'rec1',
"True arg '-' kw1 'no_kw1' kw2 'no_kw2'",
'rec0']
>>> reset_log()
If an after commit hook is raising an exception then it will log a
message at error level so that if other hooks are registered they
can be executed. We don't support execution dependencies at this level.
>>> mgr = transaction.TransactionManager()
>>> do = DataObject(mgr)
>>> def hookRaise(status, arg='no_arg', kw1='no_kw1', kw2='no_kw2'):
... raise TypeError("Fake raise")
>>> t = transaction.begin()
>>> t.addAfterCommitHook(hook, ('-', 1))
>>> t.addAfterCommitHook(hookRaise, ('-', 2))
>>> t.addAfterCommitHook(hook, ('-', 3))
>>> transaction.commit()
>>> log
["True arg '-' kw1 1 kw2 'no_kw2'", "True arg '-' kw1 3 kw2 'no_kw2'"]
>>> reset_log()
Test that the associated transaction manager has been cleanup when
after commit hooks are registered
>>> mgr = transaction.TransactionManager()
>>> do = DataObject(mgr)
>>> t = transaction.begin()
>>> len(t._manager._txns)
1
>>> t.addAfterCommitHook(hook, ('-', 1))
>>> transaction.commit()
>>> log
["True arg '-' kw1 1 kw2 'no_kw2'"]
>>> len(t._manager._txns)
0
>>> reset_log()
N( ( ( ( sF /usr/lib/python2.6/site-packages/transaction/tests/test_transaction.pyt test_addAfterCommitHook s c C s> d d k l } l } t i | d ƒ | ƒ t i t ƒ f ƒ S( Niÿÿÿÿ( t DocTestSuitet DocFileSuites doom.txt( t doctestRP RQ t unittestt TestSuitet makeSuiteR ( RP RQ ( ( sF /usr/lib/python2.6/site-packages/transaction/tests/test_transaction.pyt
test_suite³ s
t __main__( ( ( t __doc__t structRS t warningsR
t transaction.tests.warnhookR t calcsizeR R t TestCaseR R
t ExceptionR) R( RI RL RM RN RO RV t additional_testsR4 t TextTestRunnert run( ( ( sF /usr/lib/python2.6/site-packages/transaction/tests/test_transaction.pyt ( s( ½; ‰ ³