o
    ÖŸŽi4=  ã                   @   sz   d dl Z d dl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	ZG d
d„ dƒZdS )é    N)ÚStringIO)Úapps)Úsettings)Úserializers)Úrouter)Úatomic)Úimport_stringZtest_c                   @   sÀ   e Zd ZdZdd„ Zdd„ Zdd„ Z		d.dd„Zdd„ Zdd„ Z	dd„ Z
dd„ Zdd„ Zd/dd„Zd/dd„Zd0dd„Zdd„ Zd/dd „Z	!d1d"d#„Zd$d%„ Zd&d'„ Zd(d)„ Zd*d+„ Zd,d-„ Zd!S )2ÚBaseDatabaseCreationzs
    Encapsulate backend-specific differences pertaining to creation and
    destruction of the test database.
    c                 C   s
   || _ d S ©N)Ú
connection)Úselfr   © r   újC:\Users\psant\Downloads\Anu Raj Backend\school\venv\Lib\site-packages\django/db/backends/base/creation.pyÚ__init__   ó   
zBaseDatabaseCreation.__init__c                 C   s
   | j  ¡ S r
   )r   Ú_nodb_cursor©r   r   r   r   r      r   z!BaseDatabaseCreation._nodb_cursorc                 C   s   t j |tj ¡ d S r
   )ÚsysÚstderrÚwriteÚosÚlinesep)r   Úmsgr   r   r   Úlog   s   zBaseDatabaseCreation.logé   FTc           	      C   sH  ddl m} |  ¡ }|dkr!d}|rd}|  d||  ||¡f ¡ |  |||¡ | j ¡  |tj	| jj
 d< || jjd< z6| jjd d	 d
u rTtj}dd„ t ¡ D ƒt_|dt|d dƒd
| jj
dd� W | jjd d	 d
u rr|t_n| jjd d	 d
u r€|t_w |r‰|  ¡ | j_|d| jj
d� | j ¡  tj d¡dkr¢|  ¡  |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_commandr   ZCreatingzUsing existingú %s test database for alias %s...ÚNAMEÚTESTZMIGRATEFc                 S   s   i | ]}|j d “qS r
   )Úlabel)Ú.0Zappr   r   r   Ú
<dictcomp>H   s    ÿz7BaseDatabaseCreation.create_test_db.<locals>.<dictcomp>ZmigrateT)Ú	verbosityÚinteractiveÚdatabaseZ
run_syncdbZcreatecachetable)r$   ZRUNNING_DJANGOS_TEST_SUITEÚtrueN)Zdjango.core.managementr   Ú_get_test_db_namer   Ú_get_database_display_strÚ_create_test_dbr   Úcloser   Ú	DATABASESÚaliasÚsettings_dictZMIGRATION_MODULESr   Úget_app_configsÚmaxÚserialize_db_to_stringZ_test_serialized_contentsZensure_connectionr   ÚenvironÚgetÚ mark_expected_failures_and_skips)	r   r"   ÚautoclobberÚ	serializeÚkeepdbr   Útest_database_nameÚactionZold_migration_modulesr   r   r   Úcreate_test_db    sT   
þÿÿ
ÿû€ÿ
z#BaseDatabaseCreation.create_test_dbc                 C   s   |d | j jd< dS )z€
        Set this database up to be used in testing as a mirror of a primary
        database whose settings are given.
        r   N)r   r,   )r   Zprimary_settings_dictr   r   r   Úset_as_test_mirrorj   s   z'BaseDatabaseCreation.set_as_test_mirrorc                    s.   ‡ fdd„}t ƒ }tjd|ƒ 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.
        c                  3   s¢   � ddl m}  | ˆ jƒ}t ¡ D ]>}|jd urN|j|jv rN|jt	j
