a Lcf4=@szddlZddlZddlmZddlmZddlmZddlm Z ddl m Z ddl m Z ddlmZd ZGd d d ZdS) N)StringIO)apps)settings) serializers)router)atomic) import_stringZtest_c@seZdZdZddZddZddZd.d d Zd dZddZ ddZ ddZ ddZ d/ddZ d0ddZd1ddZddZd2dd Zd3d"d#Zd$d%Zd&d'Zd(d)Zd*d+Zd,d-Zd!S)4BaseDatabaseCreationzs Encapsulate backend-specific differences pertaining to creation and destruction of the test database. cCs ||_dSN) connection)selfr r ]/home/httpd/docs/test/DocsMgr/lib/python3.9/site-packages/django/db/backends/base/creation.py__init__szBaseDatabaseCreation.__init__cCs |jSr )r _nodb_cursorr r r rrsz!BaseDatabaseCreation._nodb_cursorcCstj|tjdSr )sysstderrwriteoslinesep)r msgr r rlogszBaseDatabaseCreation.logFTc CsNddlm}|}|dkrBd}|r(d}|d||||f|||||j|tj |jj d<||jj d<zl|jj dd d urtj }d d t Dt_ |d t|ddd |jj ddW|jj dd d ur|t_ n|jj dd d ur|t_ 0|r||j_|d|jj d|jtjddkrJ||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_commandrZCreatingzUsing existing %s test database for alias %s...NAMETESTZMIGRATEFcSsi|] }|jdqSr )label).0Zappr r r Hsz7BaseDatabaseCreation.create_test_db..ZmigrateT) verbosity interactivedatabaseZ run_syncdbZcreatecachetable)r#ZRUNNING_DJANGOS_TEST_SUITEtrue)Zdjango.core.managementr_get_test_db_namer_get_database_display_str_create_test_dbr closer DATABASESalias settings_dictZMIGRATION_MODULESrget_app_configsmaxserialize_db_to_stringZ_test_serialized_contentsZensure_connectionrenvironget mark_expected_failures_and_skips) r r! autoclobber serializekeepdbrtest_database_nameactionZold_migration_modulesr r rcreate_test_db sR        z#BaseDatabaseCreation.create_test_dbcCs|d|jjd<dS)z Set this database up to be used in testing as a mirror of a primary database whose settings are given. rN)r r+)r Zprimary_settings_dictr r rset_as_test_mirrorjsz'BaseDatabaseCreation.set_as_test_mirrorcs.fdd}t}tjd|d|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. c3sddlm}|j}tD]|}|jdur|j|jvr|jt j vr| D]L}|j jrLtjj|rL|jjj|j jj}|EdHqLqdS)Nr)MigrationLoader)Zdjango.db.migrations.loaderr9r rr,Z models_modulerZ migrated_appsnamerZTEST_NON_SERIALIZED_APPSZ get_models_metaZ can_migraterZallow_migrate_modelr*Z _base_managerusingZorder_bypkiterator)r9loaderZ app_configmodelZquerysetrr r get_objectsys*      z@BaseDatabaseCreation.serialize_db_to_string..get_objectsjsonN)indentstream)rrr3getvalue)r rAoutr rrr.qs z+BaseDatabaseCreation.serialize_db_to_stringc Cst|}t}t|jjd||jDtjd||jjdD]}|| |j j j j q>Wdn1sr0Y|jj|dWdn1s0YdS)zw Reload the database with data from a string generated by the serialize_db_to_string() method. )r<rBN) table_names)rsetrr r*Zconstraint_checks_disabledrZ deserializesaveaddobject __class__r;Zdb_tableZcheck_constraints)r datarGobjr r rdeserialize_db_from_strings  2z/BaseDatabaseCreation.deserialize_db_from_stringcCs d|jj|dkrd|ndfS)zR Return display string for a database for use in various actions. z'%s'%sz ('%s'))r r*)r r!Z database_namer r rr&sz.BaseDatabaseCreation._get_database_display_strcCs0|jjddr |jjddSt|jjdS)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. rr)r r+TEST_DATABASE_PREFIXrr r rr%sz&BaseDatabaseCreation._get_test_db_namecCs|d|dS)Nz%CREATE DATABASE %(dbname)s %(suffix)s)execute)r cursor parametersr4r r r_execute_create_test_dbsz,BaseDatabaseCreation._execute_create_test_dbc Csp|}|jj||d}|0}z||||Wn tyJ}z|rt|WYd}~WdS|d||st d|}|s|dkr"z@|dkr|d| ||f| d|||||Wn>ty}z$|d |t d WYd}~n d}~00n|d t dWYd}~n d}~00Wdn1sb0Y|S) zF Internal implementation - create the test db tables. )ZdbnamesuffixNz+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 %s...zDROP DATABASE %(dbname)sz-Got an error recreating the test database: %srPzTests cancelled.)r%r ops quote_namesql_table_creation_suffixrrV Exceptionrinputr&rSrexit) r r!r2r4r5Ztest_db_paramsrTeZconfirmr r rr'sH  " @z$BaseDatabaseCreation._create_test_dbcCsL|jjd}|dkr:d}|r d}|d||||f||||dS)z( Clone a test database. rrzCloning test databasezUsing existing clonez%s for alias %s...N)r r+rr&_clone_test_db)r rWr!r2r4Zsource_database_namer6r r r clone_test_dbs   z"BaseDatabaseCreation.clone_test_dbcCs$|jj}i|dd|d|iS)zX Return a modified connection settings dict for the n-th clone of a DB. rz{}_{})r r+format)r rWZorig_settings_dictr r rget_test_db_clone_settingss z/BaseDatabaseCreation.get_test_db_clone_settingscCs tddS)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.N)NotImplementedError)r rWr!r4r r rr`sz#BaseDatabaseCreation._clone_test_dbNcCs|j|dur |jjd}n||d}|dkr\d}|rBd}|d||||f|sl||||dur|tj|jj d<||jjd<dS)zv Destroy a test database, prompting the user for confirmation if the database already exists. NrrZ DestroyingZ Preservingr) r r(r+rcrr&_destroy_test_dbrr)r*)r Zold_database_namer!r4rWr5r6r r rdestroy_test_dbs(    z$BaseDatabaseCreation.destroy_test_dbcCsD|(}|d|jj|Wdn1s60YdS)zF Internal implementation - remove the test db tables. zDROP DATABASE %sN)rrSr rYrZ)r r5r!rTr r rre;s z%BaseDatabaseCreation._destroy_test_dbc Csddlm}m}|jjjD]N}|d\}}}|dd}|tj vrt |}t ||} t |||| q|jjj D]`\} } | D]R}|d\}}}|dd}|tj vrt |}t ||} t |||| | qqxdS)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)Zunittestrgrhr featuresZdjango_test_expected_failures rpartitionsplitrZINSTALLED_APPSrgetattrsetattrZdjango_test_skipsitems) r rgrhZ test_nameZtest_case_name_Ztest_method_nameZtest_appZ test_caseZ test_methodreasontestsr r rr1Hs     z5BaseDatabaseCreation.mark_expected_failures_and_skipscCsdS)zQ SQL to append to the end of the test table creation statements. rQr rr r rr[bsz.BaseDatabaseCreation.sql_table_creation_suffixcCs$|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. ZHOSTZPORTZENGINE)r r+r%)r r+r r rtest_db_signaturehs z&BaseDatabaseCreation.test_db_signaturecCs*|t|}|jj||jdSr )rcstrr r+updater()r Z _worker_idr+r r rsetup_worker_connectionvsz,BaseDatabaseCreation.setup_worker_connection)rFTF)F)F)rFF)F)NrFN)__name__ __module__ __qualname____doc__rrrr7r8r.rOr&r%rVr'rarcr`rfrer1r[rsrvr r r rr s. J    /  # r )rriorZ django.appsrZ django.confrZ django.corerZ django.dbrZdjango.db.transactionrZdjango.utils.module_loadingrrRr r r r rs