a
    xd3                     @   sn   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ZG d	d
 d
ZdS )    N)StringIO)apps)settings)serializers)router)atomicZ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d.dd Zd/d"d#Zd$d% Zd&d' Zd(d) Zd!S )0BaseDatabaseCreationzs
    Encapsulate backend-specific differences pertaining to creation and
    destruction of the test database.
    c                 C   s
   || _ d S N)
connection)selfr
    r   X/var/www/html/Ranjet/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   s4  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 rt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  |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>A   s   z7BaseDatabaseCreation.create_test_db.<locals>.<dictcomp>ZmigrateT)	verbosityinteractivedatabaseZ
run_syncdbZcreatecachetable)r"   )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_connection)	r   r    autoclobber	serializekeepdbr   test_database_nameactionZold_migration_modulesr   r   r   create_test_db   sH    



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_mirrora   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.loaderr4   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_default_managerusingZorder_bypkiterator)r4   loaderZ
app_configmodelZquerysetr   r   r   get_objectso   s(    


z@BaseDatabaseCreation.serialize_db_to_string.<locals>.get_objectsjsonN)indentstream)r   r   r.   getvalue)r   r<   outr   r   r   r,   h   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 s0    Y  dS )zw
        Reload the database with data from a string generated by
        the serialize_db_to_string() method.
        )r7   r=   N)table_names)r   setr   r
   r(   Zconstraint_checks_disabledr   Zdeserializesaveaddobject	__class__r6   Zdb_tableZcheck_constraints)r   datarB   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
parametersr/   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|  |st	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: %srK   zTests cancelled.)r#   r
   ops
quote_namesql_table_creation_suffixr   rQ   	Exceptionr   inputr$   rN   r   exit)	r   r    r-   r/   r0   Ztest_db_paramsrO   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   rR   r    r-   r/   Zsource_database_namer1   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   rR   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   rR   r    r/   r   r   r   r[      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)   r^   r   r$   _destroy_test_dbr   r'   r(   )r   Zold_database_namer    r/   rR   r0   r1   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   rN   r
   rT   rU   )r   r0   r    rO   r   r   r   r`     s    
z%BaseDatabaseCreation._destroy_test_dbc                 C   s   dS )zQ
        SQL to append to the end of the test table creation statements.
        rL   r   r   r   r   r   rV   (  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_signature.  s    z&BaseDatabaseCreation.test_db_signature)r   FTF)F)F)r   FF)F)Nr   FN)__name__
__module____qualname____doc__r   r   r   r2   r3   r,   rJ   r$   r#   rQ   r%   r\   r^   r[   ra   r`   rV   rb   r   r   r   r   r      s&   
C	

)



r   )r   r   ior   Zdjango.appsr   Zdjango.confr   Zdjango.corer   Z	django.dbr   Zdjango.db.transactionr   rM   r   r   r   r   r   <module>   s   