OwlCyberSecurity - MANAGER
Edit File: operations.cpython-39.pyc
a ���egs � @ s� d dl Z d dlZd dlmZ d dlmZ d dlmZmZ d dl m Z d dl m Z m Z mZ d dlmZmZmZmZ d dlmZ d d lmZ d d lmZ d d lmZm Z d d l m Z d d l m Z ddl!m"Z" ddl#m$Z$m%Z%m&Z& G dd� de �Z'dS )� N)� lru_cache)�settings)� DatabaseError�NotSupportedError)�BaseDatabaseOperations)�split_tzname_delta� strip_quotes� truncate_name)� AutoField�Exists�ExpressionWrapper�Lookup)�RawSQL)� WhereNode)�timezone)� force_bytes� force_str)�cached_property)�_lazy_re_compile� )�Database)�BulkInsertMapper� InsertVar�Oracle_datetimec s2 e Zd Zdddddddddd� Zi ej�ddi�Zd Zd Zd d d ed�Zdd� Z e d�Z dd� Z d~dd�Z e d�Zdd� Zdd� Zd d � Zd d � Zd d!� Zd"d#� Zdd$d%�Z� fd&d'�Zd(d)� Zd*d+� Zd,d-� Zd.d/� Zd0d1� Zd2d3� Z d4d5� Z e d6d7� �Z e d8d9� �Z d:d;� Z!d<d=� Z"d>d?� Z#d@dA� Z$dBdC� Z%dDdE� Z&d�dFdG�Z'dHdI� Z(dJdK� Z)dLdM� Z*dNdO� Z+dPdQ� Z,dRdS� Z-dTdU� Z.dVdW� Z/dXdY� Z0e1dZd[� �Z2d\d\d]�d^d_�Z3d`da� Z4dbdc� Z5ddde� Z6d�dfdg�Z7dhdi� Z8djdk� Z9dldm� Z:d�dndo�Z;� fdpdq�Z<drds� Z=dtdu� Z>dvdw� Z?� fdxdy�Z@dzd{� ZAd|d}� ZB� ZCS )��DatabaseOperations)l�����g�] � �g�] )l������ 9V � �� 9V )r r )r r )iay��i�� ) ZSmallIntegerFieldZ IntegerFieldZBigIntegerFieldZPositiveBigIntegerFieldZPositiveSmallIntegerFieldZPositiveIntegerField�SmallAutoFieldr � BigAutoField� difference�MINUSa� DECLARE table_value integer; seq_value integer; seq_name user_tab_identity_cols.sequence_name%%TYPE; BEGIN BEGIN SELECT sequence_name INTO seq_name FROM user_tab_identity_cols WHERE table_name = '%(table_name)s' AND column_name = '%(column_name)s'; EXCEPTION WHEN NO_DATA_FOUND THEN seq_name := '%(no_autofield_sequence_name)s'; END; SELECT NVL(MAX(%(column)s), 0) INTO table_value FROM %(table)s; SELECT NVL(last_number - cache_size, 0) INTO seq_value FROM user_sequences WHERE sequence_name = seq_name; WHILE table_value > seq_value LOOP EXECUTE IMMEDIATE 'SELECT "'||seq_name||'".nextval FROM DUAL' INTO seq_value; END LOOP; END; /zNVARCHAR2(2000)z NUMBER(11)z NUMBER(19)z NUMBER(5))r r r � TextFieldc C s | � d�}d|� d|� d�S )N� cache_keyzSELECT z FROM %s ORDER BY z( OFFSET %%s ROWS FETCH FIRST 1 ROWS ONLY�� quote_name)�selfr" � r& �e/home/gouroczh/virtualenv/pat/3.9/lib/python3.9/site-packages/django/db/backends/oracle/operations.py�cache_key_culling_sqlH s ��z(DatabaseOperations.cache_key_culling_sqlz[A-Z_]+c C s� d|� d�}d }|dkr d}n||dkr8d|� d�}d}nb|dkrFd}nT|d krTd }nF|d krbd }n8|� � }| j�|�s�td |����d|� d|� d�|fS |g |�|�R fS )NzTO_CHAR(�, %s)Zweek_day�DZ iso_week_dayz - 1, %s)�week�IW�quarter�QZiso_yearZIYYYzInvalid loookup type: zEXTRACT(z FROM �))�upper�_extract_format_re� fullmatch� ValueError)r% � lookup_type�sql�paramsZ extract_sqlZ extract_paramr& r& r' �date_extract_sqlS s$ z#DatabaseOperations.date_extract_sqlNc C sn | � |||�\}}d }|dv r(|�� }n,|dkr6d}n |dkrDd}nd|� d�|fS d|� d�g |�|�R fS ) N��year�monthr- r. r+ r, �TRUNC(r/ r) ��_convert_sql_to_tzr0 �r% r4 r5 r6 �tznameZ trunc_paramr& r& r' �date_trunc_sqlk s z!DatabaseOperations.date_trunc_sqlz ^[\w/:+-]+$c C s" t |�\}}}|r |� |� �S |S �N)r )r% r? �sign�offsetr& r& r' �_prepare_tzname_delta s z(DatabaseOperations._prepare_tzname_deltac C sl t jr |s||fS | j�|�s*td| ��| jj|krd| jj}| �|�}d|� d|� d|� d�|fS ||fS )NzInvalid time zone name: %szCAST((FROM_TZ(z, 'z') AT TIME ZONE 'z') AS TIMESTAMP))r �USE_TZ� _tzname_re�matchr3 � connectionZ timezone_namerD )r% r5 r6 r? Zfrom_timezone_nameZto_timezone_namer& r& r' r= � s ��z%DatabaseOperations._convert_sql_to_tzc C s" | � |||�\}}d|� d�|fS )Nr; r/ �r= )r% r5 r6 r? r& r& r' �datetime_cast_date_sql� s z)DatabaseOperations.datetime_cast_date_sqlc C s> | � |||�\}}d|� d�}d|� d|� d�g |�|�R fS )Nz+TO_TIMESTAMP(CONCAT('1900-01-01 ', TO_CHAR(z0, 'HH24:MI:SS.FF')), 'YYYY-MM-DD HH24:MI:SS.FF')z CASE WHEN z IS NOT NULL THEN z ELSE NULL ENDrI )r% r5 r6 r? Zconvert_datetime_sqlr& r& r' �datetime_cast_time_sql� s � �z)DatabaseOperations.datetime_cast_time_sqlc C s | � |||�\}}| �|||�S rA )r= r7 )r% r4 r5 r6 r? r& r& r' �datetime_extract_sql� s z'DatabaseOperations.datetime_extract_sqlc C s� | � |||�\}}d }|dv r(|�� }n`|dkr6d}nR|dkrDd}nD|dkrRd}n6|dkr`d }n(|d krxd |� d �|fS d |� d�|fS d |� d�g |�|�R fS )Nr8 r- r. r+ r, �hour�HH24�minute�MI�dayr; r/ �CAST(� AS DATE)r) r< r> r& r& r' �datetime_trunc_sql� s z%DatabaseOperations.datetime_trunc_sqlc C sd | � |||�\}}d }|dkr$d}n&|dkr2d}n|dkrJd|� d�|fS d|� d �g |�|�R fS ) NrM rN rO rP �secondrR rS r; r) rI r> r& r& r' �time_trunc_sql� s z!DatabaseOperations.time_trunc_sqlc s� t � �|�}|j�� }|dv r,|�| j� n�|dkrB|�| j� nr|dkrX|�| j� n\|dkrttj r�|�| j � n@|dkr�|�| j � n*|dkr�|�| j � n|dkr�|�| j � |jjr�|�|dkr�| jn| j� |S )N)� JSONFieldr! � BinaryFieldZ BooleanFieldZ DateTimeField� DateFieldZ TimeFieldZ UUIDField)�super�get_db_convertersZ output_field�get_internal_type�append�convert_textfield_value�convert_binaryfield_value�convert_booleanfield_valuer rE �convert_datetimefield_value�convert_datefield_value�convert_timefield_value�convert_uuidfield_valueZempty_strings_allowed�convert_empty_bytes�convert_empty_string)r% � expression� converters� internal_type�� __class__r& r' r[ � s0 ��z$DatabaseOperations.get_db_convertersc C s t |tj�r|�� }|S rA )� isinstancer �LOB�read�r% �valuerg rH r& r& r' r^ � s z*DatabaseOperations.convert_textfield_valuec C s t |tj�rt|�� �}|S rA )rl r rm r rn ro r& r& r' r_ � s z,DatabaseOperations.convert_binaryfield_valuec C s |dv rt |�}|S )N)r r )�boolro r& r& r' r` � s z-DatabaseOperations.convert_booleanfield_valuec C s |d urt �|| jj �}|S rA )r Z make_awarerH ro r& r& r' ra � s z.DatabaseOperations.convert_datetimefield_valuec C s t |tj�r|�� }|S rA )rl r � Timestamp�datero r& r& r' rb s z*DatabaseOperations.convert_datefield_valuec C s t |tj�r|�� }|S rA )rl r rr �timero r& r& r' rc s z*DatabaseOperations.convert_timefield_valuec C s |d urt �|�}|S rA )�uuid�UUIDro r& r& r' rd s z*DatabaseOperations.convert_uuidfield_valuec C s | d u r dS | S �N� r& �rp rg rH r& r& r' rf s z'DatabaseOperations.convert_empty_stringc C s | d u r dS | S )N� r& ry r& r& r' re s z&DatabaseOperations.convert_empty_bytesc C s dS )Nz DEFERRABLE INITIALLY DEFERREDr& �r% r& r& r' �deferrable_sql s z!DatabaseOperations.deferrable_sqlc C s< g }|D ]*}|� � }|g kr$td��|�|d � qt|�S )Nz�The database did not return a new row id. Probably "ORA-1403: no data found" was raised internally but was hidden by the Oracle OCI library (see https://code.djangoproject.com/ticket/28859).r )� get_valuer r] �tuple)r% �cursorZreturning_params�columns�paramrp r& r& r' � fetch_returned_insert_columns s �z0DatabaseOperations.fetch_returned_insert_columnsc C s d S rA r& r{ r& r& r' �no_limit_value+ s z!DatabaseOperations.no_limit_valuec C s@ | � ||�\}}d�dd� |r&d| nd |r4d| nd fD ��S )N� c s s | ]}|r|V qd S rA r& )�.0r5 r& r& r' � <genexpr>0 s �z6DatabaseOperations.limit_offset_sql.<locals>.<genexpr>zOFFSET %d ROWSzFETCH FIRST %d ROWS ONLY)Z_get_limit_offset_params�join)r% Zlow_markZ high_mark�fetchrC r& r& r' �limit_offset_sql. s ��z#DatabaseOperations.limit_offset_sqlc C s~ |j }|rzt|ttf�r2dd� tt�|��D �}n t|t�rNdd� |�� D �}t|t dd�D ] }|� |t || dd��}q\|S )Nc S s i | ]\}}d |� �|�qS )z:argr& )r� �ir� r& r& r' � <dictcomp>B s z:DatabaseOperations.last_executed_query.<locals>.<dictcomp>c S s i | ]\}}d |� �|�qS )�:r& )r� �key�valr& r& r' r� F rz T)r� �reverse�replace)�errors) � statementrl r~ �list� enumerate�dict�fromkeys�items�sorted�lenr� r )r% r r5 r6 r� r� r& r& r' �last_executed_query9 s � �z&DatabaseOperations.last_executed_queryc C s, | � |t|�|�}|�d| � |�� d S )Nz "%s".currvalr )�_get_sequence_namer �execute�fetchone)r% r � table_name�pk_nameZsq_namer& r& r' �last_insert_idM s z!DatabaseOperations.last_insert_idc C s4 |dv r dS |dkr |dv s,|dkr0|dkr0dS dS ) N)ZiexactZ icontainsZ istartswithZ iendswithz UPPER(%s)Zisnull)rX r! �exactrW zDBMS_LOB.SUBSTR(%s)�%sr& )r% r4 ri r& r& r' � lookup_castR s ����z DatabaseOperations.lookup_castc C s dS )Ni� r& r{ r& r& r' �max_in_list_size[ s z#DatabaseOperations.max_in_list_sizec C s dS )N� r& r{ r& r& r' �max_name_length^ s z"DatabaseOperations.max_name_lengthc C s dS )NZNULLr& r{ r& r& r' �pk_default_valuea s z#DatabaseOperations.pk_default_valuec C s |S rA r& )r% �xr& r& r' �prep_for_iexact_queryd s z(DatabaseOperations.prep_for_iexact_queryc C s |d u r dS |� � S rw )rn �r% rp r& r& r' � process_clobg s z DatabaseOperations.process_clobc C s: |� d�s&|�d�s&dt|| �� � }|�dd�}|�� S )N�"z"%s"�%�%%)� startswith�endswithr r� r� r0 )r% �namer& r& r' r$ l s z DatabaseOperations.quote_namec C s |dkrd}nd}d| S )N�regexz'c'z'i'zREGEXP_LIKE(%%s, %%s, %s)r& )r% r4 Z match_optionr& r& r' � regex_lookupy s z DatabaseOperations.regex_lookupc C sx |sdS g }g }|D ]8}|� d| �|jjj�| �|j�f � |� t|�� qdd�|�d�dgt|� �f t |�fS )N)rx r& z%s.%szRETURNING %s INTO %s�, r� ) r] r$ �model�_meta�db_table�columnr r� r� r~ )r% �fields� field_namesr6 �fieldr& r& r' �return_insert_columns� s& �����z(DatabaseOperations.return_insert_columnsc C sZ | j �� �<}|r"|�d||f� n|�d|f� |�� W d � S 1 sL0 Y d S )Na� SELECT user_tables.table_name, rcons.constraint_name FROM user_tables JOIN user_constraints cons ON (user_tables.table_name = cons.table_name AND cons.constraint_type = ANY('P', 'U')) LEFT JOIN user_constraints rcons ON (user_tables.table_name = rcons.table_name AND rcons.constraint_type = 'R') START WITH user_tables.table_name = UPPER(%s) CONNECT BY NOCYCLE PRIOR cons.constraint_name = rcons.r_constraint_name GROUP BY user_tables.table_name, rcons.constraint_name HAVING user_tables.table_name != UPPER(%s) ORDER BY MAX(level) DESC a: SELECT cons.table_name, cons.constraint_name FROM user_constraints cons WHERE cons.constraint_type = 'R' AND cons.table_name = UPPER(%s) )rH r r� Zfetchall)r% r� � recursiver r& r& r' Z__foreign_key_constraints� s � � z,DatabaseOperations.__foreign_key_constraintsc C s t dd�| j�S )Ni )�maxsize)r �,_DatabaseOperations__foreign_key_constraintsr{ r& r& r' �_foreign_key_constraints� s z+DatabaseOperations._foreign_key_constraintsF)�reset_sequences� allow_cascadec s� |sg S dd� |D ��t � }|D ]8}� j||d�D ]$\}}|rH��|� |�||f� q2q � �fdd�|D �� �fdd��D � � �fdd�|D � } |rƇfdd�� jj�� D �} | �� ��| �� | S ) Nc S s h | ] }|� � �qS r& �r0 �r� �tabler& r& r' � <setcomp>� rz z/DatabaseOperations.sql_flush.<locals>.<setcomp>)r� c sd g | ]\\}}d �� d��� d���� �|���� d��� d���� �|���� d��� d�f �qS )z%s %s %s %s %s %s %s %s;�ALTER�TABLEZDISABLE� CONSTRAINTZKEEPZINDEX�Z SQL_KEYWORDZ SQL_FIELDr$ �r� r� � constraint�r% �styler& r' � <listcomp>� s ���z0DatabaseOperations.sql_flush.<locals>.<listcomp>c s2 g | ]*}d �� d��� d���� �|��f �qS )z %s %s %s;ZTRUNCATEr� r� r� r� r& r' r� � s ���c sT g | ]L\}}d �� d��� d���� �|���� d��� d���� �|��f �qS )z%s %s %s %s %s %s;r� r� ZENABLEr� r� r� r� r& r' r� � s ���c s g | ]}|d � � � v r|�qS )r� r� )r� �sequence)�truncated_tablesr& r' r� � s �)�setr� �addrH Z introspectionZ sequence_list�extend�sequence_reset_by_name_sql) r% r� Ztablesr� r� � constraintsr� Z foreign_tabler� r5 � sequencesr& )r% r� r� r' � sql_flush� s: � � �� ���% �z DatabaseOperations.sql_flushc C sh g }|D ]Z}| � |d �}| �|d �}| �|d p6d�}| j|||t|�t|�d� }|�|� q|S )Nr� r� �id��no_autofield_sequence_namer� r� r� Z column_name)� _get_no_autofield_sequence_namer$ �_sequence_reset_sqlr r] ) r% r� r� r5 Z sequence_infor� r� r� �queryr& r& r' r� s �� z-DatabaseOperations.sequence_reset_by_name_sqlc C s~ g }| j }|D ]j}|jjD ]\}t|t�r| �|jj�}| �|jj�}| �|j�} |� |||| t |�t | �d� � qqq|S )Nr� ) r� r� Z local_fieldsrl r r� r� r$ r� r] r ) r% r� Z model_list�outputr� r� �fr� r� r� r& r& r' �sequence_reset_sql s, � ��� z%DatabaseOperations.sequence_reset_sqlc C s dS rw r& r{ r& r& r' �start_transaction_sql0 s z(DatabaseOperations.start_transaction_sqlc C s$ |rd| � |� S d| � |� S d S )NzUSING INDEX TABLESPACE %sz TABLESPACE %sr# )r% Z tablespace�inliner& r& r' �tablespace_sql3 s z!DatabaseOperations.tablespace_sqlc C s |S )z� Transform a date value to an object compatible with what is expected by the backend driver for date columns. The default implementation transforms the date to text, but that is not necessary for Oracle. r& r� r& r& r' �adapt_datefield_value9 s z(DatabaseOperations.adapt_datefield_valuec C sN |du r dS t |d�r|S t�|�rDtjr<t�|| jj�}ntd��t� |�S )aE Transform a datetime value to an object compatible with what is expected by the backend driver for datetime columns. If naive datetime is passed assumes that is in UTC. Normally Django models.DateTimeField makes sure that if USE_TZ is True passed datetime is timezone aware. N�resolve_expressionzNOracle backend does not support timezone-aware datetimes when USE_TZ is False.) �hasattrr �is_awarer rE Z make_naiverH r3 r � from_datetimer� r& r& r' �adapt_datetimefield_valueB s �z,DatabaseOperations.adapt_datetimefield_valuec C s` |d u r d S t |d�r|S t|t�r2tj�|d�S t�|�rDtd��tddd|j |j |j |j �S )Nr� z%H:%M:%Sz5Oracle backend does not support timezone-aware times.il r ) r� rl �str�datetime�strptimer r� r3 r rM rO rU � microsecondr� r& r& r' �adapt_timefield_value_ s �z(DatabaseOperations.adapt_timefield_valuec C s |S rA r& )r% rp Z max_digitsZdecimal_placesr& r& r' �adapt_decimalfield_valuer s z+DatabaseOperations.adapt_decimalfield_valuec s� |\}}|dkr dd� |� S |dkr4dd� |� S |dkrJd||d� S |d kr`d ||d� S |d krvd ||d� S |d kr�dd� |� S |dkr�td��t� �||�S )Nr� zMOD(%s)�,�&z BITAND(%s)�|z"BITAND(-%(lhs)s-1,%(rhs)s)+%(lhs)s)�lhs�rhsz<<z (%(lhs)s * POWER(2, %(rhs)s))z>>z"FLOOR(%(lhs)s / POWER(2, %(rhs)s))�^z POWER(%s)�#z'Bitwise XOR is not supported in Oracle.)r� r rZ �combine_expression)r% Z connectorZsub_expressionsr� r� rj r& r' r� u s z%DatabaseOperations.combine_expressionc C s" | � � d }dtt|�|��� S )z� Manually created sequence name to keep backward compatibility for AutoFields that aren't Oracle identity columns. � z%s_SQ)r� r r r0 )r% r� Z name_lengthr& r& r' r� � s z2DatabaseOperations._get_no_autofield_sequence_namec C s2 |� d||g� |�� }|d u r*| �|�S |d S )Nz� SELECT sequence_name FROM user_tab_identity_cols WHERE table_name = UPPER(%s) AND column_name = UPPER(%s)r )r� r� r� )r% r r� r� �rowr& r& r' r� � s �z%DatabaseOperations._get_sequence_namec C s� g }|D ]z}g }t |�D ]T\}}|| rRt|| d|| ��� }tj�|d�| }|sbd||f }|�|� q|�dd�|� � qdd�|� S )NZ target_fieldr� z %s col_%szSELECT %s FROM DUALr� zSELECT * FROM (%s)z UNION ALL )r� �getattrr\ r �types�getr] r� ) r% r� Zplaceholder_rowsr� r� �selectr� � placeholderri r& r& r' �bulk_insert_sql� s �� z"DatabaseOperations.bulk_insert_sqlc sF |dkr6|\}}|\}}g |�|�R }d||f |fS t � �|||�S )NrY z*NUMTODSINTERVAL(TO_NUMBER(%s - %s), 'DAY'))rZ �subtract_temporals) r% ri r� r� Zlhs_sqlZ lhs_paramsZrhs_sqlZ rhs_paramsr6 rj r& r' r � s �z%DatabaseOperations.subtract_temporalsc C s |r| j jjt|� S t|�S )z5Oracle restricts the number of parameters in a query.)rH �featuresZmax_query_paramsr� )r% r� Zobjsr& r& r' �bulk_batch_size� s z"DatabaseOperations.bulk_batch_sizec C sH t |tttf�rdS t |t�r0|jr0| �|j�S t |t�rD|jrDdS dS )z} Oracle supports only EXISTS(...) or filters in the WHERE clause, others must be compared with True. TF) rl r r r r Z conditional�0conditional_expression_supported_in_where_clauserg r )r% rg r& r& r' r � s �zCDatabaseOperations.conditional_expression_supported_in_where_clause)N)N)N)F)NN)D�__name__� __module__� __qualname__Zinteger_field_rangesr Z set_operatorsr� Z"cast_char_field_without_max_lengthZcast_data_typesr( r r1 r7 r@ rF rD r= rJ rK rL rT rV r[ r^ r_ r` ra rb rc rd � staticmethodrf 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� r r r r � __classcell__r& r& rj r' r s� � � * A r )(r� ru � functoolsr Z django.confr Z django.dbr r Z"django.db.backends.base.operationsr Zdjango.db.backends.utilsr r r Zdjango.db.modelsr r r r Z django.db.models.expressionsr Zdjango.db.models.sql.wherer Z django.utilsr Zdjango.utils.encodingr r Zdjango.utils.functionalr Zdjango.utils.regex_helperr �baser �utilsr r r r r& r& r& r' �<module> s