File: //opt/alt/python27/lib/python2.7/site-packages/sqlalchemy/dialects/oracle/provision.pyc
�
���ec @ s� d d l m Z d d l m Z d d l m Z d d l m Z d d l m Z d d l m Z d d l m
Z
d d l m Z d d l m Z d d
l m
Z
d d l m Z d d l m Z d d
l m Z e j d � d � � Z e j d � d � � Z d � Z e j d � d � � Z e j d � d � � Z e � Z e j d � d � � Z e
j d � d � � Z e
j d � d � � Z e j d � d � � Z e j d � d � � Z d S( i ( t
create_engine( t exc( t url( t configure_follower( t create_db( t drop_db( t follower_url_from_main( t log( t post_configure_engine( t run_reap_dbs( t set_default_schema_on_connection( t stop_test_class_outside_fixtures( t temp_table_keyword_argst oraclec C s� | j � �� } | j d | � | j d | � | j d | � | j d | f � | j d | � | j d | � | j d | � Wd QXd S( Ns create user %s identified by xes# create user %s_ts1 identified by xes# create user %s_ts2 identified by xes grant dba to %ss grant unlimited tablespace to %ss$ grant unlimited tablespace to %s_ts1s$ grant unlimited tablespace to %s_ts2( t begint exec_driver_sql( t cfgt engt identt conn( ( sU /opt/alt/python27/lib/python2.7/site-packages/sqlalchemy/dialects/oracle/provision.pyt _oracle_create_db s c C s d | | _ d | | _ d S( Ns %s_ts1s %s_ts2( t test_schemat
test_schema_2( t configR ( ( sU /opt/alt/python27/lib/python2.7/site-packages/sqlalchemy/dialects/oracle/provision.pyt _oracle_configure_follower% s
c C sW y) | j d | � t j d | � t SWn' t j k
rR } t j d | � t SXd S( Ns drop user %s cascades
Reaped db: %ss couldn't drop db: %s( R R t infot TrueR t
DatabaseErrort warningt False( R t dbnamet err( ( sU /opt/alt/python27/lib/python2.7/site-packages/sqlalchemy/dialects/oracle/provision.pyt _ora_drop_ignore+ s c C sH | j � �6 } t | | � t | d | � t | d | � Wd QXd S( Ns %s_ts1s %s_ts2( R R ( R R R R ( ( sU /opt/alt/python27/lib/python2.7/site-packages/sqlalchemy/dialects/oracle/provision.pyt _oracle_drop_db5 s
c C s� y& | j � � } | j d � Wd QXWn& t j k
rN } t j d | � n XxJ t D]B } y
| j } Wn | j j j
k
r� qV Xd | _ | | _ qV Wt j � d S( Ns purge recyclebins# purge recyclebin command failed: %si ( R R R R R R t
_all_connst
stmtcachesizet dialectt dbapit InterfaceErrort clear( R t dbt clsR R t cx_oracle_connt sc( ( sU /opt/alt/python27/lib/python2.7/site-packages/sqlalchemy/dialects/oracle/provision.pyR B s
c C sJ d d l m } | j | d � d � � } | j | d � d � � } d S( Ni����( t eventt checkoutc S s t j | � d S( N( R" t add( t dbapi_cont
con_recordt con_proxy( ( sU /opt/alt/python27/lib/python2.7/site-packages/sqlalchemy/dialects/oracle/provision.pyR- c s t checkinc S s d | j k r | j � n d S( Nt
cx_oracle_xid( R t
invalidate( t dbapi_connectiont connection_record( ( sU /opt/alt/python27/lib/python2.7/site-packages/sqlalchemy/dialects/oracle/provision.pyR2 g s ( t
sqlalchemyR, t listens_for( R t enginet follower_identR, R- R2 ( ( sU /opt/alt/python27/lib/python2.7/site-packages/sqlalchemy/dialects/oracle/provision.pyt _oracle_post_configure_engine_ s c C sh t j d | � t | � } | j � �:} t j d d j | � � | j d � } d � | D� } t � } x� | D]� } | j d � ss | j d � r� qs qs | | k rs | j | � d | | k r� | j d | � n d | | k r| j d | � qqs qs Wd
} } x9 t | d � D]( \ } }
t
| |
� r | d 7} q q Wt j d | | � Wd QXd S(
Ns db reaper connecting to %rs identifiers in file: %ss , s� select u.username from all_users u where username like 'TEST_%' and not exists (select username from v$session where username=u.username)c S s h | ] \ } | j � � q S( ( t lower( t .0t username( ( sU /opt/alt/python27/lib/python2.7/site-packages/sqlalchemy/dialects/oracle/provision.pys <setcomp>} s t _ts1t _ts2s %s_ts1s %s_ts2i i s- Dropped %d out of %d stale databases detected( R R R R t joinR t sett endswithR. t enumerateR ( R t identsR R t to_reapt all_namest to_dropt namet droppedt totalR> ( ( sU /opt/alt/python27/lib/python2.7/site-packages/sqlalchemy/dialects/oracle/provision.pyt _reap_oracle_dbsp s.
c C s% t j | � } | j d | d d � S( NR> t passwordt xe( t sa_urlt make_urlRB ( R R ( ( sU /opt/alt/python27/lib/python2.7/site-packages/sqlalchemy/dialects/oracle/provision.pyt _oracle_follower_url_from_main� s c C s i d g d 6d d 6S( Ns GLOBAL TEMPORARYt prefixess
PRESERVE ROWSt oracle_on_commit( ( R R ( ( sU /opt/alt/python27/lib/python2.7/site-packages/sqlalchemy/dialects/oracle/provision.pyt _oracle_temp_table_keyword_args� s
c C s+ | j � } | j d | � | j � d S( Ns# ALTER SESSION SET CURRENT_SCHEMA=%s( t cursort executet close( R R5 t schema_nameRU ( ( sU /opt/alt/python27/lib/python2.7/site-packages/sqlalchemy/dialects/oracle/provision.pyt( _oracle_set_default_schema_on_connection� s N( t R R R9 R RO t testing.provisionR R R R R R R R
R R t for_dbR R R R! RB R" R; RL RQ RT RY ( ( ( sU /opt/alt/python27/lib/python2.7/site-packages/sqlalchemy/dialects/oracle/provision.pyt <module> s.
"