U
    Ha                     @   s   d dl Z d dlmZ d dlmZmZmZmZmZmZ d dl	m
Z
mZ d dlmZmZ d dlmZ d dlmZmZ d dlmZ e d	Zd
d Zdd Zdd ZG dd dZdS )    N)datetime)ColumnsExpressionsForeignKeyName	IndexName	StatementTable)names_digestsplit_identifier)
DeferrableIndex)Query)TransactionManagementErroratomic)timezonezdjango.db.backends.schemac                 C   s2   | j }|jrdS |jr&|jdgkr&dS |j|jkS )zz
    When altering the given field, must constraints on its model from the given
    relation be temporarily dropped?
    FNT)fieldmany_to_manyprimary_keyZ	to_fieldsname)ZrelationZaltered_fieldr    r   B/tmp/pip-unpacked-wheel-3jxiddxt/django/db/backends/base/schema.py_is_relevant_relation   s    r   c                 C   s   | j jddddS )NFT)ZforwardreverseZinclude_hidden)_metaZ_get_fieldsmodelr   r   r   _all_related_fields    s    r   c                    s2   t fddtjD  fddt jD S )Nc                 3   s   | ]}t | r|V  qd S Nr   .0obj)	old_fieldr   r   	<genexpr>(   s     
 z+_related_non_m2m_objects.<locals>.<genexpr>c                 3   s   | ]}t | r|V  qd S r   r   r   )	new_fieldr   r   r#   )   s     
 )zipr   r   )r"   r$   r   )r$   r"   r   _related_non_m2m_objects$   s    r&   c                   @   s  e Zd ZdZdZdZdZdZdZdZ	dZ
d	Zd
ZdZdZeZdZdZdZdZdZdZdZdZdZeZdZeZdZdZdZeZdZ dZ!dZ"dZ#eZ$dZ%dd d!Z&d"d# Z'd$d% Z(dd'd(Z)d)d* Z*d+d, Z+dd-d.Z,d/d0 Z-d1d2 Z.d3d4 Z/d5d6 Z0e1d7d8 Z2d9d: Z3d;d< Z4d=d> Z5d?d@ Z6dAdB Z7dCdD Z8dEdF Z9dGdH Z:dIdJ Z;dKdL Z<dMdN Z=dOdP Z>dQdR Z?dSdT Z@dUdV ZAddWdXZBddYdZZCd[d\ ZDdd]d^ZEd_d` ZFdadb ZGdcdd ZHddfdgZIddhdiZJdjdk ZKdldm ZLdddededd&dd&ddddndodpZMddqdrZNdsdt ZOdudv ZPdwdx ZQdydz ZRd{d| ZSd}d~ ZTdd ZUdd ZVdd ZWdd ZXdd ZYdd ZZdddZ[dddZ\dddZ]dd Z^dd Z_dd Z`dd ZadddZbdddZcdd Zddd Zedd ZfdddZgdS )BaseDatabaseSchemaEditorz
    This class and its subclasses are responsible for emitting schema-changing
    statements to the databases - model creation/removal/alteration, field
    renaming, index fiddling, and so on.
    z'CREATE TABLE %(table)s (%(definition)s)z1ALTER TABLE %(old_table)s RENAME TO %(new_table)sz7ALTER TABLE %(table)s SET TABLESPACE %(new_tablespace)szDROP TABLE %(table)s CASCADEz:ALTER TABLE %(table)s ADD COLUMN %(column)s %(definition)sz!ALTER TABLE %(table)s %(changes)sz%ALTER COLUMN %(column)s TYPE %(type)sz%ALTER COLUMN %(column)s DROP NOT NULLz$ALTER COLUMN %(column)s SET NOT NULLz/ALTER COLUMN %(column)s SET DEFAULT %(default)sz$ALTER COLUMN %(column)s DROP DEFAULTz2ALTER COLUMN %(column)s TYPE %(type)s%(collation)sz4ALTER TABLE %(table)s DROP COLUMN %(column)s CASCADEzDALTER TABLE %(table)s RENAME COLUMN %(old_column)s TO %(new_column)szFUPDATE %(table)s SET %(column)s = %(default)s WHERE %(column)s IS NULLz"UNIQUE (%(columns)s)%(deferrable)szCHECK (%(check)s)z.ALTER TABLE %(table)s DROP CONSTRAINT %(name)sz"CONSTRAINT %(name)s %(constraint)sz?ALTER TABLE %(table)s ADD CONSTRAINT %(name)s CHECK (%(check)s)zPALTER TABLE %(table)s ADD CONSTRAINT %(name)s UNIQUE (%(columns)s)%(deferrable)sz|ALTER TABLE %(table)s ADD CONSTRAINT %(name)s FOREIGN KEY (%(column)s) REFERENCES %(to_table)s (%(to_column)s)%(deferrable)sNzQCREATE INDEX %(name)s ON %(table)s (%(columns)s)%(include)s%(extra)s%(condition)szOCREATE UNIQUE INDEX %(name)s ON %(table)s (%(columns)s)%(include)s%(condition)szDROP INDEX %(name)szGALTER TABLE %(table)s ADD CONSTRAINT %(name)s PRIMARY KEY (%(columns)s)zDROP PROCEDURE %(procedure)sFTc                 C   s,   || _ || _| jrg | _| j jjo$|| _d S r   )