vrN| ¡ D ]&}|j ˆ j¡rMt ˆ jj|¡rM|j ˆ jj¡ |jjj¡}| ¡ E d H  q'qd S )Nr   )ÚMigrationLoader)Zdjango.db.migrations.loaderr:   r   r   r-   Zmodels_moduler   Zmigrated_appsÚnamer   ZTEST_NON_SERIALIZED_APPSZ
get_modelsÚ_metaZcan_migrater   Zallow_migrate_modelr+   Z_base_managerÚusingZorder_byÚpkÚiterator)r:   ÚloaderZ
app_configÚmodelZquerysetr   r   r   Úget_objectsy   s0   €
ÿ
þ
ýÿþÿþ€óz@BaseDatabaseCreation.serialize_db_to_string.<locals>.get_objectsÚjsonN)ÚindentÚstream)r   r   r4   Úgetvalue)r   rB   Úoutr   r   r   r/   q   s   z+BaseDatabaseCreation.serialize_db_to_stringc              	   C   s®   t |ƒ}tƒ }t| jjd��? | j ¡ �" tjd|| jjd�D ]}| ¡  | 	|j
jjj¡ qW d  ƒ n1 s9w   Y  | jj|d� W d  ƒ dS 1 sPw   Y  dS )zw
        Reload the database with data from a string generated by
        the serialize_db_to_string() method.
        )r=   rC   N)Útable_names)r   Úsetr   r   r+   Zconstraint_checks_disabledr   ZdeserializeÚsaveÚaddÚobjectÚ	__class__r<   Zdb_tableZcheck_constraints)r   ÚdatarH   Úobjr   r   r   Údeserialize_db_from_string‘   s   

ÿüÿ"õz/BaseDatabaseCreation.deserialize_db_from_stringc                 C   s$   d| j j|dkrd| f S df S )zR
        Return display string for a database for use in various actions.
        z'%s'%sé   z ('%s')Ú N)r   r+   )r   r"   Zdatabase_namer   r   r   r'   ¦   s   þþz.BaseDatabaseCreation._get_database_display_strc                 C   s0   | j jd d r| j jd d S t| j jd  S )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   N)r   r,   ÚTEST_DATABASE_PREFIXr   r   r   r   r&   ¯   s   z&BaseDatabaseCreation._get_test_db_namec                 C   s   |  d| ¡ d S )Nz%CREATE DATABASE %(dbname)s %(suffix)s)Úexecute)r   ÚcursorÚ
parametersr5   r   r   r   Ú_execute_create_test_dbº   s   z,BaseDatabaseCreation._execute_create_test_dbc           	      C   st  |   ¡ }| jj |¡|  ¡ dœ}|  ¡ �œ}z	|  |||¡ W n� tyŸ } zu|r7|W  Y d}~W  d  ƒ S |  d| ¡ |sFt	d| ƒ}|sL|dkr‹z |dkr]|  d|  
||¡f ¡ | d| ¡ |  |||¡ W n( tyŠ } z|  d	| ¡ t d
¡ W Y d}~nd}~ww |  d¡ t d¡ W Y d}~nd}~ww W d  ƒ |S W d  ƒ |S 1 s³w   Y  |S )zF
        Internal implementation - create the test db tables.
        )ZdbnameÚsuffixNz+Got an error creating the test database: %szXType 'yes' if you would like to try deleting the test database '%s', or 'no' to cancel: Úyesr   z,Destroying old test database for alias %s...zDROP DATABASE %(dbname)sz-Got an error recreating the test database: %srQ   zTests cancelled.)r&   r   ÚopsÚ
quote_nameÚsql_table_creation_suffixr   rW   Ú	Exceptionr   Úinputr'   rT   r   Úexit)	r   r"   r3   r5   r6   Ztest_db_paramsrU   ÚeZconfirmr   r   r   r(   ½   s`   þ
ù	ÿÿÿÿÿÿ€þ

€âÿ
þ#€
Ý#Ý#z$BaseDatabaseCreation._create_test_dbc                 C   sL   | j jd }|dkrd}|rd}|  d||  ||¡f ¡ |  |||¡ dS )z(
        Clone a test database.
        r   r   zCloning test databasezUsing existing clonez%s for alias %s...N)r   r,   r   r'   Ú_clone_test_db)r   rX   r"   r3   r5   Zsource_database_namer7   r   r   r   Úclone_test_dbì   s   
