Evg=ddlZddlZddlmZddlmZddlmZddlm Z ddl m Z ddl m Z ddlmZd ZGd d ZdS) N)StringIO)apps)settings) serializers)router)atomic) import_stringtest_ceZdZdZdZdZdZ ddZd Zd Z d Z d Z d Z ddZ ddZddZdZddZ ddZdZdZdZdZdZdS)BaseDatabaseCreationzs Encapsulate backend-specific differences pertaining to creation and destruction of the test database. c||_dSN) connection)selfrs ]/var/www/pixelcanvas.ch/venv/lib/python3.11/site-packages/django/db/backends/base/creation.py__init__zBaseDatabaseCreation.__init__s $c4|jSr)r _nodb_cursorrs rrz!BaseDatabaseCreation._nodb_cursors++---rc^tj|tjzdSr)sysstderrwriteoslinesep)rmsgs rlogzBaseDatabaseCreation.logs% rz)*****rFTcddlm}|}|dkr5d}|rd}||d|||d|||||j|tj |jj d<||jj d< |jj d d d ur3tj }d tjDt_ |d t|dz dd |jj d|jj d d d ur |t_ n+#|jj d d d ur |t_ wxYw|r||j_|d|jj |jt&jddkr||S)z Create a test database, prompting the user for confirmation if the database already exists. Return the name of the test database created. r) call_commandrCreatingzUsing existing test database for alias ...NAMETESTMIGRATEFci|] }|jd Sr)label).0apps r z7BaseDatabaseCreation.create_test_db..Hs)...(+CIt...rmigrateT) verbosity interactivedatabase run_syncdbcreatecachetable)r0RUNNING_DJANGOS_TEST_SUITEtrue)django.core.managementr!_get_test_db_namer_get_database_display_str_create_test_dbrcloser DATABASESalias settings_dictMIGRATION_MODULESrget_app_configsmaxserialize_db_to_string_test_serialized_contentsensure_connectionrenvironget mark_expected_failures_and_skips) rr. autoclobber serializekeepdbr!test_database_nameactionold_migration_moduless rcreate_test_dbz#BaseDatabaseCreation.create_test_db s? 877777!3355 >>F *) HHFF229>PQQQQ    Y V<<< >6 7 76 A A  1 1 3 3 3!!s 5A8E(E<c0|d|jjd<dS)z Set this database up to be used in testing as a mirror of a primary database whose settings are given. r%N)rr<)rprimary_settings_dicts rset_as_test_mirrorz'BaseDatabaseCreation.set_as_test_mirrorjs 1Ff0M%f---rcfd}t}tjd|d||S)z Serialize all data in the database into a JSON string. Designed only for test runner usage; will not handle large amounts of data. c38Kddlm}|j}tjD]}|j|j|jvr|jtj vr| D]}|j jrtjjj|rm|jjj|j jj}|jrdnd}||Ed{VdS)Nr)MigrationLoaderi) chunk_size)django.db.migrations.loaderrRrrr> models_moduler) migrated_appsnamerTEST_NON_SERIALIZED_APPS get_models_meta can_migraterallow_migrate_modelr; _base_managerusingorder_bypk_prefetch_related_lookupsiterator)rRloader app_configmodelquerysetrSrs r get_objectsz@BaseDatabaseCreation.serialize_db_to_string..get_objectsysP C C C C C C$_T_55F"244 P P ,8"(F,@@@"x/PPP!+!6!6!8!8 P P ;22 O P$89NPUVV P(-':'@'@ $ 5((&hu{~':;;%)1(J TPT'(0'8'8J'8'O'OOOOOOOO! P PrjsonN)indentstream)rrrGgetvalue)rrgouts` rr@z+BaseDatabaseCreation.serialize_db_to_stringqsZ P P P P P.jjfkkmmDMMMM||~~rct|}t}t|jj5|j5t jd||jjD]?}|| |j j j j @ dddn #1swxYwY|j|ddddS#1swxYwYdS)zw Reload the database with data from a string generated by the serialize_db_to_string() method. )r^rhN) table_names)rsetrrr;constraint_checks_disabledr deserializesaveaddobject __class__rZdb_tablecheck_constraints)rdatarnobjs rdeserialize_db_from_stringz/BaseDatabaseCreation.deserialize_db_from_strings ~~ee $// 0 0 0 G G;;== I I&2D(=IICHHJJJOOCJ$8$>$GHHHH I I I I I I I I I I I I I I I I O - -+ - F F F G G G G G G G G G G G G G G G G G Gs6C4A"C5 C4C C4C C44C8;C8c<d|jjd|dkrd|zndS)zR Return display string for a database for use in various actions. 'z ('%s'))rr;)rr. database_names rr7z.BaseDatabaseCreation._get_database_display_strs6 O ! ! !+4>>Y & &r A  rc|jjddr|jjddSt|jjdzS)z Internal implementation - return the name of the test DB that will be created. Only useful when called from create_test_db() and _create_test_db() and when no external munging is done with the 'NAME' settings. r&r%)rr<TEST_DATABASE_PREFIXrs rr6z&BaseDatabaseCreation._get_test_db_namesF ? ( 0 8 A?08@ @#do&CF&KKKrc6|d|zdS)Nz%CREATE DATABASE %(dbname)s %(suffix)s)execute)rcursor parametersrHs r_execute_create_test_dbz,BaseDatabaseCreation._execute_create_test_dbs >KLLLLLrc |}|jj||d}|5} ||||n1#t$r#}|r|cYd}~cdddS|d|z|std|z}|s|dkr |dkr-|d| ||d| d |z||||nl#t$r6}|d |ztj d Yd}~n1d}~wwxYw|d tj dYd}~nd}~wwxYwdddn #1swxYwY|S) zF Internal implementation - create the test db tables. )dbnamesuffixNz+Got an error creating the test database: %szXType 'yes' if you would like to try deleting the test database '%s', or 'no' to cancel: yesrz'Destroying old test database for alias r$zDROP DATABASE %(dbname)sz-Got an error recreating the test database: %sr}zTests cancelled.)r6rops quote_namesql_table_creation_suffixrr Exceptionrinputr7rrexit) rr.rFrHrItest_db_paramsreconfirms rr8z$BaseDatabaseCreation._create_test_dbs"3355o)445GHH4466      ! F ,,V^VLLLL   .------! ! ! ! ! ! ! ! FJKKK"#=?QRG 'U"2"2$$>> HHH%)$B$B(13E%&%&%&%&!"'AN'RSSS44V^VTTTT$$$$!PST!TUUU $HH/000HQKKK= ! ! ! ! ! ! ! ! ! ! ! ! ! ! ! F"!syF5A86F58 F&F!F&F54F! A"D0/F!0 E0:,E+&F!+E00,F!F5!F&&F55F9<F9c|jjd}|dkr5d}|rd}||d|||d||||dS)z( Clone a test database. r%rzCloning test databasezUsing existing clonez for alias r$N)rr<rr7_clone_test_db)rrr.rFrHsource_database_namerJs r clone_test_dbz"BaseDatabaseCreation.clone_test_dbs $>,F 0/ HHFF229>RSSSS    FIv66666rc^|jj}i|dd|d|iS)zX Return a modified connection settings dict for the n-th clone of a DB. r%z{}_{})rr<format)rrorig_settings_dicts rget_test_db_clone_settingsz/BaseDatabaseCreation.get_test_db_clone_settingssD"_:   GNN#5f#=vFF   rc td)zI Internal implementation - duplicate the test db tables. znThe database backend doesn't support cloning databases. Disable the option to run tests in parallel processes.)NotImplementedError)rrr.rHs rrz#BaseDatabaseCreation._clone_test_dbs" E   rNc|j||jjd}n||d}|dkr5d}|rd}||d|||d|s||||0|tj|jj d<||jjd<dSdS)zv Destroy a test database, prompting the user for confirmation if the database already exists. Nr%r Destroying Preservingr#r$) rr9r<rrr7_destroy_test_dbrr:r;)rold_database_namer.rHrrIrJs rdestroy_test_dbz$BaseDatabaseCreation.destroy_test_dbs  >!%!>v!F  !%!@!@!H!H!P  >>!F &% HHFF229>PQQQQ    A  ! !"4i @ @ @  (@QH t4 5f =4EDO )& 1 1 1 ) (rc|5}|d|jj|zddddS#1swxYwYdS)zF Internal implementation - remove the test db tables. zDROP DATABASE %sN)rrrrr)rrIr.rs rrz%BaseDatabaseCreation._destroy_test_db>s    F NN"T_%8%C%CDV%W%WW                     s6AAAc ddlm}m}|jjjD]}}|d\}}}|dd}|tj vr9t|}t||} t|||| ~|jjj D]\} } | D]}|d\}}}|dd}|tj vrBt|}t||} t|||| | dS)z Mark tests in Django's test suite which are expected failures on this database and test which should be skipped on this database. r)expectedFailureskip.N)unittestrrrfeaturesdjango_test_expected_failures rpartitionsplitrINSTALLED_APPSr getattrsetattrdjango_test_skipsitems) rrr test_nametest_case_name_test_method_nametest_app test_case test_methodreasontestss rrEz5BaseDatabaseCreation.mark_expected_failures_and_skipsKs} 322222221O S SI2;2F2Fs2K2K /NA/ s++A.H8222).99 %i1ABB  #3__[5Q5QRRR!_5GMMOO T TMFE" T T 6?6J6J36O6O3#3$??3//2x666 -n = =I"))5E"F"FKI'7fk9R9RSSS T T TrcdS)zQ SQL to append to the end of the test table creation statements. r~rs rrz.BaseDatabaseCreation.sql_table_creation_suffixes rrcn|jj}|d|d|d|fS)z Return a tuple with elements of self.connection.settings_dict (a DATABASES setting value) that uniquely identify a database accordingly to the RDBMS particularities. HOSTPORTENGINE)rr<r6)rr<s rtest_db_signaturez&BaseDatabaseCreation.test_db_signatureks? 5 & ! & ! ( #  " " $ $   rc|t|}|jj||jdSr)rstrrr<updater9)r _worker_idr<s rsetup_worker_connectionz,BaseDatabaseCreation.setup_worker_connectionysP77JHH %,,];;; r)rFTF)F)rFF)NrFN)__name__ __module__ __qualname____doc__rrrrLrOr@rzr7r6rr8rrrrrrErrrrrrr r s %%%...+++FKH"H"H"H"TNNN!!!FGGG*    L L LMMMM-"-"-"-"^7777,        IM!F!F!F!FF   TTT4         rr )rrior django.appsr django.confr django.corer django.dbrdjango.db.transactionrdjango.utils.module_loadingr rr rrrrs  ######((((((555555o o o o o o o o o o r