connectioncollect_sqlcollected_sqlfeaturescan_rollback_ddlatomic_migration)selfr(   r)   r   r   r   r   __init__c   s
    z!BaseDatabaseSchemaEditor.__init__c                 C   s(   g | _ | jr$t| jj| _| j  | S r   )deferred_sqlr-   r   r(   alias	__enter__r.   r   r   r   r2   l   s
    
z"BaseDatabaseSchemaEditor.__enter__c                 C   s8   |d kr| j D ]}| | q| jr4| j||| d S r   )r0   executer-   r   __exit__)r.   exc_type	exc_value	tracebacksqlr   r   r   r5   s   s
    
z!BaseDatabaseSchemaEditor.__exit__r   c              	   C   s   | j s | jjr | jjjs tdt|}tjd||||dd | j r|	drTdnd}|dk	r| j
|tt| j| |  q| j
||  n"| j }||| W 5 Q R X dS )z:Execute the given SQL statement, with optional parameters.ziExecuting DDL statements while in a transaction on databases that can't perform a rollback is prohibited.z%s; (params %r))paramsr9   )extra; N)r)   r(   Zin_atomic_blockr+   r,   r   strloggerdebugendswithr*   appendtuplemapquote_valuecursorr4   )r.   r9   r:   ZendingrF   r   r   r   r4   |   s    "z BaseDatabaseSchemaEditor.executec                 C   s   | j j|S r   )r(   ops
quote_name)r.   r   r   r   r   rH      s    z#BaseDatabaseSchemaEditor.quote_namec                    s    j jD ]*} fdd|D }j | qg }g } j jD ]<} |\}}|dkrdqD|jjd}	|	d r|dj	|	  7 }|j
jd}
|
r|d|
 7 }|| |jr6|jr6|jjj j}|jjj |jjj}jr|dj||d  7 }n"jjjr6j |d	 |d
|j|f  | dkrDjj j j|j}|rDj| qD fdd j jD }j j jddd ||D d } j jrjj j j}|r|d| 7 }||fS )z-Take a model and return its table definition.c                    s   g | ]} j |jqS r   r   	get_fieldcolumnr    r   r   r   r   
<listcomp>   s     z6BaseDatabaseSchemaEditor.table_sql.<locals>.<listcomp>Nr(   check  %s)to_table	to_column_fk_%(to_table)s_%(to_column)sz%s %s)Z	AutoFieldZBigAutoFieldZSmallAutoFieldc                    s   g | ]}|  qS r   )Zconstraint_sqlr    
constraintr   r.   r   r   rM      s     , c                 s   s   | ]}|r|V  qd S r   r   rU   r   r   r   r#      s      z5BaseDatabaseSchemaEditor.table_sql.<locals>.<genexpr>)table
definition) r   Zunique_togetherr0   rB   _create_unique_sqllocal_fields
column_sqldb_parametersr(   sql_check_constraintZdb_type_suffixextendremote_fielddb_constraintr   db_tablerJ   
field_namerK   sql_create_inline_fkrH   r+   supports_foreign_keys_create_fk_sqlget_internal_typerG   autoinc_sqlconstraintssql_create_tablejoindb_tablespacetablespace_sql)r.   r   fieldscolumnsZcolumn_sqlsr:   r   rZ   Zextra_params	db_paramsZcol_type_suffixrR   rS   ri   rj   r9   rn   r   rW   r   	table_sql   sX    


z"BaseDatabaseSchemaEditor.table_sqlc                 C   sj  |j | jd}|d }g }|dkr&dS t|dd}|rD|| |7 }|j}|oh| | oh|of| | }|r| |}	d| | }
|	dk	r| jj	j
r||
| |	 7 }n||
7 }||	g7 }|jr|js| jj	jrd}|r| jj	js|d7 }n|s|d	7 }|jr|d
7 }n|jr|d7 }|jp,|jj}|rb| jj	jrb|jrb|d| jjj|dd 7 }||fS )z
        Take a field and return its column definition.
        The field must already have had set_attributes_from_name() called.
        rN   typeN)NNdb_collationz	 DEFAULT Tz NULLz	 NOT NULLz PRIMARY KEYz UNIQUErQ   )inline)r^   r(   getattr_collate_sqlnullskip_defaultskip_default_on_altereffective_default_column_default_sqlr+   requires_literal_defaultsprepare_defaultempty_strings_allowedr   !interprets_empty_strings_as_nullsZimplied_column_nulluniquerm   r   Zsupports_tablespacesrG   rn   )r.   r   r   include_defaultrq   r9   r:   	collationrx   default_valueZcolumn_defaultZ
tablespacer   r   r   r]      sL    