þÿÿ
z"BaseDatabaseCreation.clone_test_dbc                 C   s$   | j j}i |¥dd |d |¡i¥S )zX
        Return a modified connection settings dict for the n-th clone of a DB.
        r   z{}_{}N)r   r,   Úformat)r   rX   Zorig_settings_dictr   r   r   Úget_test_db_clone_settings  s   ÿþz/BaseDatabaseCreation.get_test_db_clone_settingsc                 C   s   t dƒ‚)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   rX   r"   r5   r   r   r   ra     s   ÿz#BaseDatabaseCreation._clone_test_dbNc                 C   sš   | j  ¡  |du r| j jd }n|  |¡d }|dkr.d}|r!d}|  d||  ||¡f ¡ |s6|  ||¡ |durK|tj| j j	 d< || j jd< dS dS )zv
        Destroy a test database, prompting the user for confirmation if the
        database already exists.
        Nr   r   Z
DestroyingZ
Preservingr   )
r   r)   r,   rd   r   r'   Ú_destroy_test_dbr   r*   r+   )r   Zold_database_namer"   r5   rX   r6   r7   r   r   r   Údestroy_test_db  s*   

þÿÿ
þz$BaseDatabaseCreation.destroy_test_dbc                 C   sF   |   ¡ �}| d| jj |¡ ¡ W d  ƒ dS 1 sw   Y  dS )zF
        Internal implementation - remove the test db tables.
        zDROP DATABASE %sN)r   rT   r   rZ   r[   )r   r6   r"   rU   r   r   r   rf   ;  s
   
ÿ"ÿz%BaseDatabaseCreation._destroy_test_dbc                 C   sÞ   ddl m}m} | jjjD ]'}| d¡\}}}| d¡d }|tj	v r4t
|ƒ}t||ƒ}	t||||	ƒƒ q| jjj ¡ D ]0\}
}|D ])}| d¡\}}}| d¡d }|tj	v rkt
|ƒ}t||ƒ}	t||||
ƒ|	ƒƒ qBq<dS )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   )ÚexpectedFailureÚskipÚ.N)Zunittestrh   ri   r   ÚfeaturesZdjango_test_expected_failuresÚ
rpartitionÚsplitr   ZINSTALLED_APPSr   ÚgetattrÚsetattrZdjango_test_skipsÚitems)r   rh   ri   Z	test_nameZtest_case_nameÚ_Ztest_method_nameZtest_appZ	test_caseZtest_methodÚreasonÚtestsr   r   r   r2   H  s(   

€

€ùÿz5BaseDatabaseCreation.mark_expected_failures_and_skipsc                 C   s   dS )zQ
        SQL to append to the end of the test table creation statements.
        rR   Nr   r   r   r   r   r\   b  s   z.BaseDatabaseCreation.sql_table_creation_suffixc                 C   s$   | j j}|d |d |d |  ¡ fS )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.
        ZHOSTZPORTZENGINEN)r   r,   r&   )r   r,   r   r   r   Útest_db_signatureh  s   üz&BaseDatabaseCreation.test_db_signaturec                 C   s*   |   t|ƒ¡}| jj |¡ | j ¡  d S r
   )rd   Ústrr   r,   Úupdater)   )r   Z
_worker_idr,   r   r   r   Úsetup_worker_connectionv  s   z,BaseDatabaseCreation.setup_worker_connection)r   FTF)F)r   FF)Nr   FN)Ú__name__Ú
__module__Ú__qualname__Ú__doc__r   r   r   r8   r9   r/   rP   r'   r&   rW   r(   rb   rd   ra   rg   rf   r2   r\   rt   rw   r   r   r   r   r	      s0    
ÿJ 	


/


ÿ#r	   )r   r   Úior   Zdjango.appsr   Zdjango.confr   Zdjango.corer   Z	django.dbr   Zdjango.db.transactionr   Zdjango.utils.module_loadingr   rS   r	   r   r   r   r   Ú<module>   s    