B ©0H[òHã@sþdZddlZddlZddlZddlZddlmZddlZddl m Z ddl m Z ddl m ZddlmZddlmZddlmZmZmZmZd d lmZd d lmZd d lmZd d lmZd dl m!Z!d dl"m#Z#dd„Z$e %ddd„¡e %de$eƒ¡e %de$eƒ¡e %de$eƒ¡e %de$eƒ¡e %de$eƒ¡e %de$ej&ƒ¡e 'ej&ej(¡Gdd„deƒZ)e *d¡Z+Gdd„dej,ƒZ-d d!„Z.d"d#„Z/d$d%„Z0d&d'„Z1d(d)„Z2d*d+„Z3d,d-„Z4d.d/„Z5d0d1„Z6d2d3„Z7d4d5„Z8d6d7„Z9d8d9„Z:d:d;„Z;dS)!szdecoder..r)rr)rrÚdecodersrÚboolcCs|dkS)Nó1r)rrrrr$srÚtimeÚdateÚdatetimeÚ timestampÚ TIMESTAMPÚdecimalc@seZdZdZdZdddddddd d ddd dd d d ddddddddddœZdddœZdddddddddddddddœZd Zd!d"d#d$d%d&d'œZ e Z e Z e ZeZeZeZeZd(d)„Zd*d+„Zd,d-„ZdCd/d0„Zd1d2„Zd3d4„Zd5d6„Zd7d8„Zd9d:„ZdDd;d<„Z d=d>„Z!d?d@„Z"dAdB„Z#d.S)EÚDatabaseWrapperZsqliteZSQLiteÚintegerZBLOBrzvarchar(%(max_length)s)rrr ZbigintÚrealzchar(15)zchar(39)zinteger unsignedzsmallint unsignedZsmallintÚtextrzchar(32))Ú AutoFieldÚ BigAutoFieldZ BinaryFieldZ BooleanFieldZ CharFieldZ DateFieldZ DateTimeFieldZ DecimalFieldZ DurationFieldZ FileFieldZ FilePathFieldZ FloatFieldZ IntegerFieldZBigIntegerFieldZIPAddressFieldZGenericIPAddressFieldZNullBooleanFieldZ OneToOneFieldZPositiveIntegerFieldZPositiveSmallIntegerFieldZ SlugFieldZSmallIntegerFieldZ TextFieldZ TimeFieldZ UUIDFieldZ AUTOINCREMENT)r%r&z= %szLIKE %s ESCAPE '\'z REGEXP %szREGEXP '(?i)' || %sz> %sz>= %sz< %sz<= %s)ÚexactZiexactÚcontainsÚ icontainsÚregexZiregexÚgtZgteÚltZlteÚ startswithÚendswithÚ istartswithÚ iendswithz@REPLACE(REPLACE(REPLACE({}, '\', '\\'), '%%', '\%%'), '_', '\_')z"LIKE '%%' || {} || '%%' ESCAPE '\'z)LIKE '%%' || UPPER({}) || '%%' ESCAPE '\'zLIKE {} || '%%' ESCAPE '\'z!LIKE UPPER({}) || '%%' ESCAPE '\'zLIKE '%%' || {} ESCAPE '\'z!LIKE '%%' || UPPER({}) ESCAPE '\')r(r)r-r/r.r0cCs~|j}|dstdƒ‚|dtjtjBdœ}| |d¡d|krV|drVt dt¡| ddi¡|j j rz| dd i¡|S) NÚNAMEzJsettings.DATABASES is improperly configured. Please supply the NAME value.)ZdatabaseZ detect_typesÚOPTIONSZcheck_same_threadzÃThe `check_same_thread` option was provided and set to True. It will be overridden with False. Use the `DatabaseWrapper.allow_thread_sharing` property instead for controlling thread shareability.FÚuriT) Ú settings_dictrÚDatabaseZPARSE_DECLTYPESZPARSE_COLNAMESÚupdateÚwarningsÚwarnÚRuntimeWarningÚfeaturesZcan_share_in_memory_db)Úselfr4ÚkwargsrrrÚget_connection_paramsƒsz%DatabaseWrapper.get_connection_paramscCsÐtjf|Ž}| ddt¡| ddt¡| ddt¡| ddt¡| ddt¡| ddt¡| d dt ¡| d dt ¡| d dt ¡| d dt ¡| d dt ¡| ddt¡| ddt¡| d¡|S)NZdjango_date_extractéZdjango_date_truncZdjango_datetime_cast_dateZdjango_datetime_cast_timeZdjango_datetime_extractéZdjango_datetime_truncZdjango_time_extractZdjango_time_truncZdjango_time_diffZdjango_timestamp_diffÚregexpZdjango_format_dtdeltaZ django_powerzPRAGMA foreign_keys = ON)r5ÚconnectZcreate_functionÚ_sqlite_date_extractÚ_sqlite_date_truncÚ_sqlite_datetime_cast_dateÚ_sqlite_datetime_cast_timeÚ_sqlite_datetime_extractÚ_sqlite_datetime_truncÚ_sqlite_time_extractÚ_sqlite_time_truncÚ_sqlite_time_diffÚ_sqlite_timestamp_diffÚ_sqlite_regexpÚ_sqlite_format_dtdeltaÚ _sqlite_powerÚexecute)r;Z conn_paramsÚconnrrrÚget_new_connection¡s   z"DatabaseWrapper.get_new_connectioncCsdS)Nr)r;rrrÚinit_connection_state³sz%DatabaseWrapper.init_connection_stateNcCs|jjtdS)N)Úfactory)Ú connectionÚcursorÚSQLiteCursorWrapper)r;ÚnamerrrÚ create_cursor¶szDatabaseWrapper.create_cursorcCs| ¡| ¡st |¡dS)N)Zvalidate_thread_sharingÚis_in_memory_dbrÚclose)r;rrrrZ¹szDatabaseWrapper.closecCs|jjo |jS)N)r:Zuses_savepointsÚin_atomic_block)r;rrrÚ_savepoint_allowedÁs z"DatabaseWrapper._savepoint_allowedc Cs,|r d}nd}|j||j_WdQRXdS)NÚ)Zwrap_database_errorsrTZisolation_level)r;Z autocommitÚlevelrrrÚ_set_autocommitÍs zDatabaseWrapper._set_autocommitcCs|jr dS| ¡ d¡dS)NFzPRAGMA foreign_keys = OFFT)r[rUrO)r;rrrÚdisable_constraint_checkingÙsz+DatabaseWrapper.disable_constraint_checkingcCs| ¡ d¡dS)NzPRAGMA foreign_keys = ON)rUrO)r;rrrÚenable_constraint_checkingàsz*DatabaseWrapper.enable_constraint_checkingc Cs¸| ¡}|dkr|j |¡}x–|D]Ž}|j ||¡}|s:q"|j ||¡}xf|D]^\}}}| d||||||||f¡x4| ¡D](} t d|| d||| d||f¡‚q€WqNWq"WdS)a³ Check each table name in `table_names` for rows with invalid foreign key references. This method is intended to be used in conjunction with `disable_constraint_checking()` and `enable_constraint_checking()`, to determine if rows with invalid references were entered while constraint checks were off. Raise an IntegrityError on the first invalid foreign key reference encountered (if any) and provide detailed information about the invalid reference in the error message. Backends can override this method if they can more directly apply constraint checking (e.g. via "SET CONSTRAINTS ALL IMMEDIATE") Na SELECT REFERRING.`%s`, REFERRING.`%s` FROM `%s` as REFERRING LEFT JOIN `%s` as REFERRED ON (REFERRING.`%s` = REFERRED.`%s`) WHERE REFERRING.`%s` IS NOT NULL AND REFERRED.`%s` IS NULL z–The row in table '%s' with primary key '%s' has an invalid foreign key: %s.%s contains a value '%s' that does not have a corresponding value in %s.%s.rr ) rUÚ introspectionÚ table_namesZget_primary_key_columnZget_key_columnsrOZfetchallrZIntegrityError) r;rcrUZ table_nameZprimary_key_column_nameZ key_columnsZ column_nameZreferenced_table_nameZreferenced_column_nameZbad_rowrrrÚcheck_constraintsãs&    z!DatabaseWrapper.check_constraintscCsdS)NTr)r;rrrÚ is_usableszDatabaseWrapper.is_usablecCs| ¡ d¡dS)z Start a transaction explicitly in autocommit mode. Staying in autocommit mode works around a bug of sqlite3 that breaks savepoints when autocommit is disabled. ZBEGINN)rUrO)r;rrrÚ#_start_transaction_under_autocommitsz3DatabaseWrapper._start_transaction_under_autocommitcCs|j |jd¡S)Nr1)ÚcreationrYr4)r;rrrrYszDatabaseWrapper.is_in_memory_db)N)N)$Ú__name__Ú __module__Ú __qualname__ÚvendorZ display_nameZ data_typesZdata_types_suffixÚ operatorsZ pattern_escZ pattern_opsr5rZSchemaEditorClassr Z client_classr Zcreation_classrZfeatures_classrZintrospection_classrZ ops_classr=rQrRrXrZr\r_r`rardrerfrYrrrrr!/sŒ     / r!z(?|dkr dSyt |¡}Wnttfk r2dSXt||ƒS)N)r|rŽr~rr…)r†r‡rrrrH¤srHc Cs¼yšt|tƒr$tt |¡t d¡ƒ}t|ƒ}|dkr>t |¡}t|tƒr`tt |¡t d¡ƒ}t|ƒ}|dkrzt |¡}| ¡dkr||}n||}Wnt t fk r²dSXt|ƒS)z¢ LHS and RHS can be either: - An integer number of microseconds - A string representing a timedelta object - A string representing a datetime i@BNú+) Ú isinstanceÚintÚstrr ÚDecimalr r|r}Ústripr~r)rPÚlhsÚrhsZreal_lhsZreal_rhsÚoutrrrrM®s"       rMcCstt |¡}t |¡}|jddd|jdd|jd|j|jddd|jdd|jd|jS)Né<i@B)r|rŽr‹rŒrÚ microsecond)ršr›ÚleftÚrightrrrrJËs  XrJcCs$t |¡}t |¡}|| ¡dS)Ni@B)r|r}Ú total_seconds)ršr›rŸr rrrrKÚs  rKcCs |dk rtt |t|ƒ¡ƒSdS)NF)rÚreÚsearchr—)Z re_patternZ re_stringrrrrLàsrLcCs||S)Nr)ÚxÚyrrrrNäsrN)sZ            t