z#BaseDatabaseSchemaEditor.column_sqlc                 C   s   dS )z
        Some backends don't accept default values for certain columns types
        (i.e. MySQL longtext and longblob).
        Fr   r.   r   r   r   r   ry     s    z%BaseDatabaseSchemaEditor.skip_defaultc                 C   s   dS )z
        Some backends don't accept default values for certain columns types
        (i.e. MySQL longtext and longblob) in the ALTER COLUMN statement.
        Fr   r   r   r   r   rz     s    z.BaseDatabaseSchemaEditor.skip_default_on_alterc                 C   s   t ddS )zU
        Only used for backends which have requires_literal_defaults feature
        zsubclasses of BaseDatabaseSchemaEditor for backends which have requires_literal_defaults must provide a prepare_default() methodNNotImplementedErrorr.   valuer   r   r   r~     s    z(BaseDatabaseSchemaEditor.prepare_defaultc                 C   s   dS )z
        Return the SQL to use in a DEFAULT clause. The resulting string should
        contain a '%s' placeholder for a default value.
        %sr   r   r   r   r   r|   $  s    z,BaseDatabaseSchemaEditor._column_default_sqlc                 C   s   |   r|  }n| js<| jr<| jr<|  dkr6d}qd}nbt| ddsTt| ddrt }|  }|dkrv|	 }q|dkr|
 }q|d	krt }nd }|S )
NZBinaryField    r=   Zauto_nowFZauto_now_addZ	DateFieldZ	TimeFieldZDateTimeField)has_defaultget_defaultrx   blankr   rh   rv   r   nowdatetimer   )r   defaultZinternal_typer   r   r   _effective_default+  s"    



z+BaseDatabaseSchemaEditor._effective_defaultc                 C   s   | | || jS )z2Return a field's effective database default value.)Zget_db_prep_saver   r(   r   r   r   r   r{   B  s    z*BaseDatabaseSchemaEditor.effective_defaultc                 C   s
   t  dS )aX  
        Return a quoted version of the value so it's safe to use in an SQL
        string. This is not safe against injection from user code; it is
        intended only for use in making SQL scripts or preparing default values
        for particularly tricky backends (defaults are not user-defined, though,
        so this is safe).
        Nr   r   r   r   r   rE   F  s    z$BaseDatabaseSchemaEditor.quote_valuec                 C   s\   |  |\}}| ||pd | j| | |jjD ]}|jjjj	r8| 
