v^iY@sdZddlZddlZddlZddlZddlmZddlmZddl m Z ddl m Z ddl mZddlmZdd lmZmZdd lmZd d Zed'd(gyddlZWn5ek rZze deWYddZ[XnXddlmZddlmZddlm Z ddl!m"Z"ddl#m$Z$ddl%m&Z&ddl m'Z'ddl(m)Z)eddZ*GdddZ+Gdd d eZ,Gd!d"d"Z-Gd#d$d$Z.Gd%d&d&Z/dS))ze Oracle database backend for Django. Requires cx_Oracle: https://oracle.github.io/python-cx_Oracle/ N)contextmanager)settings)ImproperlyConfigured)utils)BaseDatabaseWrapper) async_unsafe) force_bytes force_str)cached_propertycCstjjjdryddl}Wn5tk rb}ztd|WYdd}~XnX|jd}x7|D]\}}|j||qyWnt j j |dS)NZCYGWINrz_Error loading ctypes: %s; the Oracle backend requires ctypes to operate correctly under Cygwin.kernel32) platformsystemupper startswithctypes ImportErrorrCDLLZSetEnvironmentVariableAosenvironupdate)rrer namevaluer@/tmp/pip-build-8lau8j11/django/django/db/backends/oracle/base.py_setup_environmentsrNLS_LANG .AL32UTF8ORA_NCHAR_LITERAL_REPLACETRUEz"Error loading cx_Oracle module: %s)DatabaseClient)DatabaseCreation)DatabaseFeatures)DatabaseIntrospection)DatabaseOperations)DatabaseSchemaEditor)Oracle_datetime)DatabaseValidationccsy dVWntjk r}zi|jd}t|drt|dr|jdkrd|jkrtjt|jWYdd}~XnXdS)Nrcodemessagei+z ORA-02291) Database DatabaseErrorargshasattrr)r*rZIntegrityErrortuple)rxrrrwrap_oracle_errors?s  <r1c@seZdZdddZdS)!_UninitializedOperatorsDescriptorNcCs3|dkrtd|jj|jdS)Nz*operators not available as class attribute operators)AttributeErrorcursorclose__dict__)selfinstanceclsrrr__get__Ss  z)_UninitializedOperatorsDescriptor.__get__)__name__ __module__ __qualname__r;rrrrr2Qs r2c6seZdZdZdZddddddd d d d d ddddddddd dd dddddddddd d!d d"dd#dd$dd%d d&d'd(dd)d*d+dd,d-d.d/iZd d0d!d0d#d1d$d1iZdpZeZ d5d6d7d8d9d:d;d<d=d>d?d@dAdBdCdDdEd:dFd:dGd<dHd<i Z e d9dId;dJdEdIdFdIdGdJdHdJiZ dKZ d9dLd;dMdEdNdGdOdFdPdHdQiZ dRdSe jDZdTdSe jDZeZeZeZeZeZeZeZeZfdUdVZ dWdXZ!dYdZZ"d[d\Z#e$d]d^Z%d_d`Z&e$dadbdcZ'dddeZ(dfdgZ)dhdiZ*dadjdkZ+dldmZ,e-dndoZ.S)qDatabaseWrapperZoracleZOracleZ AutoFieldz3NUMBER(11) GENERATED BY DEFAULT ON NULL AS IDENTITYZ BigAutoFieldz3NUMBER(19) GENERATED BY DEFAULT ON NULL AS IDENTITYZ BinaryFieldZBLOBZ BooleanFieldz NUMBER(1)Z CharFieldzNVARCHAR2(%(max_length)s)Z DateFieldZDATEZ DateTimeField TIMESTAMPZ DecimalFieldz*NUMBER(%(max_digits)s, %(decimal_places)s)Z DurationFieldzINTERVAL DAY(9) TO SECOND(6)Z FileFieldZ FilePathFieldZ FloatFieldzDOUBLE PRECISIONZ IntegerFieldz NUMBER(11)ZBigIntegerFieldz NUMBER(19)ZIPAddressFieldz VARCHAR2(15)ZGenericIPAddressFieldz VARCHAR2(39)ZNullBooleanFieldZ OneToOneFieldZPositiveIntegerFieldZPositiveSmallIntegerFieldZ SlugFieldZSmallAutoFieldz2NUMBER(5) GENERATED BY DEFAULT ON NULL AS IDENTITYZSmallIntegerFieldZ TextFieldZNCLOBZ TimeFieldZURLFieldzVARCHAR2(%(max_length)s)Z UUIDFieldz VARCHAR2(32)z%(qn_column)s IN (0,1)z%(qn_column)s >= 0clobnclobblobexactz= %sZiexactz = UPPER(%s)containszFLIKE TRANSLATE(%s USING NCHAR_CS) ESCAPE TRANSLATE('\' USING NCHAR_CS)Z icontainszMLIKE UPPER(TRANSLATE(%s USING NCHAR_CS)) ESCAPE TRANSLATE('\' USING NCHAR_CS)gtz> %sgtez>= %sltz< %sltez<= %srendswithZ istartswithZ iendswithzLIKEC %s ESCAPE '\'zLIKEC UPPER(%s) ESCAPE '\'z@REPLACE(REPLACE(REPLACE({}, '\', '\\'), '%%', '\%%'), '_', '\_')z'%%' || {} || '%%'z'%%' || UPPER({}) || '%%'z {} || '%%'zUPPER({}) || '%%'z '%%' || {}z'%%' || UPPER({})cCs'i|]\}}d|d|qS)zLIKE TRANSLATE( z5 USING NCHAR_CS) ESCAPE TRANSLATE('\' USING NCHAR_CS)r).0kvrrr s zDatabaseWrapper.cCs'i|]\}}d|d|qS)zLIKEC z ESCAPE '\'r)rKrLrMrrrrNs cs<tj|||jdjdd}||j_dS)NOPTIONSuse_returning_intoT)super__init__ settings_dictgetfeaturesZcan_return_columns_from_insert)r8r-kwargsrP) __class__rrrRszDatabaseWrapper.__init__cCsZ|j}|djs#d|d<|drRtj|dt|d|dS|dS)NZHOST localhostZPORTNAME)rSstripr+Zmakedsnint)r8rSrrr_dsns    %zDatabaseWrapper._dsncCs%d|jd|jd|jfS)Nz %s/"%s"@%sUSERPASSWORD)rSr\)r8rrr_connect_stringszDatabaseWrapper._connect_stringcCs*|jdj}d|kr&|d=|S)NrOrP)rScopy)r8 conn_paramsrrrget_connection_paramss z%DatabaseWrapper.get_connection_paramscCs3tjd|jdd|jdd|j|S)Nuserr]passwordr^Zdsn)r+connectrSr\)r8rarrrget_new_connections     z"DatabaseWrapper.get_new_connectionc Cs|j}|jd|jdtjr1dnd|jd|jkr|j}y"|jd|jddgWn-tjk r|j |_ |j |_ YnX|j|_ |j |_ |jd |j_|js|jdS) Nz+ALTER SESSION SET NLS_TERRITORY = 'AMERICA'zmALTER SESSION SET NLS_DATE_FORMAT = 'YYYY-MM-DD HH24:MI:SS' NLS_TIMESTAMP_FORMAT = 'YYYY-MM-DD HH24:MI:SS.FF'z TIME_ZONE = 'UTC'r3z!SELECT 1 FROM DUAL WHERE DUMMY %srEX) create_cursorexecuterUSE_TZr6r7_standard_operatorsr+r,_likec_operatorsr3_likec_pattern_opsZ pattern_ops_standard_pattern_ops connectionZ stmtcachesizeZget_autocommitcommit)r8r5rrrinit_connection_states*            z%DatabaseWrapper.init_connection_stateNcCs t|jS)N)FormatStylePlaceholderCursorrq)r8rrrrrjszDatabaseWrapper.create_cursorc Cs1|jdk r-t|jjSWdQRXdS)N)rqr1rr)r8rrr_commits zDatabaseWrapper._commitcCs9|jr5|jjdd|jj|ddidS)NZsqlz-- RELEASE SAVEPOINT %s (faked)timez0.000)Zqueries_loggedZ queries_logappendopsZ quote_name)r8Zsidrrr_savepoint_commits  z!DatabaseWrapper._savepoint_commitc Cs!|j||j_WdQRXdS)N)Zwrap_database_errorsrq autocommit)r8rzrrr_set_autocommit%s zDatabaseWrapper._set_autocommitcCs*|jjd|jjddS)zl Check constraints by setting them to immediate. Return them to deferred afterward. zSET CONSTRAINTS ALL IMMEDIATEzSET CONSTRAINTS ALL DEFERREDN)r5rk)r8Z table_namesrrrcheck_constraints)sz!DatabaseWrapper.check_constraintsc Cs5y|jjWntjk r,dSYnXdSdS)NFT)rqZpingr+Error)r8rrr is_usable1s  zDatabaseWrapper.is_usablec Cs>|j+tdd|jjjdDSWdQRXdS)Ncss|]}t|VqdS)N)r[)rKr0rrr <sz1DatabaseWrapper.oracle_version...)Ztemporary_connectionr/rqversionsplit)r8rrroracle_version9s zDatabaseWrapper.oracle_version)rArBrC)/r<r=r>vendorZ display_nameZ data_typesZdata_type_check_constraintsZ_limited_data_typesr2r3rmrnZ pattern_escZ _pattern_opsitemsrpror+r&ZSchemaEditorClassr!Z client_classr"Zcreation_classr#Zfeatures_classr$Zintrospection_classr%Z ops_classr(Zvalidation_classrRr\r_rbrrfrsrjruryr{r|r~r rrr)rWrr?^s              (    r?c@s%eZdZdZdddZdS) OracleParama Wrapper object for formatting parameters for Oracle. If the string representation of the value is large enough (greater than 4000 characters) the input size needs to be set as CLOB. Alternatively, if the parameter has an `input_size` attribute, then the value of the `input_size` attribute will be used instead. Otherwise, no input size will be set for the parameter when executing the query. FcCs^tjr:t|tjr:t|t r:tj|}d}|dkrUd}n|dkrgd}t|dr|j||_nlt|t j tj fr||_nEt ||j ||_t|jtrtt||j |}t|dr|j|_nE|dkr0t j|_n*t|tjrQt j|_n d|_dS)NrTr Fbind_parameter input_sizei)rrl isinstancedatetimer'Z from_datetimer.rrr+Binary timedeltar charsetstrlenrZCLOBr@)r8paramr5Z strings_onlyZ string_sizerrrrRIs,     zOracleParam.__init__N)r<r=r>__doc__rRrrrrr?s rc@sFeZdZdZddZddZddZdd Zd S) VariableWrappera  An adapter class for cursor variables that prevents the wrapped object from being converted into a string when used to instantiate an OracleParam. This can be used generally for any other object that should be passed into Cursor.execute as-is. cCs ||_dS)N)var)r8rrrrrRuszVariableWrapper.__init__cCs|jS)N)r)r8r5rrrrxszVariableWrapper.bind_parametercCst|j|S)N)getattrr)r8keyrrr __getattr__{szVariableWrapper.__getattr__cCs3|dkr||j|rrRrrrrrrrrms    rc@seZdZdZdZddZeddZeddZed d Z d d Z d dZ ddZ dddZ dddZdddZddZddZddZdd Zd!d"ZdS)#rtz Django uses "format" (e.g. '%s') style placeholders, but Oracle uses ":var" style. This fixes it -- but note that if you want to use a literal "%s" in a query, you'll need to use "%%s". zutf-8cCs"|j|_|j|j_dS)N)r5_output_type_handlerZoutputtypehandler)r8rqrrrrRsz%FormatStylePlaceholderCursor.__init__cCs#d|krtj|St|S)Nr)decimalDecimalr[)rrrr_output_number_convertersz5FormatStylePlaceholderCursor._output_number_convertercsN|dkrtStjd|tjdj| fddS)NrZprecr cstj|jdS)Ncontext)rrZquantize)rM)rquantize_valuerrszEFormatStylePlaceholderCursor._get_decimal_converter..)r[rZContextrZscaleb) precisionscaler)rrr_get_decimal_converters  z3FormatStylePlaceholderCursor._get_decimal_convertercCs|tjkr|dkr<|dkr3tj}qft}n*|dkr]tj||}n tj}|jtjddd|jd|SdS) zx Called for each db column fetched from cursors. Return numbers as the appropriate Python type. rsize arraysize outconverterNi) r+NUMBERrtrfloatrrSTRINGr)r5rZ defaultTypelengthrrrrrrrs        z1FormatStylePlaceholderCursor._output_type_handlerc sWy!fdd|jDSWn/tk rRtfdd|DSYnXdS)Ncs+i|]!\}}t|d|qS)T)r)rKrLrM)r8rrrNs z?FormatStylePlaceholderCursor._format_params..c3s!|]}t|dVqdS)TN)r)rKp)r8rrrsz>FormatStylePlaceholderCursor._format_params..)rr4r/)r8paramsr)r8r_format_paramss! z+FormatStylePlaceholderCursor._format_paramscCst|ddrsi}xA|D]9}x0|jD]"\}}|jr3|j||.cSsg|]}|jqSr)r)rKrrrr s zAFormatStylePlaceholderCursor._param_generator..)r.r)r8rrrr_param_generatorsz-FormatStylePlaceholderCursor._param_generatorFcs'|jds|jdr.|dd }|dkrCg}nt|drrdd|D}||}n|r|rddttj|Dfdd |D}d djD}|t|}n/d d tt|D}|t|}||j |fS) N;/r rcSsi|]}d||qS)z:%sr)rKrLrrrrNs z@FormatStylePlaceholderCursor._fix_for_params..cSs#i|]\}}d||qS)z:arg%dr)rKrrrrrrNs csg|]}|qSrr)rKr) params_dictrrrs z@FormatStylePlaceholderCursor._fix_for_params..cSsi|]\}}||qSrr)rKrrrrrrNs cSsg|]}d|qS)z:arg%dr)rKrrrrrs ) rJr.rdictfromkeysrr/rangerr)r8queryrunify_by_valuesr-r)rr_fix_for_paramss      z,FormatStylePlaceholderCursor._fix_for_paramsNc Cs_|j||dd\}}|j|gt!|jj||j|SWdQRXdS)NrT)rrr1r5rkr)r8rrrrrrks z$FormatStylePlaceholderCursor.executec s|s dSt|}j|t|\}}|gfdd|D}j|t+jj|fdd|DSWdQRXdS)Ncsg|]}j|qSr)r)rKr)r8rrrs z.csg|]}j|qSr)r)rKr)r8rrrs )iterrnextrr1r5 executemany)r8rrZ params_iterZ firstparams formattedr)r8rrs    z(FormatStylePlaceholderCursor.executemanyc Cs-y|jjWntjk r(YnXdS)N)r5r6r+ZInterfaceError)r8rrrr6sz"FormatStylePlaceholderCursor.closecGst|jj|S)N)rr5r)r8r-rrrrsz FormatStylePlaceholderCursor.varcGst|jj|S)N)rr5arrayvar)r8r-rrrrsz%FormatStylePlaceholderCursor.arrayvarcCst|j|S)N)rr5)r8attrrrrr"sz(FormatStylePlaceholderCursor.__getattr__cCs t|jS)N)rr5)r8rrr__iter__%sz%FormatStylePlaceholderCursor.__iter__)r<r=r>rrrR staticmethodrrrrrrrrkrr6rrrrrrrrrts"  !   "    rt)rr)rzTRUE)0rrrrr contextlibrZ django.confrZdjango.core.exceptionsrZ django.dbrZdjango.db.backends.base.baserZdjango.utils.asynciorZdjango.utils.encodingrr Zdjango.utils.functionalr rZ cx_Oracler+rrclientr!Zcreationr"rUr#Z introspectionr$ operationsr%Zschemar&r'Z validationr(r1r2r?rrrtrrrrsD      # .