a
    ÛEbì:  ã                   @   sŠ   d dl Z d dlZd dlmZ d dlmZ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)ÚexpectedFailureÚskip)Ú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d/dd„Zdd„ Zd0dd „Zd1d"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   ú`/home/ja/django-apps/lartica_env/lib/python3.9/site-packages/django/db/backends/base/creation.pyÚ__init__   s    zBaseDatabaseCreation.__init__c                 C   s
   | j  ¡ S r   )r   Ú_nodb_cursor©r   r   r   r   r      s    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   sN  ddl m} |  ¡ }|dkrBd}|r(d}|  d||  ||¡f ¡ |  |||¡ | j ¡  |tj	| jj
 d< || jjd< zl| jjd d	 d
u r¨tj}dd„ t ¡ D ƒt_|dt|d dƒd
| jj
dd� W | jjd d	 d
u rä|t_n| jjd d	 d
u �r|t_0 |�r|  ¡ | j_|d| jj
d� | j ¡  tj d¡dk�rJ|  ¡  |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>I   s   z7BaseDatabaseCreation.create_test_db.<locals>.<dictcomp>ZmigrateT)Ú	verbosityÚinteractiveÚdatabaseZ
run_syncdbZcreatecachetable)r%   ZRUNNING_DJANGOS_TEST_SUITEÚtrue)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!   sR    
þÿÿ
ÿûÿ
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_mirrork   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r|j|jv r|jt	j
vr| ¡ D ]L}|j ˆ j¡rLt ˆ jj|¡rL|j ˆ jj¡ |jjj¡}| ¡ E d H  qLq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   s*    
ÿ
þ
ýÿþÿþz@BaseDatabaseCreation.serialize_db_to_string.<locals>.get_objectsÚjsonN)ÚindentÚstream)r   r   r5   Úgetvalue)r   rC   Úoutr   r   r   r0   r   s    z+BaseDatabaseCreation.serialize_db_to_stringc              	   C   s¬   t |ƒ}tƒ }t| jjd��| | j ¡ �D tjd|| jjd�D ]}| ¡  | 	|j
jjj¡ q>W d  ƒ n1 sr0    Y  | jj|d� W d  ƒ n1 sž0    Y  dS )zw
        Reload the database with data from a string generated by
        the serialize_db_to_string() method.
        )r>   rD   N)Útable_names)r   Úsetr	   r   r,   Zconstraint_checks_disabledr   ZdeserializeÚsaveÚaddÚobjectÚ	__class__r=   Zdb_tableZcheck_constraints)r   ÚdatarI   Úobjr   r   r   Údeserialize_db_from_string‘   s    
ÿ
2z/BaseDatabaseCreation.deserialize_db_from_stringc                 C   s    d| j j|dkrd| ndf S )zR
        Return display string for a database for use in various actions.
        z'%s'%sé   z ('%s')Ú )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   )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Ú
parametersr6   r   r   r   Ú_execute_create_test_dbº   s    z,BaseDatabaseCreation._execute_create_test_dbc           	      C   sp  |   ¡ }| jj |¡|  ¡ dœ}|  ¡ ��0}z|  |||¡ W �n
 t�yJ } zð|rt|W  Y d}~W  d  ƒ S |  d| ¡ |s’t	d| ƒ}|s |dk�r"z@|dkrÂ|  d|  
||¡f ¡ | d| ¡ |  |||¡ W n> t�y } z$|  d	| ¡ t d
¡ W Y d}~n
d}~0 0 n|  d¡ t d¡ W Y d}~n
d}~0 0 W d  ƒ n1 �sb0    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: %srR   zTests cancelled.)r'   r   ÚopsÚ
quote_nameÚsql_table_creation_suffixr   rX   Ú	Exceptionr   Úinputr(   rU   r   Úexit)	r   r#   r4   r6   r7   Ztest_db_paramsrV   ÚeZconfirmr   r   r   r)   ½   sH    þÿÿÿÿÿÿ"
@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   rY   r#   r4   r6   Zsource_database_namer8   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{}_{})r   r-   Úformat)r   rY   Zorig_settings_dictr   r   r   Úget_test_db_clone_settings  s    ÿþz/BaseDatabaseCreation.get_test_db_clone_settingsc                 C   s   t dƒ‚dS )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   rY   r#   r6   r   r   r   rb     s    ÿz#BaseDatabaseCreation._clone_test_dbNc                 C   s–   | j  ¡  |du r | j jd }n|  |¡d }|dkr\d}|rBd}|  d||  ||¡f ¡ |sl|  ||¡ |dur’|tj| j j	 d< || j jd< 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-   re   r   r(   Ú_destroy_test_dbr   r+   r,   )r   Zold_database_namer#   r6   rY   r7   r8   r   r   r   Údestroy_test_db  s(    

þÿÿ
z$BaseDatabaseCreation.destroy_test_dbc                 C   sD   |   ¡ �(}| d| jj |¡ ¡ W d  ƒ n1 s60    Y  dS )zF
        Internal implementation - remove the test db tables.
        zDROP DATABASE %sN)r   rU   r   r[   r\   )r   r7   r#   rV   r   r   r   rg   ;  s    
ÿz%BaseDatabaseCreation._destroy_test_dbc           
      C   sÎ   | j jjD ]N}| d¡\}}}| d¡d }|tjv r
t|ƒ}t||ƒ}t	||t
|ƒƒ q
| j jj ¡ D ]`\}}	|	D ]R}| d¡\}}}| d¡d }|tjv rtt|ƒ}t||ƒ}t	||t|ƒ|ƒƒ qtqhd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   N)r   ÚfeaturesZdjango_test_expected_failuresÚ
rpartitionÚsplitr   ZINSTALLED_APPSr
   ÚgetattrÚsetattrr   Zdjango_test_skipsÚitemsr   )
r   Z	test_nameZtest_case_nameÚ_Ztest_method_nameZtest_appZ	test_caseZtest_methodÚreasonÚtestsr   r   r   r3   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.
        rS   r   r   r   r   r   r]   _  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ENGINE)r   r-   r'   )r   r-   r   r   r   Útest_db_signaturee  s    üz&BaseDatabaseCreation.test_db_signature)r   FTF)F)F)r   FF)F)Nr   FN)Ú__name__Ú
__module__Ú__qualname__Ú__doc__r   r   r   r9   r:   r0   rQ   r(   r'   rX   r)   rc   re   rb   rh   rg   r3   r]   rs   r   r   r   r   r      s,    ÿ
J	

/


 ÿ
#r   )r   r   Úior   Zunittestr   r   Zdjango.appsr   Zdjango.confr   Zdjango.corer   Z	django.dbr   Zdjango.db.transactionr	   Zdjango.utils.module_loadingr
   rT   r   r   r   r   r   Ú<module>   s   