|jj q8dS )zr
        Create a table and any accompanying indexes or unique constraints for
        the given `model`.
        N)rr   r4   r0   r`   _model_indexes_sqlr   local_many_to_manyra   throughauto_createdcreate_model)r.   r   r9   r:   r   r   r   r   r   R  s    z%BaseDatabaseSchemaEditor.create_modelc                 C   s~   |j jD ]}|jjj jr| |jj q| | jd| |j j	i  t
| jD ](}t|trP||j j	rP| j| qPdS )z!Delete a model from the database.rY   N)r   r   ra   r   r   delete_modelr4   sql_delete_tablerH   rc   listr0   
isinstancer   Zreferences_tableremove)r.   r   r   r9   r   r   r   r   c  s     z%BaseDatabaseSchemaEditor.delete_modelc                 C   s.   |j r| jjjsdS | j||| dd dS )zAdd an index on a model.Nr:   )contains_expressionsr(   r+   supports_expression_indexesr4   
create_sqlr.   r   indexr   r   r   	add_indexs  s    z"BaseDatabaseSchemaEditor.add_indexc                 C   s*   |j r| jjjsdS | |||  dS )zRemove an index from a model.N)r   r(   r+   r   r4   
remove_sqlr   r   r   r   remove_index~  s    z%BaseDatabaseSchemaEditor.remove_indexc                 C   s"   | || }|r| j|dd dS )zAdd a constraint to a model.Nr   )r   r4   r.   r   rV   r9   r   r   r   add_constraint  s    z'BaseDatabaseSchemaEditor.add_constraintc                 C   s   | || }|r| | dS )z!Remove a constraint from a model.N)r   r4   r   r   r   r   remove_constraint  s    z*BaseDatabaseSchemaEditor.remove_constraintc                    sz   dd |D }dd |D }| |D ]}|  |ddi| j q&| |D ](} fdd|D }| |  | qLdS )	z
        Deal with a model changing its unique_together. The input
        unique_togethers must be doubly-nested, not the single-nested
        ["foo", "bar"] format.
        c                 S   s   h | ]}t |qS r   rC   r    ro   r   r   r   	<setcomp>  s     zABaseDatabaseSchemaEditor.alter_unique_together.<locals>.<setcomp>c                 S   s   h | ]}t |qS r   r   r   r   r   r   r     s     r   Tc                    s   g | ]} j |jqS r   rI   rL   r   r   r   rM     s     zBBaseDatabaseSchemaEditor.alter_unique_together.<locals>.<listcomp>N)
difference_delete_composed_indexsql_delete_uniquer4   r[   )r.   r   Zold_unique_togetherZnew_unique_togetheroldsnewsro   rp   r   r   r   alter_unique_together  s    z.BaseDatabaseSchemaEditor.alter_unique_togetherc                    s   dd |D }dd |D }| |D ]}|  |ddd| j q&| |D ],} fdd|D }| | j |d	d
 qNdS )z
        Deal with a model changing its index_together. The input
        index_togethers must be doubly-nested, not the single-nested
        ["foo", "bar"] format.
        c                 S   s   h | ]}t |qS r   r   r   r   r   r   r     s     z@BaseDatabaseSchemaEditor.alter_index_together.<locals>.<setcomp>c                 S   s   h | ]}t |qS r   r   r   r   r   r   r     s     TF)r   r   c                    s   g | ]} j |qS r   r   rJ   rL   r   r   r   rM     s     zABaseDatabaseSchemaEditor.alter_index_together.<locals>.<listcomp>_idxro   suffixN)r   r   sql_delete_indexr4   _create_index_sql)r.   r   Zold_index_togetherZnew_index_togetherr   r   ro   field_namesr   r   r   alter_index_together  s    z-BaseDatabaseSchemaEditor.alter_index_togetherc           	         s   dd  j jD }dd  j jD } fdd|D }| j |fd||B i|}t|dkr~tdt| j jd	|f | | 	| |d
  d S )Nc                 S   s   h | ]
}|j qS r   r   rU   r   r   r   r     s     zBBaseDatabaseSchemaEditor._delete_composed_index.<locals>.<setcomp>c                 S   s   h | ]
}|j qS r   r   rU   r   r   r   r     s     c                    s   g | ]} j |jqS r   rI   rL   r   r   r   rM     s     zCBaseDatabaseSchemaEditor._delete_composed_index.<locals>.<listcomp>exclude   z1Found wrong number (%s) of constraints for %s(%s)rX   r   )
r   rj   indexes_constraint_nameslen
ValueErrorrc   rl   r4   _delete_constraint_sql)	r.   r   ro   Zconstraint_kwargsr9   meta_constraint_namesmeta_index_namesrp   constraint_namesr   r   r   r     s$     z/BaseDatabaseSchemaEditor._delete_composed_indexc                 C   sn   ||ks"| j jjr&| | kr&dS | | j| || |d  | jD ]}t|t	rN|
|| qNdS )z#Rename the table a model points to.N)Z	old_tableZ	new_table)r(   r+   Zignores_table_name_caselowerr4   sql_rename_tablerH   r0   r   r   Zrename_table_references)r.   r   Zold_db_tableZnew_db_tabler9   r   r   r   alter_db_table  s    


z'BaseDatabaseSchemaEditor.alter_db_tablec                 C   s2   |  | j| |jj| || |d  dS )z)Move a model's table between tablespaces.)rY   Zold_tablespaceZnew_tablespaceN)r4   sql_retablespace_tablerH   r   rc   )r.   r   Zold_db_tablespaceZnew_db_tablespacer   r   r   alter_db_tablespace  s
    z,BaseDatabaseSchemaEditor.alter_db_tablespacec              
   C   s  |j r |jjjjr | |jjS | j||dd\}}|dkr@dS |j| jd}|d rh|d| j	|  7 }|jr2| jj
jr2|jr2d}| jr|jjjj}|jjj|jjj}t|jj\}	}
|d| j| ||||	rd| |	 nd	| |j| || || jj d
  7 }n| j| ||| | j| |jj| |j|d }| || | |s| |dk	r| j|d|dd\}}| j | |jj|d }| || | j!| "|| | jj
j#r| j$  dS )z
        Create a field on a model. Usually involves adding a column, but may
        involve adding a table instead (for M2M fields).
        T)r   NrN   rO   rP   rT   z%s.r=   )r   	namespacerK   rR   rS   
deferrable)rY   rK   rZ   droprY   changes)%r   ra   r   r   r   r   r]   r^   r(   r_   r+   rf   rb   sql_create_column_inline_fkr   rc   rJ   rd   rK   r
   _fk_constraint_namerH   rG   deferrable_sqlr0   rB   rg   sql_create_columnr4   rz   r{   _alter_column_default_sqlsql_alter_columnr`   _field_indexes_sqlconnection_persists_old_columnsclose)r.   r   r   rZ   r:   rq   Zconstraint_suffixrR   rS   r   _r9   changes_sqlr   r   r   	add_field  sN    



z"BaseDatabaseSchemaEditor.add_fieldc                 C   s   |j r |jjjjr | |jjS |j| jdd dkr:dS |jrp| j||j	gdd}|D ]}| 
| || qX| j| |jj| |j	d }| 
| | jjjr| j  t| jD ],}t|tr||jj|j	r| j| qdS )z
        Remove a field from a model. Usually involves deleting a column,
        but for M2Ms may involve deleting a table.
        rN   rs   NTforeign_key)rY   rK   )r   ra   r   r   r   r   r^   r(   r   rK   r4   _delete_fk_sqlsql_delete_columnrH   rc   r+   r   r   r   r0   r   r   Zreferences_columnr   )r.   r   r   fk_namesfk_namer9   r   r   r   remove_field  s$    



