o ¹iâ ã@s¨ddlmZddlmZddlmZddlmZddlmZddlmZddlmZe  d¡d d „ƒZ e  d¡d d „ƒZ e  d¡d d„ƒZ dd„Z e  d¡dd„ƒZdS)é)Ú create_engine)Úexc)Ú create_db)Údrop_db)Úlog)Ú run_reap_dbs)Úupdate_db_optsÚmssqlcCs d|d<dS)NFÚlegacy_schema_aliasing©)Údb_urlÚdb_optsr r ú^/var/www/edux/Edux_v2/venv/lib/python3.10/site-packages/sqlalchemy/dialects/mssql/provision.pyÚ_mssql_update_db_opts s rcCs‚| ¡jdd/}| d|¡| d|¡| d|¡| d|¡| d¡| d¡WdƒdS1s:wYdS) NÚ AUTOCOMMIT©Úisolation_levelzcreate database %sz1ALTER DATABASE %s SET ALLOW_SNAPSHOT_ISOLATION ONz0ALTER DATABASE %s SET READ_COMMITTED_SNAPSHOT ONzuse %szcreate schema test_schemazcreate schema test_schema_2)ÚconnectÚexecution_optionsÚexecute©ÚcfgÚengÚidentÚconnr r rÚ_mssql_create_dbsÿÿ  "örcCs@| ¡jdd}t||ƒWdƒdS1swYdS)Nrr)rrÚ_mssql_drop_ignorerr r rÚ_mssql_drop_dbs "ÿrc CsVz| d|¡t d|¡WdStjy*}z t d|¡WYd}~dSd}~ww)Nzdrop database %sz Reaped db: %sTzcouldn't drop db: %sF)rrÚinforÚ DatabaseErrorÚwarning)rrÚerrr r rr$s  €þrc CsÒt d|¡t|ƒ}| ¡jddM}t dd |¡¡| d¡}dd„|Dƒ}tƒ}|D] }||vr8| |¡q-d }} t |d ƒD] \} } t || ƒrO|d 7}qBt d || ¡WdƒdS1sbwYdS) Nzdb reaper connecting to %rrrzidentifiers in file: %sz, z›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)cSsh|]\}| ¡’qSr )Úlower)Ú.0Údbnamer r rÚ Dsz"_reap_mssql_dbs..ééz-Dropped %d out of %d stale databases detected) rrrrrÚjoinrÚsetÚaddÚ enumerater) ÚurlÚidentsrrÚto_reapÚ all_namesÚto_dropÚnameÚdroppedÚtotalr$r r rÚ_reap_mssql_dbs6s, ÿ € €ÿ"ìr4N)ÚrrÚtesting.provisionrrrrrÚfor_dbrrrrr4r r r rÚs