�
a�Nc@s
dZd
dl
mZ
d
dlmZ
def
d��YZdef
d��YZdef
d	��YZd
�Z	ddgZ
dekr�er�d
d
l
mZ
eedd�

Ze�Zej�Zejdejd�
�

ej�\ZZeGeGHndS(s�
Middleware related to transactions and database connections.

At this time it is very basic; but will eventually sprout all that
two-phase commit goodness that I don't need.

.. note::

   This is experimental, and will change in the future.
i����(
t
HTTPException(
tcatch_errorstTransactionManagerMiddlewarec
BseZ
d�Zd
�ZRS(cCs
|
|_dS(
N(
tapplication(tselfR((sB/opt/alt/python27/lib/python2.7/site-packages/paste/transaction.pyt__init__s
cCs@t�|
d
<}t
|
d<t|j|
|d|jd|j�S(Nspaste.transaction_managerspaste.throw_errorsterror_callbacktok_callback(tManagertTrueR
Rterrortfinish(Rtenvirontstart_responsetmanager((sB/opt/alt/python27/lib/python2.7/site-packages/paste/transaction.pyt__call__s




	
(t__name__t
__module__RR(((sB/opt/alt/python27/lib/python2.7/site-packages/paste/transaction.pyRs	Rc
Bs,eZ
d�Zd
�Zd�Zd�ZRS(c

Cst|_
g|_dS(
N(tFalsetabortedttransactions(
R((sB/opt/alt/python27/lib/python2.7/site-packages/paste/transaction.pyR"s
	
c

Cs
t|_
dS(
N(R	R(
R((sB/opt/alt/python27/lib/python2.7/site-packages/paste/transaction.pytabort&s
cCst|_
|j�
dS(
N(R	RR(Rtexc_info((sB/opt/alt/python27/lib/python2.7/site-packages/paste/transaction.pyR
)s
	
c
Cs8x1|jD]&}
|j
r&|
j�
q
|
j�
q
WdS(
N(RRtrollbacktcommit(Rttrans((sB/opt/alt/python27/lib/python2.7/site-packages/paste/transaction.pyR-s

	

(RRRRR
R(((sB/opt/alt/python27/lib/python2.7/site-packages/paste/transaction.pyR s			tConnectionFactorycBs#eZ
dZd
�Zdd�
ZRS(s

    Provides a callable interface for connecting to ADBAPI databases in
    a WSGI style (using the environment).  More advanced connection
    factories might use the REMOTE_USER and/or other environment
    variables to make the connection returned depend upon the request.
    cOsO|
|_||_
||_d
�|_t|jd�rK|jj|_ndS(Nc

Ssd
|jdd�S(Ns'%s't
's''(
treplace(
t
s((sB/opt/alt/python27/lib/python2.7/site-packages/paste/transaction.pyt<lambda>Cst
PgQuoteString(tmoduletargstkwargstquotethasattrR(RR R!R"((sB/opt/alt/python27/lib/python2.7/site-packages/paste/transaction.pyR<s	
	
	

cCs?|jj
|j|j�}|j|jd
<|j|jd<|S(NR R#(R tconnectR!R"t__dict__R#(RRtconn((sB/opt/alt/python27/lib/python2.7/site-packages/paste/transaction.pyRGs



N(RRt__doc__RtNoneR(((sB/opt/alt/python27/lib/python2.7/site-packages/paste/transaction.pyR5s
	cs��
fd
�}|S(s�

    Provides a simple mechanism for starting a transaction based on the
    factory; and for either committing or rolling back the transaction
    depending on the result.  It checks for the response's current
    status code either through the latest call to start_response; or
    through a HTTPException's code.  If it is a 100, 200, or 300; the
    transaction is committed; otherwise it is rolled back.
    cs_�|�
��|d
<dg
�
d��
fd�
}d�
�fd�
}t
�||||�S(Nspaste.connectioni�
c

sy|r3t|d
t
�r3�
j|d
j�

q3n�
j�dkrR�j�
ny�j�
Wn


dSX�j�
dS(Ni
i�
(t
isinstanceRtappendtcodetpopRRtclose(
R(R't
should_commit(sB/opt/alt/python27/lib/python2.7/site-packages/paste/transaction.pyt	finalizerZs








cs0�jt
|jd
�
d�
�

�
||
|�S(Nt
 i(R+tinttsplit(tstatustheadersR(R/R
(sB/opt/alt/python27/lib/python2.7/site-packages/paste/transaction.pytbasictrans_start_responsegs
 
(R)R
(RR
R0R6(Rtfactory(R'R/R
sB/opt/alt/python27/lib/python2.7/site-packages/paste/transaction.pytbasic_transactionVs



	


((RR7R8((RR7sB/opt/alt/python27/lib/python2.7/site-packages/paste/transaction.pytBasicTransactionHandlerMs	R9t__main__(
tPgSQLtdatabasettestingsSELECT now(), %ss	B'n\'glesN(R(tpaste.httpexceptionsRtwsgilibR
tobjectRRRR9t__all__RRtpyPgSQLR;R7R'tcursortcurrtexecuteR#tfetchonettimetbing(((sB/opt/alt/python27/lib/python2.7/site-packages/paste/transaction.pyt<module>s


	!