z%BaseDatabaseSchemaEditor.remove_fieldc           	   
   C   s6  |  ||sdS |j| jd}|d }|j| jd}|d }|dkrN|jdks`|dkrr|jdkrrtd||f n|dkr|dkr|jjr|jjr|jjjjr|jjjjr| ||||S |dkr|dkr|jjr|jjr|jjjjs|jjjjsdS |dks
|dkrtd||f | 	|||||||| dS )a'  
        Allow a field's type, uniqueness, nullability, default, column,
        constraints, etc. to be modified.
        `old_field` is required to compute the necessary changes.
        If `strict` is True, raise errors if the old column does not match
        `old_field` precisely.
        NrN   rs   zqCannot alter field %s into %s - they do not properly define db_type (are you using a badly-written custom field?)zCannot alter field %s into %s - they are not compatible types (you cannot alter to or from M2M fields, or add or remove through= on M2M fields))
_field_should_be_alteredr^   r(   ra   r   r   r   r   _alter_many_to_many_alter_field)	r.   r   r"   r$   strictold_db_paramsold_typenew_db_paramsnew_typer   r   r   alter_field8  s^    



  z$BaseDatabaseSchemaEditor.alter_fieldc	           )      C   s  t  }	| jjjr|jr|jr| j||jgdd}
|r\t|
dkr\t	dt|
|j
j|jf |
D ]$}|	|jf | | || q`|jr|jr| ||rdd |j
jD }| j||jgdd|d}|rt|dkrt	d	t||j
j|jf |D ]}| | || q| jjjoF|jr0|js@|joF|joF||k}|rt||D ]B\}}| j|j|jjgdd}|D ]}| | |j| q|qX|jr|js|jr|jrd
d |j
jD }| j||jgdtj|d}|D ]}| | || q|d |d kr|d rdd |j
jD }| j||jgd|d}|rzt|dkrzt	dt||j
j|jf |D ]}| | || q~|j|jkr| | |j
j||| | jD ](}t|t r|!|j
j|j|j qg }g }g }t"|dd}t"|dd}||kr:| #||||}|$| n2||krl| %||||\}}|$| |&| d}|j'r|j's| (|}| (|} | )|s|| kr| dk	rd}|$| *||| |j'|j'kr| +|||}|r|$| |, o|j'o|j' }!|s|r|!s,|| }| jjj-rd|rdt.t/| \}}"d0|t1|"g fg}|D ],\}}"| | j2| 3|j
j|d |" qh|!r| | j4| 3|j
j| 3|jdd | g |D ],\}}"| | j2| 3|j
j|d |" q|r|D ]\}}"| ||" q|jr:|js:| 5|| | 6||r^| | 7||jg |jrn|jr|jr|js| | j8||gd g }#|r|#&t|| | ||r| | 9|| |#&t|| |#D ]\}$}|jj:| jd}%|%d }&| %|j|$j|j|&\}}| | j2| 3|jj
j|d d |d  |D ]\}}"| ||" qLq| jjjr|jr|	s|jr|js|jr| | ;||d |r|j<j
j=D ]4}'t>|'|r|'jjr| | ;|'j|'jd q|d |d kr@|d r@| j?|j
j|jgdd}| | @|||d  |r| j*|||dd\}(}"| j2| 3|j
j|(d }| ||" | jjjAr| jB  dS )z3Perform a "physical" (non-ManyToMany) field update.Tr   r   z<Found wrong number (%s) of foreign key constraints for %s.%sc                 S   s   h | ]
}|j qS r   r   rU   r   r   r   r   z  s     z8BaseDatabaseSchemaEditor._alter_field.<locals>.<setcomp>F)r   r   r   z7Found wrong number (%s) of unique constraints for %s.%sc                 S   s   h | ]
}|j qS r   r   )r    r   r   r   r   r     s     )r   type_r   rO   c                 S   s   h | ]
}|j qS r   r   rU   r   r   r   r     s     )rO   r   z6Found wrong number (%s) of check constraints for %s.%srt   NrX   r   r   )rY   rK   r   ro   rN   rs   r   rT   Z_fk_checkr   r   )Csetr(   r+   rf   ra   rb   r   rK   r   r   r   rc   addr4   r   r   _field_became_primary_keyrj   _delete_unique_sqlr   r&   Zrelated_modelr   db_indexr   r   r   _delete_index_sql_delete_check_sql_rename_field_sqlr0   r   r   Zrename_column_referencesrv   _alter_column_collation_sqlrB   _alter_column_type_sqlr`   rx   r{   rz   r   _alter_column_null_sqlr   Zsupports_combined_altersrC   r%   rl   sumr   rH   sql_update_with_default_delete_primary_key_unique_should_be_addedr[   r   _create_primary_key_sqlr^   rg   r   Zrelated_objectsr   _create_index_name_create_check_sqlr   r   ))r.   r   r"   r$   r   r   r   r   r   Zfks_droppedr   r   r   r   constraint_nameZdrop_foreign_keysZ_old_relZnew_relZrel_fk_namesr   Zindex_names
index_namer9   actionsZnull_actionsZpost_actionsZold_collationnew_collationfragmentZother_actionsZneeds_database_defaultZold_defaultnew_defaultZfour_way_default_alterationr:   Zrels_to_updateZold_relZrel_db_paramsZrel_typerelr   r   r   r   r   c  s              











    z%BaseDatabaseSchemaEditor._alter_fieldc                 C   s\   | j jjr| dkrdS |j| j d}|jr4| jn| j}|| |j	|d d g fS dS )z
        Hook to specialize column null alteration.

        Return a (sql, params) fragment to set a column to null or non-null
        as required by new_field, or None if no changes are required.
        )Z	CharFieldZ	TextFieldNrN   rs   rK   rs   )
r(   r+   r   rh   r^   rx   sql_alter_column_nullsql_alter_column_not_nullrH   rK   )r.   r   r"   r$   r   r9   r   r   r   r   b  s    


z/BaseDatabaseSchemaEditor._alter_column_null_sqlc           
      C   s   |  |}| |}|g}|r$g }n| jjjr<| |}g }|j| jd}|rd|jr\| j}	qj| j	}	n| j
}	|	| |j|d |d |fS )z
        Hook to specialize column default alteration.

        Return a (sql, params) fragment to add or drop (depending on the drop
        argument) a default to new_field's column.
        rN   rs   )rK   rs   r   )r{   r|   r(   r+   r}   r~   r^   rx    sql_alter_column_no_default_nullsql_alter_column_no_defaultsql_alter_column_defaultrH   rK   )
r.   r   r"   r$   r   r  r   r:   r   r9   r   r   r   r   x  s*    




z2BaseDatabaseSchemaEditor._alter_column_default_sqlc                 C   s    | j | |j|d g fg fS )a  
        Hook to specialize column type alteration for different backends,
        for cases when a creation type is different to an alteration type
        (e.g. SERIAL in PostgreSQL, PostGIS fields).

        Return a two-tuple of: an SQL fragment of (sql, params) to insert into
        an ALTER TABLE statement and a list of extra (sql, params) tuples to
        run once the field is altered.
        r
  )sql_alter_column_typerH   rK   )r.   r   r"   r$   r   r   r   r   r     s    
z/BaseDatabaseSchemaEditor._alter_column_type_sqlc                 C   s,   | j | |j||r| |ndd g fS )Nr=   )rK   rs   r   )sql_alter_column_collaterH   rK   rw   )r.   r   r$   r   r  r   r   r   r     s    
z4BaseDatabaseSchemaEditor._alter_column_collation_sqlc                 C   s   |j jjj|j jjjkr:| |j j|j jjj|j jjj | |j j|j jj| |j jj|  | |j j|j jj| |j jj|  dS )z*Alter M2Ms to repoint their to= endpoints.N)	ra   r   r   rc   r   r   rJ   Zm2m_reverse_field_nameZm2m_field_name)r.   r   r"   r$   r   r   r   r   r     s    
z,BaseDatabaseSchemaEditor._alter_many_to_manyr=   c           	      C   s   t |\}}dt|f|ddi|f }| jj p6d}d|d||f }t||kr\|S t||d kr||d|d  }|t| d	 d
 }d|d| d|d| |f }|d dks|d  rd|dd  }|S )z
        Generate a unique name for an index/unique constraint.

        The name is divided into 3 parts: the table name, the column names,
        and a unique digest and suffix.
        z%s%slength      z%s_%s_%sr      N   r   r   zD%s)r
   r	   r(   rG   Zmax_name_lengthrl   r   isdigit)	r.   Z
table_namecolumn_namesr   r   Zhash_suffix_part
max_lengthr  Zother_lengthr   r   r   r    s"    
z+BaseDatabaseSchemaEditor._create_index_namec                 C   sX   |d kr:t |dkr*|d jr*|d j}n|jjr:|jj}|d k	rTd| jj| S dS )Nr   r   rP   r=   )r   rm   r   r(   rG   rn   )r.   r   ro   rm   r   r   r   _get_index_tablespace_sql  s    z2BaseDatabaseSchemaEditor._get_index_tablespace_sqlc                 C   s   |rd| S dS )Nz WHERE r=   r   )r.   	conditionr   r   r   _index_condition_sql  s    z-BaseDatabaseSchemaEditor._index_condition_sqlc                 C   s,   |r| j jjsdS tdt|jj|| jdS )Nr=   z INCLUDE (%(columns)s))rp   )r(   r+   supports_covering_indexesr   r   r   rc   rH   )r.   r   rp   r   r   r   _index_include_sql  s    z+BaseDatabaseSchemaEditor._index_include_sql)ro   r   r   usingrm   col_suffixesr9   	opclassesr  includeexpressionsc                   s   |pg }|pg }t |ddjjd}j|||d}dd |D }|pLj}|jj} fdd}t|t|j	t
||||||r||||	nt|||j||
||d	S )
z
        Return the SQL statement to create the index for one or several fields
        or expressions. `sql` can be specified if the syntax differs from the
        standard (GIS indexes, ...).
        F)Z
alias_colsrN   )rm   c                 S   s   g | ]
}|j qS r   )rK   rL   r   r   r   rM     s     z>BaseDatabaseSchemaEditor._create_index_sql.<locals>.<listcomp>c                     s    d krj | |  S r   )r  rH   argskwargsr   r.   r   r   create_index_name  s    zEBaseDatabaseSchemaEditor._create_index_sql.<locals>.create_index_name)rY   r   r   rp   r;   r  r#  )r   Zget_compilerr(   r  sql_create_indexr   rc   r   r   rH   r   _index_columnsr   rE   r  r  )r.   r   ro   r   r   r   rm   r!  r9   r"  r  r#  r$  compilerrn   rp   r*  rY   r)  r   r(  r   r     s,    


z*BaseDatabaseSchemaEditor._create_index_sqlc                 C   s&   t |p
| jt|jj| j| |dS N)rY   r   )r   r   r   r   rc   rH   )r.   r   r   r9   r   r   r   r   ,  s
    z*BaseDatabaseSchemaEditor._delete_index_sqlc                 C   s   t ||| j|dS )N)r!  )r   rH   )r.   rY   rp   r!  r"  r   r   r   r+  3  s    z'BaseDatabaseSchemaEditor._index_columnsc                    s    j jr j js j jrg S g } j jD ]}||  | q( j jD ],} fdd|D }|| j	 |dd qH j j
D ]&}|jr| jjjr~|| |  q~|S )z
        Return a list of all index SQL statements (field indexes,
        index_together, Meta.indexes) for the specified model.
        c                    s   g | ]} j |qS r   r   rL   r   r   r   rM   B  s     z?BaseDatabaseSchemaEditor._model_indexes_sql.<locals>.<listcomp>r   r   )r   ZmanagedproxyZswappedr\   r`   r   Zindex_togetherrB   r   r   r   r(   r+   r   r   )r.   r   outputr   r   ro   r   r   r   r   r   6  s    z+BaseDatabaseSchemaEditor._model_indexes_sqlc                 C   s*   g }|  ||r&|| j||gd |S )zT
        Return a list of all index SQL statements for the specified field.
        r   )_field_should_be_indexedrB   r   )r.   r   r   r/  r   r   r   r   M  s    z+BaseDatabaseSchemaEditor._field_indexes_sqlc                 C   s   |  \}}}}|  \}}}}	ddddddddd	d
