|
Server : Apache System : Linux iad1-shared-b8-43 6.6.49-grsec-jammy+ #10 SMP Thu Sep 12 23:23:08 UTC 2024 x86_64 User : dh_edsupp ( 6597262) PHP Version : 8.2.26 Disable Function : NONE Directory : /lib/python3/dist-packages/django/db/backends/oracle/__pycache__/ |
Upload File : |
o
3�a�l � @ s� d dl Z d dlZd dlmZ d dlmZ d dlmZmZ d dl m
Z
d dl m Z m
Z
d dlmZmZmZ d dlmZ d d lmZ d d
lmZ d d lmZmZ d d lm 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)� strip_quotes�
truncate_name)� AutoField�Exists�ExpressionWrapper)�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 dd� Z
ddd�Z e d�Z
dd� Zdd� Zdd � Zd d � Zd d � Zd!d"� Zdd#d$�Z� fd%d&�Zd'd(� Zd)d*� Zd+d,� Zd-d.� Zd/d0� Zd1d2� Zd3d4� Z e d5d6� �Z e d7d8� �Z d9d:� Z d;d<� Z!d=d>� Z"d?d@� Z#dAdB� Z$dCdD� Z%dEdF� Z&ddGdH�Z'dIdJ� Z(dKdL� Z)dMdN� Z*dOdP� Z+dQdR� Z,dSdT� Z-dUdV� Z.dWdX� Z/dYdZ� Z0e1d[d\� �Z2d]d]d^�d_d`�Z3dadb� Z4dcdd� Z5dedf� Z6d�dgdh�Z7didj� Z8dkdl� Z9dmdn� Z:d�dodp�Z;� fdqdr�Z<dsdt� Z=dudv� Z>dwdx� Z?� fdydz�Z@d{d|� ZAd}d~� ZB� ZCS )��DatabaseOperations)l�����g�] � �g�] )l������ 9V � �� 9V )r r )r r )iay��i�� ) �SmallIntegerField� IntegerField�BigIntegerField�PositiveBigIntegerField�PositiveSmallIntegerField�PositiveIntegerField�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 � dS )NzSSELECT cache_key FROM %s ORDER BY cache_key OFFSET %%s ROWS FETCH FIRST 1 ROWS ONLY� ��selfr' r' �F/usr/lib/python3/dist-packages/django/db/backends/oracle/operations.py�cache_key_culling_sqlH � z(DatabaseOperations.cache_key_culling_sqlc C s` |dkrd| S |dkrd| S |dkrd| S |dkr d| S |d kr(d
| S d |� � |f S ) N�week_dayzTO_CHAR(%s, 'D')� iso_week_dayzTO_CHAR(%s - 1, 'D')�weekzTO_CHAR(%s, 'IW')�quarterzTO_CHAR(%s, 'Q')�iso_yearzTO_CHAR(%s, 'IYYY')zEXTRACT(%s FROM %s)��upper)r) � lookup_type�
field_namer' r' r* �date_extract_sqlK s z#DatabaseOperations.date_extract_sqlNc C sL | � ||�}|dv rd||�� f S |dkrd| S |dkr"d| S d| S )N��year�month�TRUNC(%s, '%s')r0 �TRUNC(%s, 'Q')r/ �TRUNC(%s, 'IW')� TRUNC(%s)��_convert_field_to_tzr3 �r) r4 r5 �tznamer' r' r* �date_trunc_sql\ s z!DatabaseOperations.date_trunc_sqlz ^[\w/:+-]+$c C s8 d|v r
||� d�d � S d|v r||� d�d � S |S )N�+�-)�find)r) rA r' r' r* �_prepare_tzname_deltan s
z(DatabaseOperations._prepare_tzname_deltac C sN t jr|s|S | j�|�std| ��| jj|kr%d|| jj| �|�f S |S )NzInvalid time zone name: %sz8CAST((FROM_TZ(%s, '%s') AT TIME ZONE '%s') AS TIMESTAMP))r �USE_TZ�
_tzname_re�match�
ValueError�
connection�
timezone_namerF �r) r5 rA r' r' r* r? u s
�z'DatabaseOperations._convert_field_to_tzc C s | � ||�}d| S )Nr= �r? rM r' r' r* �datetime_cast_date_sql� s z)DatabaseOperations.datetime_cast_date_sqlc C s | � ||�S �NrN rM r' r' r* �datetime_cast_time_sql� s z)DatabaseOperations.datetime_cast_time_sqlc C s | � ||�}| �||�S rP )r? r6 r@ r' r' r* �datetime_extract_sql� s z'DatabaseOperations.datetime_extract_sqlc C s� | � ||�}|dv rd||�� f }|S |dkr d| }|S |dkr(d| }|S |dkr2d| }|S |d kr<d
| }|S |d krFd | }|S d
| }|S )Nr7 r: r0 r; r/ r< �dayr= �hour�TRUNC(%s, 'HH24')�minute�TRUNC(%s, 'MI')�CAST(%s AS DATE)r> �r) r4 r5 rA �sqlr' r' r* �datetime_trunc_sql� s*
� � ����z%DatabaseOperations.datetime_trunc_sqlc C sH | � ||�}|dkrd| }|S |dkrd| }|S |dkr"d| }|S )NrT rU rV rW �secondrX rN rY r' r' r* �time_trunc_sql� s ��z!DatabaseOperations.time_trunc_sqlc s� t � �|�}|j�� }|dv r|�| j� nD|dkr!|�| j� n9|dv r,|�| j� n.|dkr:tj r9|�| j
� n |dkrE|�| j � n|dkrP|�| j � n
|dkrZ|�| j
� |jjrk|�|dkrg| jn| j� |S )N)� JSONFieldr% � BinaryField)� BooleanField�NullBooleanField�
DateTimeField� DateField� TimeField� UUIDField)�super�get_db_converters� output_field�get_internal_type�append�convert_textfield_value�convert_binaryfield_value�convert_booleanfield_valuer rG �convert_datetimefield_value�convert_datefield_value�convert_timefield_value�convert_uuidfield_value�field�empty_strings_allowed�convert_empty_bytes�convert_empty_string)r) �
expression�
converters�
internal_type�� __class__r' r* rg � s2
� ��z$DatabaseOperations.get_db_convertersc C � t |tj�r
|�� }|S rP )�
isinstancer �LOB�read�r) �valuerv rK r' r' r* rk � � z*DatabaseOperations.convert_textfield_valuec C s t |tj�r t|�� �}|S rP )r| r r} r r~ r r' r' r* rl � s z,DatabaseOperations.convert_binaryfield_valuec C s |dv rt |�}|S )N)r r )�boolr r' r' r* rm � s z-DatabaseOperations.convert_booleanfield_valuec C s |d ur t �|| jj �}|S rP )r �
make_awarerK r r' r' r* rn � s z.DatabaseOperations.convert_datetimefield_valuec C r{ rP )r| r � Timestamp�dater r' r' r* ro � r� z*DatabaseOperations.convert_datefield_valuec C r{ rP )r| r r� �timer r' r' r* rp � r� z*DatabaseOperations.convert_timefield_valuec C s |d ur t �|�}|S rP )�uuid�UUIDr r' r' r* rq � s
z*DatabaseOperations.convert_uuidfield_valuec C � | d u rdS | S �N� r' �r� rv rK r' r' r* ru � � z'DatabaseOperations.convert_empty_stringc C r� )N� r' r� r' r' r* rt � r� z&DatabaseOperations.convert_empty_bytesc C r& )Nz DEFERRABLE INITIALLY DEFERREDr' r( r' r' r* �deferrable_sql� r, z!DatabaseOperations.deferrable_sqlc C sR g }|D ] }|� � }|d u s|g krtd��|�t|t�r!|d n|� 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 rj r| �list�tuple)r) �cursor�returning_params�columns�paramr� r' r' r* � fetch_returned_insert_columns s � z0DatabaseOperations.fetch_returned_insert_columnsc C s |r
|� d�r
|dkr
dS dS )Nr} r^ �DBMS_LOB.SUBSTR(%s)�%s)�endswith)r) �db_typerx r' r' r* �field_cast_sql s z!DatabaseOperations.field_cast_sqlc C s d S rP r' r( r' r' r* �no_limit_value r, z!DatabaseOperations.no_limit_valuec C s@ | � ||�\}}d�dd� |rd| nd |rd| nd fD ��S )N� c s s � | ]}|r|V qd S rP r' )�.0rZ r' r' r* � <genexpr> s � �z6DatabaseOperations.limit_offset_sql.<locals>.<genexpr>zOFFSET %d ROWSzFETCH FIRST %d ROWS ONLY)�_get_limit_offset_params�join)r) �low_mark� high_mark�fetch�offsetr' r' r* �limit_offset_sql s
�z#DatabaseOperations.limit_offset_sqlc C sz |j }t|ttf�r!t|�D ]\}}|�d| t|dd��}q|S t|t�r;|�� D ]\}}|�d| t|dd��}q*|S )Nz:arg%d�replace)�errorsz:%s) � statementr| r� r� � enumerater� r �dict�items)r) r� rZ �paramsr� �ir� �keyr' r' r* �last_executed_query! 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_name�sq_namer' r' r* �last_insert_id0 s z!DatabaseOperations.last_insert_idc C s$ |dv rdS |dkr|dkrdS dS )N)�iexact� icontains� istartswith� iendswithz UPPER(%s)r^ �exactr� r� r' )r) r4 rx r' r' r* � lookup_cast5 s
z DatabaseOperations.lookup_castc C r& )Ni� r' r( r' r' r* �max_in_list_size< r, z#DatabaseOperations.max_in_list_sizec C r& )N� r' r( r' r' r* �max_name_length? r, z"DatabaseOperations.max_name_lengthc C r& )N�NULLr' r( r' r' r* �pk_default_valueB r, z#DatabaseOperations.pk_default_valuec C � |S rP r' )r) �xr' r' r* �prep_for_iexact_queryE r, z(DatabaseOperations.prep_for_iexact_queryc C s |d u rdS |� � S r� )r~ �r) r� r' r' r* � process_clobH s z DatabaseOperations.process_clobc C s> |� d�s|�d�sdt|�� | �� � }|�dd�}|�� S )N�"z"%s"�%�%%)�
startswithr� r r3 r� r� )r) �namer' r' r* �
quote_nameM s z DatabaseOperations.quote_namec C s |dkr
d}d| S d}d| S )N�regexz'c'z'i'zREGEXP_LIKE(%%s, %%s, %s)r' )r) r4 � match_optionr' r' r* � regex_lookupZ s
�z DatabaseOperations.regex_lookupc C sx |sdS g }g }|D ] }|� d| �|jjj�| �|j�f � |� t|�� q
dd�|�d�dgt|� �f t |�fS )N)r� r' z%s.%szRETURNING %s INTO %s�, r� )
rj r� �model�_meta�db_table�columnr r� �lenr� )r) �fields� field_namesr� rr r' r' r* �return_insert_columnsa s
���z(DatabaseOperations.return_insert_columnsc C sZ | j �� � }|r|�d||f� n|�d|f� |�� W d � S 1 s&w 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
a6
SELECT
cons.table_name, cons.constraint_name
FROM
user_constraints cons
WHERE
cons.constraint_type = 'R'
AND cons.table_name = UPPER(%s)
)rK r� r� �fetchall)r) r� � recursiver� r' r' r* �__foreign_key_constraintsq 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 ] }� j||d�D ]\}}|r$��|� |�||f� qq� �fdd�|D �� �fdd��D � � �fdd�|D � } |rc�fdd�� jj�� D �}
| �� ��|
�� | S ) Nc S s h | ]}|� � �qS r' r2 �r� �tabler' r' r* � <setcomp>� s 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�TABLE�DISABLE�
CONSTRAINT�KEEP�INDEX�� SQL_KEYWORD� 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;�TRUNCATEr� r� r� r� r' r* r� � s ���c
sT g | ]&\}}d �� d��� d���� �|���� d��� d���� �|��f �qS )z%s %s %s %s %s %s;r� r� �ENABLEr� r� r� r� r' r* r� � s ���c s g | ] }|d � � � v r|�qS )r� r2 )r� �sequence)�truncated_tablesr' r* r� � s
�)�setr� �addrK �
introspection�
sequence_list�extend�sequence_reset_by_name_sql) r) r� �tablesr� r� � constraintsr� �
foreign_tabler� rZ � sequencesr' )r) r� r� r* � sql_flush� s6
�
� �� ��
�z DatabaseOperations.sql_flushc C sh g }|D ]-}| � |d �}| �|d �}| �|d pd�}| j|||t|�t|�d� }|�|� q|S )Nr� r� �id��no_autofield_sequence_namer� r� r� � column_name)� _get_no_autofield_sequence_namer� �_sequence_reset_sqlr rj ) r) r� r rZ �
sequence_infor r� r� �queryr' r' r* r� � s � z-DatabaseOperations.sequence_reset_by_name_sqlc
C s~ g }| j }|D ]5}|jjD ].}t|t�r;| �|jj�}| �|jj�}| �|j�} |� |||| t
|�t
| �d� � nq
q|S )Nr ) r r� � local_fieldsr| r r r� r� r� rj r )
r) r� �
model_list�outputr
r� �fr r� r� r' r' r* �sequence_reset_sql� s&
� ��z%DatabaseOperations.sequence_reset_sqlc C r& r� r' r( r' r' r* �start_transaction_sql� r, z(DatabaseOperations.start_transaction_sqlc C s |r d| � |� S d| � |� S )NzUSING INDEX TABLESPACE %sz
TABLESPACE %s)r� )r) �
tablespace�inliner' r' r* �tablespace_sql� s z!DatabaseOperations.tablespace_sqlc C r� )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_value� s z(DatabaseOperations.adapt_datefield_valuec C sN |du rdS t |d�r
|S t�|�r"tjr 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 rG �
make_naiverK rJ r �
from_datetimer� r' r' r* �adapt_datetimefield_value s
z,DatabaseOperations.adapt_datetimefield_valuec C s` |d u rd S t |d�r
|S t|t�rtj�|d�S t�|�r"td��tddd|j |j
|j |j �S )Nr z%H:%M:%Sz5Oracle backend does not support timezone-aware times.il r )
r r| �str�datetime�strptimer r rJ r rT rV r\ � microsecondr� r' r' r* �adapt_timefield_value s
�z(DatabaseOperations.adapt_timefield_valuec C r� rP r' )r) r� �
max_digits�decimal_placesr' r' r* �adapt_decimalfield_value0 r, z+DatabaseOperations.adapt_decimalfield_valuec s� |\}}|dkrdd� |� S |dkrdd� |� S |dkr%d||d� S |d kr0d
||d� S |d kr;d ||d� S |d
krFdd� |� S |dkrNtd��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 rf �combine_expression)r) � connector�sub_expressionsr& r' ry r' r* r* 3 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 r3 )r) r� � name_lengthr' r' r* r E 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� M s
�z%DatabaseOperations._get_sequence_namec C s� g }|D ]=}g }t |�D ]*\}}|| r)t|| d|| ��� }tj�|d�| }|s1d||f }|�|� q |�dd�|� � qdd�|� S )N� target_fieldr� z %s col_%szSELECT %s FROM DUALr� zSELECT * FROM (%s)z UNION ALL )r� �getattrri r �types�getrj r� ) r) r� �placeholder_rowsr
r/ �selectr� � placeholderrx r' r' r* �bulk_insert_sqlV s z"DatabaseOperations.bulk_insert_sqlc sF |dkr|\}}|\}}g |�|�R }d||f |fS t � �|||�S )Nrc z*NUMTODSINTERVAL(TO_NUMBER(%s - %s), 'DAY'))rf �subtract_temporals) r) rx r& r' �lhs_sql�
lhs_params�rhs_sql�
rhs_paramsr� ry r' r* r8 k s z%DatabaseOperations.subtract_temporalsc C s |r | j jjt|� S t|�S )z5Oracle restricts the number of parameters in a query.)rK �features�max_query_paramsr� )r) r� �objsr' r' r* �bulk_batch_sizes s z"DatabaseOperations.bulk_batch_sizec C sF t |ttf�r dS t |t�r|jr| �|j�S t |t�r!|jr!dS dS )z}
Oracle supports only EXISTS(...) or filters in the WHERE clause, others
must be compared with True.
TF)r| r
r
r � conditional�0conditional_expression_supported_in_where_clauserv r )r) rv r' r' r* rB y s zCDatabaseOperations.conditional_expression_supported_in_where_clauserP )F)NN)D�__name__�
__module__� __qualname__�integer_field_rangesr �
set_operatorsr �"cast_char_field_without_max_length�cast_data_typesr+ r6 rB r rH rF r? rO rQ rR r[ r] rg rk rl rm rn ro rp rq � staticmethodru rt 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� r7 r8 r@ rB �
__classcell__r' r' ry r* r s� � �
!
5
r )&r r� � functoolsr � django.confr � django.dbr r �"django.db.backends.base.operationsr �django.db.backends.utilsr r �django.db.modelsr r
r � django.db.models.expressionsr �django.db.models.sql.wherer
� django.utilsr �django.utils.encodingr r �django.utils.functionalr �django.utils.regex_helperr �baser �utilsr r r r r' r' r' r* �<module> s"