File: //opt/alt/python27/lib/python2.7/site-packages/sqlalchemy/dialects/mssql/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 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 j d � d � � Z e j d � d � � Z d S( i����( t inspect( t Integeri ( t
create_engine( t exc( t Column( t DropConstraint( t ForeignKeyConstraint( t MetaData( t Table( t create_db( t" drop_all_schema_objects_pre_tables( t drop_db( t get_temp_table_name( t log( t run_reap_dbs( t temp_table_keyword_argst mssqlc C s� | j � j d d � �e } | j d | � | j d | � | j d | � | j d | � | j d � | j d � Wd QXd S( Nt isolation_levelt
AUTOCOMMITs create database %ss1 ALTER DATABASE %s SET ALLOW_SNAPSHOT_ISOLATION ONs0 ALTER DATABASE %s SET READ_COMMITTED_SNAPSHOT ONs use %ss create schema test_schemas create schema test_schema_2( t connectt execution_optionst exec_driver_sql( t cfgt engt identt conn( ( sT /opt/alt/python27/lib/python2.7/site-packages/sqlalchemy/dialects/mssql/provision.pyt _mssql_create_db s
c C s2 | j � j d d � � } t | | � Wd QXd S( NR R ( R R t _mssql_drop_ignore( R R R R ( ( sT /opt/alt/python27/lib/python2.7/site-packages/sqlalchemy/dialects/mssql/provision.pyt _mssql_drop_db( s c C sW y) | j d | � t j d | � t SWn' t j k
rR } t j d | � t SXd S( Ns drop database %ss
Reaped db: %ss couldn't drop db: %s( R R
t infot TrueR t
DatabaseErrort warningt False( R R t err( ( sT /opt/alt/python27/lib/python2.7/site-packages/sqlalchemy/dialects/mssql/provision.pyR . s c C s t j d | � t | � } | j � j d d � �� } t j d d j | � � | j d � } d � | D� } t � } x* | D]" } | | k r | j | � q q Wd } } x9 t | d � D]( \ } }
t
| |
� r� | d 7} q� q� Wt j d
| | � Wd QXd S( Ns db reaper connecting to %rR R s identifiers in file: %ss , s� select d.name from sys.databases as d where name like 'TEST_%' and not exists (select session_id from sys.dm_exec_sessions where database_id=d.database_id)c S s h | ] \ } | j � � q S( ( t lower( t .0t dbname( ( sT /opt/alt/python27/lib/python2.7/site-packages/sqlalchemy/dialects/mssql/provision.pys <setcomp>M s i i s- Dropped %d out of %d stale databases detected( R
R R R R t joinR t sett addt enumerateR ( t urlt identsR R t to_reapt all_namest to_dropt namet droppedt totalR% ( ( sT /opt/alt/python27/lib/python2.7/site-packages/sqlalchemy/dialects/mssql/provision.pyt _reap_mssql_dbs? s"
c C s i S( N( ( R R ( ( sT /opt/alt/python27/lib/python2.7/site-packages/sqlalchemy/dialects/mssql/provision.pyt _mssql_temp_table_keyword_args\ s c C s d | S( Ns ##( ( R R t base_name( ( sT /opt/alt/python27/lib/python2.7/site-packages/sqlalchemy/dialects/mssql/provision.pyt _mssql_get_temp_table_namea s c C s� | j � j d d � �� } t | � } x� d d | j | j f D]� } x� | j d | � D]� } t | t � t d t
� t d t
� d | �} x[ t | � j | d | �D]> } | j t
t | j j g | j j g d | d �� � q� WqY Wq@ WWd QXd S( NR R t dbot schemat xt yR/ ( R R R t Nonet test_schemat
test_schema_2t get_table_namesR R R R t get_foreign_keyst executeR R t cR8 R9 ( R R R t inspectorR7 t tnamet tbt fk( ( sT /opt/alt/python27/lib/python2.7/site-packages/sqlalchemy/dialects/mssql/provision.pyR
f s "N( t
sqlalchemyR R t R R R7 R R R R R t testing.provisionR R
R R R
R R t for_dbR R R R2 R3 R5 ( ( ( sT /opt/alt/python27/lib/python2.7/site-packages/sqlalchemy/dialects/mssql/provision.pyt <module> s,