dg}
|
D ]}||d  |	|d  q>| |j| |jkp|||f|||	fkS )Nr   Z	db_columneditableZerror_messages	help_textZlimit_choices_toZ	on_deleteZrelated_nameZrelated_query_nameZ
validatorsZverbose_name)ZdeconstructpoprH   rK   )r.   r"   r$   r   old_pathZold_argsZ
old_kwargsnew_pathnew_argsZ
new_kwargsZnon_database_attrsattrr   r   r   r   V  s(    z1BaseDatabaseSchemaEditor._field_should_be_alteredc                 C   s   |j o|j S r   )r   r   r.   r   r   r   r   r   r0  s  s    z1BaseDatabaseSchemaEditor._field_should_be_indexedc                 C   s   |j  o|j S r   r   r.   r"   r$   r   r   r   r   v  s    z2BaseDatabaseSchemaEditor._field_became_primary_keyc                 C   s"   |j  r|j p |jo |j o |j S r   )r   r   r:  r   r   r   r   y  s    z0BaseDatabaseSchemaEditor._unique_should_be_addedc                 C   s*   | j | || |j| |j|d S )N)rY   Z
old_columnZ
new_columnrs   )sql_rename_columnrH   rK   )r.   rY   r"   r$   r   r   r   r   r   ~  s    

