/
opt
/
alt
/
python27
/
lib64
/
python2.7
/
site-packages
/
sqlalchemy
/
dialects
/
mssql
/
up file
home
� 1��fc @ 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 d d l m Z e j d � d � � 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 post_configure_engine( t run_reap_dbs( t temp_table_keyword_argst mssqlc C s% | j d k r! t | j j _ n d S( Nt pyodbc( t drivert Falset dialectt dbapit pooling( t urlt enginet follower_ident( ( sV /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/dialects/mssql/provision.pyR s c 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( ( sV /opt/alt/python27/lib64/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# ( ( sV /opt/alt/python27/lib64/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 warningR ( R# R" t err( ( sV /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/dialects/mssql/provision.pyR% 5 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( ( sV /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/dialects/mssql/provision.pys <setcomp>T s i i s- Dropped %d out of %d stale databases detected( R R' R R R t joinR t sett addt enumerateR% ( R t identsR! R# t to_reapt all_namest to_dropt namet droppedt totalR. ( ( sV /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/dialects/mssql/provision.pyt _reap_mssql_dbsF s" c C s i S( N( ( R R! ( ( sV /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/dialects/mssql/provision.pyt _mssql_temp_table_keyword_argsc s c C s d | S( Ns ##( ( R R! t base_name( ( sV /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/dialects/mssql/provision.pyt _mssql_get_temp_table_nameh 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 yR7 ( R R R t Nonet test_schemat test_schema_2t get_table_namesR R R R t get_foreign_keyst executeR R t cR@ RA ( R R! R# t inspectorR? t tnamet tbt fk( ( sV /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/dialects/mssql/provision.pyR m s "N( t sqlalchemyR R t R R R? R R R R R t testing.provisionR R R R R R R R t for_dbR$ R& R% R: R; R= ( ( ( sV /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/dialects/mssql/provision.pyt <module> s0