TQc@sddZddlmZddlZddlZddlZddlZddlZddlm Z ddl Tddl m Z ddl mZddlmZdd lmZdd lmZmZmZdd lmZdd lmZdd lmZddlmZy<yddlmZ Wn!e!k rBddl"mZ nXWn3e!k ryZ#ddl$m%Z%e%de#nXe j&Z&e j'Z'dZ(dZ)dZ*e j+e,de*de j+e,de*ee j+e,de*ee j+e,de*e(e j+e,de*e(e j+e,de*e(e j+e,de*e-j.e j/eje)e j/ej0e-j1e j2d/kre j/e,d e j/ed!nd"e3fd#YZ4d$e5fd%YZ6d&e7fd'YZ8ej9d(Z:d)e j;fd*YZ<d+Z=d,Z>d-Z?d.Z@dS(0ut SQLite3 backend for django. Works with either the pysqlite2 module or the sqlite3 module in the standard library. i(tunicode_literalsN(tutils(t*(tconnection_created(tDatabaseClient(tDatabaseCreation(tDatabaseIntrospection(t parse_datetparse_datetimet parse_time(tcached_property(t SafeBytes(tsix(ttimezone(tdbapi2(tImproperlyConfigureduKError loading either pysqlite2 or sqlite3 modules (tried in that order): %scCsLt|}|dk rHtjrHtj|rH|jdtj}n|S(Nttzinfo(RtNonetsettingstUSE_TZR tis_naivetreplacetutc(tvaluetdt((s8../Django//lib/python/django/db/backends/sqlite3/base.pyt$parse_datetime_with_timezone_support(s $cCstjrntj|rMtjd|ttj}tj||}n|j tj j dd}n|j tdS(NuHSQLite received a naive datetime (%s) while time zone support is active.Ru (RRR RtwarningstwarntRuntimeWarningtget_default_timezonet make_awaret astimezoneRRRt isoformattstr(Rtdefault_timezone((s8../Django//lib/python/django/db/backends/sqlite3/base.pyt$adapt_datetime_with_timezone_support/s   !cs fdS(u The Python sqlite3 interface returns always byte strings. This function converts the received value to a regular string before passing it to the receiver function. cs|jdS(Nuutf-8(tdecode(ts(t conv_func(s8../Django//lib/python/django/db/backends/sqlite3/base.pyt@s((R&((R&s8../Django//lib/python/django/db/backends/sqlite3/base.pytdecoder;suboolcCs |dkS(Nu1((R%((s8../Django//lib/python/django/db/backends/sqlite3/base.pyR'Bsutimeudateudatetimeu timestampu TIMESTAMPudecimaliiicCs |jdS(Nuutf-8(R$(R%((s8../Django//lib/python/django/db/backends/sqlite3/base.pyR'RscCs |jdS(Nuutf-8(R$(R%((s8../Django//lib/python/django/db/backends/sqlite3/base.pyR'SstDatabaseFeaturescBsGeZeZeZeZeZeZeZ eZ eZ e dZ RS(cCsa|jj}|jdy|jdt}Wntjk rOt}nX|jd|S(uConfirm support for STDDEV and related stats functions SQLite supports STDDEV as an extension package; so connection.ops.check_aggregate_support() can't unilaterally rule out support for STDDEV. We need to manually check whether the call works. u CREATE TABLE STDDEV_TEST (X INT)u!SELECT STDDEV(*) FROM STDDEV_TESTuDROP TABLE STDDEV_TEST(t connectiontcursortexecutetTrueRt DatabaseErrortFalse(tselfR+t has_support((s8../Django//lib/python/django/db/backends/sqlite3/base.pytsupports_stddevcs      (t__name__t __module__R/tcan_use_chunked_readst#test_db_allows_multiple_connectionsR-tsupports_unspecified_pktsupports_timezonestsupports_1000_query_parameterst(supports_mixed_date_datetime_comparisonsthas_bulk_insertt6can_combine_inserts_with_and_without_auto_increment_pkR R2(((s8../Django//lib/python/django/db/backends/sqlite3/base.pyR)UstDatabaseOperationscBseZdZdZdZdZdZdZdZdZ dZ d Z d Z d Z d Zd ZRS(cCsHt|dkrdnd}t|dkr>|t|St|S(u SQLite has a compile-time default (SQLITE_LIMIT_VARIABLE_NUMBER) of 999 variables per query. If there is just single field to insert, then we can hit another limit, SQLITE_MAX_COMPOUND_SELECT which defaults to 500. iiii(tlen(R0tfieldstobjstlimit((s8../Django//lib/python/django/db/backends/sqlite3/base.pytbulk_batch_sizewscCsd|j|fS(Nudjango_extract('%s', %s)(tlower(R0t lookup_typet field_name((s8../Django//lib/python/django/db/backends/sqlite3/base.pytdate_extract_sqlscCs d|||j|j|jfS(Nu1django_format_dtdelta(%s, "%s", "%d", "%d", "%d")(tdaystsecondst microseconds(R0tsqlt connectort timedelta((s8../Django//lib/python/django/db/backends/sqlite3/base.pytdate_interval_sqlscCsd|j|fS(Nudjango_date_trunc('%s', %s)(RC(R0RDRE((s8../Django//lib/python/django/db/backends/sqlite3/base.pytdate_trunc_sqlscCsdS(Nu((R0((s8../Django//lib/python/django/db/backends/sqlite3/base.pytdrop_foreignkey_sqlscCsdS(NuNULL((R0((s8../Django//lib/python/django/db/backends/sqlite3/base.pytpk_default_valuescCs*|jdr"|jdr"|Sd|S(Nu"u"%s"(t startswithtendswith(R0tname((s8../Django//lib/python/django/db/backends/sqlite3/base.pyt quote_namescCsdS(Ni((R0((s8../Django//lib/python/django/db/backends/sqlite3/base.pytno_limit_valuescCsNg|D]=}d|jd|jd|j|j|f^q}|S(Nu %s %s %s;uDELETEuFROM(t SQL_KEYWORDt SQL_FIELDRT(R0tstylettablest sequencesttableRJ((s8../Django//lib/python/django/db/backends/sqlite3/base.pyt sql_flushsGcCse|dkrdStj|rXtjrI|jtjjdd}qXtdnt j |S(NRuNSQLite backend does not support timezone-aware datetimes when USE_TZ is False.( RR tis_awareRRRRRt ValueErrorR t text_type(R0R((s8../Django//lib/python/django/db/backends/sqlite3/base.pytvalue_to_db_datetimes  !cCs;|dkrdStj|r.tdntj|S(Nu5SQLite backend does not support timezone-aware times.(RR R]R^R R_(R0R((s8../Django//lib/python/django/db/backends/sqlite3/base.pytvalue_to_db_times  cCsd}d}||||gS(Nu%s-01-01u%s-12-31 23:59:59.999999((R0Rtfirsttsecond((s8../Django//lib/python/django/db/backends/sqlite3/base.pytyear_lookup_boundsscCs|j}|dkr.tj|j|S|rC|jdsO|dkrYt|S|dkrot|S|dkrt|S|dkrt|S|S(uSQLite returns floats when it should be returning decimals, and gets dates and datetimes wrong. For consistency with other backends, coerce when required. u DecimalFieldu IntegerFieldu AutoFieldu DateFieldu DateTimeFieldu TimeField( tget_internal_typetutilttypecast_decimalt format_numberRRtintRRR (R0Rtfieldt internal_type((s8../Django//lib/python/django/db/backends/sqlite3/base.pytconvert_valuess  !       csog}|jddjfd|D|jddjdgt|g|ddj|S(Nu SELECT %su, c3s%|]}dj|jVqdS(u %%s AS %sN(RTtcolumn(t.0tf(R0(s8../Django//lib/python/django/db/backends/sqlite3/base.pys suUNION ALL SELECT %su%siu (tappendtjointextendR>(R0R?t num_valuestres((R0s8../Django//lib/python/django/db/backends/sqlite3/base.pytbulk_insert_sqls 2(R3R4RBRFRMRNRORPRTRUR\R`RaRdRlRu(((s8../Django//lib/python/django/db/backends/sqlite3/base.pyR=vs        tDatabaseWrappercBseZdZidd6dd6dd6dd6dd6d d 6d d 6d d6dd6dd6dd6dd6dd6dd6ZdZdZdZddZdZ RS(usqliteu= %suexactuLIKE %s ESCAPE '\'uiexactucontainsu icontainsu REGEXP %suregexuREGEXP '(?i)' || %suiregexu> %sugtu>= %sugteu< %sultu<= %sulteu startswithuendswithu istartswithu iendswithcOswtt|j||t||_t||_t||_t ||_ t ||_ t ||_dS(N(tsuperRvt__init__R)tfeaturesR=topsRtclientRtcreationRt introspectiontBaseDatabaseValidationt validation(R0targstkwargs((s8../Django//lib/python/django/db/backends/sqlite3/base.pyRxscCs)|j}|ds2ddlm}|dni|dd6tjtjBd6}|j|dd|kr|drtjd t n|jit d6tj ||_ |j j d d t|j j d d t|j j d d t|j j ddttjd|jd|dS(NuNAMEi(RuJsettings.DATABASES is improperly configured. Please supply the NAME value.udatabaseu detect_typesuOPTIONSucheck_same_threaduThe `check_same_thread` option was provided and set to True. It will be overriden with False. Use the `DatabaseWrapper.allow_thread_sharing` property instead for controlling thread shareability.udjango_extractiudjango_date_truncuregexpudjango_format_dtdeltaitsenderR*(t settings_dicttdjango.core.exceptionsRtDatabasetPARSE_DECLTYPEStPARSE_COLNAMEStupdateRRRR/tconnectR*tcreate_functiont_sqlite_extractt_sqlite_date_trunct_sqlite_regexpt_sqlite_format_dtdeltaRtsendt __class__(R0RRR((s8../Django//lib/python/django/db/backends/sqlite3/base.pyt_sqlite_create_connection s(     cCs/|jdkr|jn|jjdtS(Ntfactory(R*RRR+tSQLiteCursorWrapper(R0((s8../Django//lib/python/django/db/backends/sqlite3/base.pyt_cursor0s c Cs|j}|dkr-|jj|}nx|D]}|jj||}|s[q4n|jj||}x|D]\}}}|jd||||||||fxD|jD]6} tj d|| d||| d||fqWqwWq4WdS(u Checks 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. Raises an IntegrityError on the first invalid foreign key reference encountered (if any) and provides 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") u 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 NULLuThe 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.iiN( R+RR}t table_namestget_primary_key_columntget_key_columnsR,tfetchallRtIntegrityError( R0RR+t table_nametprimary_key_column_namet key_columnst column_nametreferenced_table_nametreferenced_column_nametbad_row((s8../Django//lib/python/django/db/backends/sqlite3/base.pytcheck_constraints5s"     cCs1|j|jddkr-tj|ndS(NuNAMEu:memory:(tvalidate_thread_sharingRtBaseDatabaseWrappertclose(R0((s8../Django//lib/python/django/db/backends/sqlite3/base.pyRWs N( R3R4tvendort operatorsRxRRRRR(((s8../Django//lib/python/django/db/backends/sqlite3/base.pyRvs*  #  "u(?sf           !wr