z*BaseDatabaseSchemaEditor._rename_field_sqlc           
   	   C   s   t |jj| j}| |||}t|jj|jg| j}t |jjjj| j}t|jjjj|jjg| j}| j	j
 }	t| j||||||	dS )N)rY   r   rK   rR   rS   r   )r   r   rc   rH   r   r   rK   target_fieldr   r(   rG   r   r   sql_create_fk)
r.   r   r   r   rY   r   rK   rR   rS   r   r   r   r   rg     s    z'BaseDatabaseSchemaEditor._create_fk_sqlc                    s<    fdd}t |jj|jgt|jjjjd |jjg||S )Nc                     s      j| |S r   rH   r  r%  r3   r   r   create_fk_name  s    zDBaseDatabaseSchemaEditor._fk_constraint_name.<locals>.create_fk_namer   )r   r   rc   rK   r
   r<  r   )r.   r   r   r   r?  r   r3   r   r     s    z,BaseDatabaseSchemaEditor._fk_constraint_namec                 C   s   |  | j||S r   )r   sql_delete_fkr.   r   r   r   r   r   r     s    z'BaseDatabaseSchemaEditor._delete_fk_sqlc                 C   s,   |d krdS |t jkrdS |t jkr(dS d S )Nr=   z DEFERRABLE INITIALLY DEFERREDz DEFERRABLE INITIALLY IMMEDIATE)r   ZDEFERREDZ	IMMEDIATE)r.   r   r   r   r   _deferrable_constraint_sql  s    

z3BaseDatabaseSchemaEditor._deferrable_constraint_sqlc           
      C   s   |r| j jjsd S |s|s|rH| j||||||d}|rD| j| d S | jdt| j	|| 
|d }	| j| 	||	d S )N)r   r  r#  r"  rX   )rp   r   r   rV   )r(   r+   &supports_deferrable_unique_constraintsr[   r0   rB   sql_unique_constraintrl   rD   rH   rB  sql_constraint)
r.   r   ro   r   r  r   r#  r"  r9   rV   r   r   r   _unique_sql  s2    z$BaseDatabaseSchemaEditor._unique_sqlc                    s   |r j jjr*|r j jjr*|r. j jjs.d S  fdd}t|jj j}	|d krft	|jj|d|}n
 |} j
