Ńņ
4äKc @ s` d Z d e f d YZ d e f d YZ d Z e Z e d j o e i n d S( sj Sample objects for use in tests
$Id: test_SampleResourceManager.py 112140 2010-05-07 15:29:36Z tseaver $
t ResourceManagerc B sk e Z d Z d Z d Z d Z d d Z d Z d Z d Z d Z
d
Z d Z RS( sX Sample resource manager.
This class provides a trivial resource-manager implementation and doc
strings to illustrate the protocol and to provide a tool for writing
tests.
Our sample resource manager has state that is updated through an inc
method and through transaction operations.
When we create a sample resource manager:
>>> rm = ResourceManager()
It has two pieces state, state and delta, both initialized to 0:
>>> rm.state
0
>>> rm.delta
0
state is meant to model committed state, while delta represents
tentative changes within a transaction. We change the state by
calling inc:
>>> rm.inc()
which updates delta:
>>> rm.delta
1
but state isn't changed until we commit the transaction:
>>> rm.state
0
To commit the changes, we use 2-phase commit. We execute the first
stage by calling prepare. We need to pass a transation. Our
sample resource managers don't really use the transactions for much,
so we'll be lazy and use strings for transactions. The sample
resource manager updates the state when we call tpc_vote:
>>> t1 = '1'
>>> rm.tpc_begin(t1)
>>> rm.state, rm.delta
(0, 1)
>>> rm.tpc_vote(t1)
>>> rm.state, rm.delta
(1, 1)
Now if we call tpc_finish:
>>> rm.tpc_finish(t1)
Our changes are "permanent". The state reflects the changes and the
delta has been reset to 0.
>>> rm.state, rm.delta
(1, 0)
c C s1 d | _ d | _ d | _ d | _ d | _ d S( Ni ( t statet spt Nonet transactiont deltat txn_state( t self( ( sP /usr/lib/python2.6/site-packages/transaction/tests/test_SampleResourceManager.pyt __init__S s
c G s1 | i | j o t d | i | f n d S( Ns& txn in state %r but expected one of %r( R t
ValueError( R t ok_states( ( sP /usr/lib/python2.6/site-packages/transaction/tests/test_SampleResourceManager.pyt _check_stateZ s c C s= | | i j o) | i d j o t d | | i n d S( Ns Transaction missmatch( R R t TypeError( R R ( ( sP /usr/lib/python2.6/site-packages/transaction/tests/test_SampleResourceManager.pyt _checkTransaction_ s i c C s | i | 7_ d S( N( R ( R t n( ( sP /usr/lib/python2.6/site-packages/transaction/tests/test_SampleResourceManager.pyt ince s c C s0 | i | | i d | | _ d | _ d S( sß Prepare to commit data.
>>> rm = ResourceManager()
>>> rm.inc()
>>> t1 = '1'
>>> rm.tpc_begin(t1)
>>> rm.tpc_vote(t1)
>>> rm.tpc_finish(t1)
>>> rm.state
1
>>> rm.inc()
>>> t2 = '2'
>>> rm.tpc_begin(t2)
>>> rm.tpc_vote(t2)
>>> rm.tpc_abort(t2)
>>> rm.state
1
It is an error to call tpc_begin more than once without completing
two-phase commit:
>>> rm.tpc_begin(t1)
>>> rm.tpc_begin(t1)
Traceback (most recent call last):
...
ValueError: txn in state 'tpc_begin' but expected one of (None,)
>>> rm.tpc_abort(t1)
If there was a preceeding savepoint, the transaction must match:
>>> rollback = rm.savepoint(t1)
>>> rm.tpc_begin(t2)
Traceback (most recent call last):
,,,
TypeError: ('Transaction missmatch', '2', '1')
>>> rm.tpc_begin(t1)
t tpc_beginN( R
R R R R ( R R ( ( sP /usr/lib/python2.6/site-packages/transaction/tests/test_SampleResourceManager.pyR h s )
c C s9 | i | | i d | i | i 7_ d | _ d S( s( Verify that a data manager can commit the transaction.
This is the last chance for a data manager to vote 'no'. A
data manager votes 'no' by raising an exception.
transaction is the ITransaction instance associated with the
transaction being committed.
R t tpc_voteN( R
R R R R ( R R ( ( sP /usr/lib/python2.6/site-packages/transaction/tests/test_SampleResourceManager.pyR s
c C sB | i | | i d d | _ d | _ t | _ d | _ d S( st Complete two-phase commit
>>> rm = ResourceManager()
>>> rm.state
0
>>> rm.inc()
We start two-phase commit by calling prepare:
>>> t1 = '1'
>>> rm.tpc_begin(t1)
>>> rm.tpc_vote(t1)
We complete it by calling tpc_finish:
>>> rm.tpc_finish(t1)
>>> rm.state
1
It is an error ro call tpc_finish without calling tpc_vote:
>>> rm.inc()
>>> t2 = '2'
>>> rm.tpc_begin(t2)
>>> rm.tpc_finish(t2)
Traceback (most recent call last):
...
ValueError: txn in state 'tpc_begin' but expected one of ('tpc_vote',)
>>> rm.tpc_abort(t2) # clean slate
>>> rm.tpc_begin(t2)
>>> rm.tpc_vote(t2)
>>> rm.tpc_finish(t2)
Of course, the transactions given to tpc_begin and tpc_finish must
be the same:
>>> rm.inc()
>>> t3 = '3'
>>> rm.tpc_begin(t3)
>>> rm.tpc_vote(t3)
>>> rm.tpc_finish(t2)
Traceback (most recent call last):
...
TypeError: ('Transaction missmatch', '2', '3')
R i N( R
R R R R t Falset preparedR ( R R ( ( sP /usr/lib/python2.6/site-packages/transaction/tests/test_SampleResourceManager.pyt
tpc_finish¤ s 0
c C sf | i | | i d j o
d | _ n | i d j o | i | i 8_ n d | _ d | _ d S( so Abort a transaction
The abort method can be called before two-phase commit to
throw away work done in the transaction:
>>> rm = ResourceManager()
>>> rm.inc()
>>> rm.state, rm.delta
(0, 1)
>>> t1 = '1'
>>> rm.tpc_abort(t1)
>>> rm.state, rm.delta
(0, 0)
The abort method also throws away work done in savepoints:
>>> rm.inc()
>>> r = rm.savepoint(t1)
>>> rm.inc()
>>> r = rm.savepoint(t1)
>>> rm.state, rm.delta
(0, 2)
>>> rm.tpc_abort(t1)
>>> rm.state, rm.delta
(0, 0)
If savepoints are used, abort must be passed the same
transaction:
>>> rm.inc()
>>> r = rm.savepoint(t1)
>>> t2 = '2'
>>> rm.tpc_abort(t2)
Traceback (most recent call last):
...
TypeError: ('Transaction missmatch', '2', '1')
>>> rm.tpc_abort(t1)
The abort method is also used to abort a two-phase commit:
>>> rm.inc()
>>> rm.state, rm.delta
(0, 1)
>>> rm.tpc_begin(t1)
>>> rm.state, rm.delta
(0, 1)
>>> rm.tpc_vote(t1)
>>> rm.state, rm.delta
(1, 1)
>>> rm.tpc_abort(t1)
>>> rm.state, rm.delta
(0, 0)
Of course, the transactions passed to prepare and abort must
match:
>>> rm.tpc_begin(t1)
>>> rm.tpc_abort(t2)
Traceback (most recent call last):
...
TypeError: ('Transaction missmatch', '2', '1')
>>> rm.tpc_abort(t1)
This should never fail.
R i N( R
R R R R R ( R R ( ( sP /usr/lib/python2.6/site-packages/transaction/tests/test_SampleResourceManager.pyt tpc_abortŪ s E
c C sO | i d j o t d n | i | | | _ | i d 7_ t | S( sž
Provide the ability to rollback transaction state
Savepoints provide a way to:
- Save partial transaction work. For some resource managers, this
could allow resources to be used more efficiently.
- Provide the ability to revert state to a point in a
transaction without aborting the entire transaction. In
other words, savepoints support partial aborts.
Savepoints don't use two-phase commit. If there are errors in
setting or rolling back to savepoints, the application should
abort the containing transaction. This is *not* the
responsibility of the resource manager.
Savepoints are always associated with a transaction. Any work
done in a savepoint's transaction is tentative until the
transaction is committed using two-phase commit.
>>> rm = ResourceManager()
>>> rm.inc()
>>> t1 = '1'
>>> r = rm.savepoint(t1)
>>> rm.state, rm.delta
(0, 1)
>>> rm.inc()
>>> rm.state, rm.delta
(0, 2)
>>> r.rollback()
>>> rm.state, rm.delta
(0, 1)
>>> rm.tpc_begin(t1)
>>> rm.tpc_vote(t1)
>>> rm.tpc_finish(t1)
>>> rm.state, rm.delta
(1, 0)
Savepoints must have the same transaction:
>>> r1 = rm.savepoint(t1)
>>> rm.state, rm.delta
(1, 0)
>>> rm.inc()
>>> rm.state, rm.delta
(1, 1)
>>> t2 = '2'
>>> r2 = rm.savepoint(t2)
Traceback (most recent call last):
...
TypeError: ('Transaction missmatch', '2', '1')
>>> r2 = rm.savepoint(t1)
>>> rm.inc()
>>> rm.state, rm.delta
(1, 2)
If we rollback to an earlier savepoint, we discard all work
done later:
>>> r1.rollback()
>>> rm.state, rm.delta
(1, 0)
and we can no longer rollback to the later savepoint:
>>> r2.rollback()
Traceback (most recent call last):
...
TypeError: ('Attempt to roll back to invalid save point', 3, 2)
We can roll back to a savepoint as often as we like:
>>> r1.rollback()
>>> r1.rollback()
>>> r1.rollback()
>>> rm.state, rm.delta
(1, 0)
>>> rm.inc()
>>> rm.inc()
>>> rm.inc()
>>> rm.state, rm.delta
(1, 3)
>>> r1.rollback()
>>> rm.state, rm.delta
(1, 0)
But we can't rollback to a savepoint after it has been
committed:
>>> rm.tpc_begin(t1)
>>> rm.tpc_vote(t1)
>>> rm.tpc_finish(t1)
>>> r1.rollback()
Traceback (most recent call last):
...
TypeError: Attempt to rollback stale rollback
s+ Can't get savepoint during two-phase commiti N( R R R R
R R t SavePoint( R R ( ( sP /usr/lib/python2.6/site-packages/transaction/tests/test_SampleResourceManager.pyt savepoint* s f
c C s d S( N( ( R R ( ( sP /usr/lib/python2.6/site-packages/transaction/tests/test_SampleResourceManager.pyt discard s (
t __name__t
__module__t __doc__R R R
R R R R R R R ( ( ( sP /usr/lib/python2.6/site-packages/transaction/tests/test_SampleResourceManager.pyR s > . 7 O mR c B s# e Z d Z d Z d Z RS( c C s1 | | _ | i | _ | i | _ | i | _ d S( N( t rmR R R ( R R ( ( sP /usr/lib/python2.6/site-packages/transaction/tests/test_SampleResourceManager.pyR s c C s} | i | i i j o t d n | i i | i j o t d | i | i i n | i | i _ | i | i _ d S( Ns" Attempt to rollback stale rollbacks* Attempt to roll back to invalid save point( R R R R R ( R ( ( sP /usr/lib/python2.6/site-packages/transaction/tests/test_SampleResourceManager.pyt rollback¢ s c C s d S( N( ( R ( ( sP /usr/lib/python2.6/site-packages/transaction/tests/test_SampleResourceManager.pyR « s ( R R R R R ( ( ( sP /usr/lib/python2.6/site-packages/transaction/tests/test_SampleResourceManager.pyR s c C s d d k l } | S( Ni’’’’( t DocTestSuite( t doctestR ( R ( ( sP /usr/lib/python2.6/site-packages/transaction/tests/test_SampleResourceManager.pyt
test_suite® s t __main__N( R t objectR R R t additional_testsR t unittestt main( ( ( sP /usr/lib/python2.6/site-packages/transaction/tests/test_SampleResourceManager.pyt s ’