a Eb#@sddlZddlZddlZddlZddlZddlZddlmZddlm Z ddl m Z e dZ GdddZGdd d eZd d Zd d ZddZddZddZdddZddZddZddZdS)N)contextmanager)NotSupportedError) parse_timezdjango.db.backendsc@steZdZddZegdZddZddZdd Zd d Z dd dZ dddZ ddZ ddZ ddZddZd S) CursorWrappercCs||_||_dSN)cursordb)selfrrr X/home/ja/django-apps/lartica_env/lib/python3.9/site-packages/django/db/backends/utils.py__init__szCursorWrapper.__init__)ZfetchoneZ fetchmanyZfetchallZnextsetcCs*t|j|}|tjvr"|j|S|SdSr)getattrrrWRAP_ERROR_ATTRSrwrap_database_errors)r attrZ cursor_attrr r r __getattr__s   zCursorWrapper.__getattr__ccs8|jj|jEdHWdn1s*0YdSr)rrrr r r r __iter__s zCursorWrapper.__iter__cCs|Srr rr r r __enter__!szCursorWrapper.__enter__cCs*z |Wn|jjjy$Yn0dSr)closerZDatabaseError)r typevalue tracebackr r r __exit__$s zCursorWrapper.__exit__NcCs|dur|jjjstd|j|jj|durX|durX|j|WdS|dur||j||WdS|pd}|j|||WdSWdn1s0YdS)NzKKeyword parameters for callproc are not supported on this database backend.r )rfeaturesZsupports_callproc_kwargsrvalidate_no_broken_transactionrrcallproc)r ZprocnameparamsZkparamsr r r r0s  zCursorWrapper.callproccCs|j||d|jdS)NFmanyexecutor)_execute_with_wrappers_executer sqlrr r r executeBs zCursorWrapper.executecCs|j||d|jdS)NTr)r" _executemanyr r% param_listr r r executemanyGs zCursorWrapper.executemanycCs8|j|d}t|jjD]}t||}q|||||S)N) connectionr)rreversedZexecute_wrappers functoolspartial)r r%rr r!contextwrapperr r r r"Ls z$CursorWrapper._execute_with_wrapperscGst|j|jjN|dur6|j|WdS|j||WdSWdn1sf0YdSr)rrrrr&)r r%rignored_wrapper_argsr r r r#Rs   zCursorWrapper._executecGsD|j|jj|j||WdS1s60YdSr)rrrrr*)r r%r)r1r r r r'[s  zCursorWrapper._executemany)NN)N)__name__ __module__ __qualname__r frozensetrrrrrrr&r*r"r#r'r r r r rs    rcs8eZdZd fdd ZfddZed ddZZS) CursorDebugWrapperNcsB|j||ddt||WdS1s40YdS)NT)use_last_executed_query) debug_sqlsuperr&r$ __class__r r r&eszCursorDebugWrapper.executecsB|j||ddt||WdS1s40YdS)NT)r )r8r9r*r(r:r r r*iszCursorDebugWrapper.executemanyFc csft}zdVWt}||}|r:|jj|j||}z|rHt|nd}Wntydd}Yn0|jj |r~d||fn|d|dt j d||||jj ||||jj ddnt}||}|r|jj|j||}z|rt|nd}Wnty d}Yn0|jj |r(d||fn|d|dt j d||||jj ||||jj dd0dS) N?z %s times: %sz%.3f)r%timez(%.3f) %s; args=%s; alias=%s)durationr%ralias)extra) r> monotonicropsZlast_executed_queryrlen TypeErrorZ queries_logappendloggerdebugr@) r r%rr7r startstopr?timesr r r r8msj   zCursorDebugWrapper.debug_sql)N)NNFF)r2r3r4r&r*rr8 __classcell__r r r:r r6as  r6cCsFdD]6}||vr||d\}}|rt|r|||fSq|ddfS)zH Split a time zone name into a 3-tuple of (name, sign, offset). )+-N)rsplitr)tznamesignnameoffsetr r r split_tzname_deltas  rUcCs|rtjtt|dSdS)NrN)datetimedatemapintsplit)sr r r typecast_datesr\c Cs`|sdS|d\}}}d|vr0|d\}}nd}tt|t|t|t|dddS)N:.0000000)rZrVr>rY)r[hourminutesseconds microsecondsr r r typecast_times$rfc Cs|sdSd|vrt|S|\}}d|vr>|dd\}}nd|vrV|dd\}}|d}|d}|d}d|vr|d\}}nd}tt|d t|dt|dt|d t|dt|t|d dd S) N rNrOrMr]r^r_rr`ra)r\rZrVrY)r[dt_datesrKrdrer r r typecast_timestamps0        rmcCsDz|d\}}Wnty.d|}}Yn0|d|dfS)z Split an SQL identifier into a two element tuple of (namespace, name). The identifier could be a table, column, or sequence name might be prefixed by a namespace. z"."r<")rZ ValueErrorstrip) identifier namespacerSr r r split_identifiers  rscCsVt|\}}|dus t||kr$|St||d}d|r>d|nd|d|||fS)z Shorten an SQL identifier to a repeatable mangled version with the given length. If a quote stripped name contains a namespace, e.g. USERNAME"."TABLE, truncate the table portion only. N)lengthz%s%s%sz%s"."r<)rsrD names_digest)rqruZhash_lenrrrSdigestr r r truncate_names  rxcGs0t}|D]}||q |d|S)zk Generate a 32-bit digest of a set of arguments that can be used to shorten identifying names. N)hashlibmd5updateencode hexdigest)ruargshargr r r rvsrvcCsl|dur dSt}|dur&||_|durL|jtd| |d}nd|jtj<| |}d |S)zc Format a number into a string with the requisite number of digits and decimal places. NrO)r/z{:f}) decimal getcontextcopyprecquantizeDecimalscalebZtrapsRoundedcreate_decimalformat)rZ max_digitsZdecimal_placesr/r r r format_number s   rcCs(|do|d}|r$|ddS|S)z Strip quotes off of quoted table names to make them safe for use in index names, sequence names, etc. For example '"USER"."TABLE"' (an Oracle naming scheme) becomes 'USER"."TABLE'. rnrO) startswithendswith)Z table_nameZ has_quotesr r r strip_quotessr)Nrt)rVrr-ryloggingr> contextlibrZ django.dbrZdjango.utils.dateparser getLoggerrGrr6rUr\rfrmrsrxrvrrr r r r s(    R2 $