|	|d|d}|s|s|r j}
n j}
t|
|	|| | | ||dS )Nc                     s      j| |S r   r>  r%  r3   r   r   create_unique_name  s    zGBaseDatabaseSchemaEditor._create_unique_sql.<locals>.create_unique_name_uniqr   )r!  r"  )rY   r   rp   r  r   r#  )r(   r+   rD  supports_partial_indexesr  r   r   rc   rH   r   r+  sql_create_unique_indexsql_create_uniquer   r  rB  r  )r.   r   rp   r   r  r   r#  r"  rH  rY   r9   r   r3   r   r[     s>    

z+BaseDatabaseSchemaEditor._create_unique_sqlc                 C   sV   |r| j jjr*|r| j jjr*|r.| j jjs.d S |s:|s:|rB| j}n| j}| |||S r   )r(   r+   rD  rJ  r  r   r   r   )r.   r   r   r  r   r#  r"  r9   r   r   r   r     s"    z+BaseDatabaseSchemaEditor._delete_unique_sqlc                 C   s    | j | || jd|i d S )NrO   rC  )rF  rH   r_   )r.   r   rO   r   r   r   
_check_sql  s    z#BaseDatabaseSchemaEditor._check_sqlc                 C   s$   t | jt|jj| j| ||dS )N)rY   r   rO   )r   sql_create_checkr   r   rc   rH   )r.   r   r   rO   r   r   r   r    s    z*BaseDatabaseSchemaEditor._create_check_sqlc                 C   s   |  | j||S r   )r   sql_delete_checkrA  r   r   r   r     s    z*BaseDatabaseSchemaEditor._delete_check_sqlc                 C   s    t |t|jj| j| |dS r-  )r   r   r   rc   rH   )r.   templater   r   r   r   r   r     s
    z/BaseDatabaseSchemaEditor._delete_constraint_sqlc
              	      s  |dk	r fdd|D } j  }
 j j|
|jj}W 5 Q R X g }| D ]\}}|dksl||d krP|dk	r|d |krqP|dk	r|d |krqP|dk	r|d |krqP|dk	r|d |krqP|dk	r|d	 sqP|dk	r|d
 |krqP|	r||	krP|| qP|S )z@Return all constraint names matching the columns and conditions.Nc                    s   g | ]} j j|qS r   )r(   introspectionZidentifier_converter)r    r   r3   r   r   rM   $  s   z>BaseDatabaseSchemaEditor._constraint_names.<locals>.<listcomp>rp   r   r   r   rO   r   rs   )r(   rF   rQ  Zget_constraintsr   rc   itemsrB   )r.   r   r  r   r   r   r   rO   r   r   rF   rj   resultr   Zinfodictr   r3   r   r     s0    
z*BaseDatabaseSchemaEditor._constraint_namesc                 C   sV   | j |dd}|r6t|dkr6tdt||jjf |D ]}| | || q:d S )NTr9  r   z0Found wrong number (%s) of PK constraints for %s)r   r   r   r   rc   r4   _delete_primary_key_sql)r.   r   r   r   r  r   r   r   r   =  s    z,BaseDatabaseSchemaEditor._delete_primary_keyc              
   C   sJ   t | jt|jj| j| | j|jj|jgddt|jj|jg| jdS )NZ_pkr   )rY   r   rp   )	r   sql_create_pkr   r   rc   rH   r  rK   r   r8  r   r   r   r   G  s    z0BaseDatabaseSchemaEditor._create_primary_key_sqlc                 C   s   |  | j||S r   )r   sql_delete_pkrA  r   r   r   rT  Q  s    z0BaseDatabaseSchemaEditor._delete_primary_key_sqlc                 C   s   d|  | S )Nz	 COLLATE )rH   )r.   r   r   r   r   rw   T  s    z%BaseDatabaseSchemaEditor._collate_sqlc                 C   s*   | j | |d|d }| | d S )N,)Z	procedureparam_types)sql_delete_procedurerH   rl   r4   )r.   Zprocedure_namerX  r9   r   r   r   remove_procedureW  s
    z)BaseDatabaseSchemaEditor.remove_procedure)FT)r   )F)F)F)F)r=   )N)N)NNNN)NNNNN)NNNN)NNNNNNNN)F)r   )h__name__
__module____qualname____doc__rk   r   r   r   r   r   r  r  r  r  r  r  r  r   r;  r   rE  r_   Zsql_delete_constraintrF  rN  rO  rL  r   r=  re   r   r@  r*  rK  r   rU  rV  rY  r/   r2   r5   r4   rH   rr   r]   ry   rz   r~   r|   staticmethodr   r{   rE   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r  r  r  r  r   r   r+  r   r   r   r0  r   r   r   rg   r   r   rB  rG  r[   r   rM  r  r   r   r   r   r   rT  rw   rZ  r   r   r   r   r'   -   s
  
		
;
<	
	9
, 
  
%



     '
		      
!        
&      
           



r'   )loggingr   Z!django.db.backends.ddl_referencesr   r   r   r   r   r   Zdjango.db.backends.utilsr	   r
   Zdjango.db.modelsr   r   Zdjango.db.models.sqlr   Zdjango.db.transactionr   r   Zdjango.utilsr   	getLoggerr?   r   r   r&   r'   r   r   r   r   <module>   s    
	