o [h+@sddlZddlZddlZddlZddlZddlZddlmZddlm Z ddl m Z ddl m Z ddlmZedZGdd d ZGd d d eZed d ZddZddZddZddZddZd!ddZddZddZdd ZdS)"N)contextmanager)md5)apps)NotSupportedError) parse_timezdjango.db.backendsc@sxeZdZddZegdZdZddZddZd d Z d d Z dddZ dddZ ddZ ddZddZddZd S) CursorWrappercCs||_||_dSN)cursordb)selfr r r /home/ubuntu/experiments/live_experiments/Pythonexperiments/Otree/venv/lib/python3.10/site-packages/django/db/backends/utils.py__init__s zCursorWrapper.__init__)ZfetchoneZ fetchmanyZfetchallZnextsetzAccessing the database during app initialization is discouraged. To fix this warning, avoid executing queries in AppConfig.ready() or when your app modules are imported.cCs&t|j|}|tjvr|j|S|Sr)getattrr rWRAP_ERROR_ATTRSr wrap_database_errors)r attrZ cursor_attrr r r __getattr__s   zCursorWrapper.__getattr__ccs<|jj|jEdHWddS1swYdSr)r rr r r r r __iter__%s "zCursorWrapper.__iter__cCs|Srr rr r r __enter__)szCursorWrapper.__enter__cCs*z|WdS|jjjyYdSwr)closer ZDatabaseError)r typevalue tracebackr r r __exit__,s zCursorWrapper.__exit__NcCs|dur |jjjs tdtjstjstj|j t d|j |jj ;|dur:|dur:|j |WdS|durL|j ||WdS|pOd}|j |||WdS1sbwYdS)NzKKeyword parameters for callproc are not supported on this database backend.categoryr )r featuresZsupports_callproc_kwargsrrreadystored_app_configswarningswarnAPPS_NOT_READY_WARNING_MSGRuntimeWarningvalidate_no_broken_transactionrr callproc)r ZprocnameparamsZkparamsr r r r'8s"     $zCursorWrapper.callproccC|j||d|jdS)NFmanyexecutor)_execute_with_wrappers_executer sqlr(r r r executeN zCursorWrapper.executecCr))NTr*)r- _executemanyr r0 param_listr r r executemanySr2zCursorWrapper.executemanycCs8|j|d}t|jjD]}t||}q |||||S)N) connectionr )r reversedZexecute_wrappers functoolspartial)r r0r(r+r,contextwrapperr r r r-Xs z$CursorWrapper._execute_with_wrapperscGstjstjstj|jtd|j|jj |dur)|j |WdS|j ||WdS1s:wYdSNr) rr r!r"r#r$r%r r&rr r1)r r0r(ignored_wrapper_argsr r r r.^s     $zCursorWrapper._executecGs`tjstjstj|jtd|j|jj |j ||WdS1s)wYdSr=) rr r!r"r#r$r%r r&rr r6)r r0r5r>r r r r3ks    $zCursorWrapper._executemany)NNr)__name__ __module__ __qualname__r frozensetrr$rrrrr'r1r6r-r.r3r r r r rs   rcs:eZdZd fdd ZfddZe d ddZZS) CursorDebugWrapperNcB|j||ddt||WdS1swYdS)NT)use_last_executed_query) debug_sqlsuperr1r/ __class__r r r1x $zCursorDebugWrapper.executecrD)NT)r+)rFrGr6r4rHr r r6|rJzCursorDebugWrapper.executemanyFc csbt}zXdVWt}||}|r|jj|j||}z |r%t|nd}Wn ty3d}Ynw|jj |r@d||fn|d|dt j d||||jj ||||jj dddSt}||}|rr|jj|j||}z |ryt|nd}Wn tyd}Ynw|jj |rd||fn|d|dt j d||||jj ||||jj ddw) N?z %s times: %s%.3fr0time(%.3f) %s; args=%s; alias=%s)durationr0r(aliasextra) rO monotonicr opsZlast_executed_queryr len TypeError queries_logappendloggerdebugrR) r r0r(rEr+startstoprQtimesr r r rFsp   zCursorDebugWrapper.debug_sqlr)NNFF)r?r@rAr1r6rrF __classcell__r r rHr rCus  rCccst}z1dVW|jr5t}||}|jd|d|dtjd||d|j|||jdddSdS|jrat}||}|jd|d|dtjd||d|j|||jddww)Nz%srMrNrP)rQr0rRrS)rOrUZqueries_loggedrYrZr[r\rR)r7r0r]r^rQr r r debug_transactionsV racCsXdD]$}||vr&||d\}}|r&t|r&d|vr|d}|||fSq|ddfS)zH Split a time zone name into a 3-tuple of (name, sign, offset). )+-:z:00N)rsplitr)tznamesignnameoffsetr r r split_tzname_deltas   rkcCs|r tjtt|dSdS)Nrc)datetimedatemapintsplit)sr r r typecast_datesrrc Cs`|sdS|d\}}}d|vr|d\}}nd}tt|t|t|t|dddS)Nre.0000000)rprlrOro)rqhourminutesseconds microsecondsr r r typecast_times$r{c Cs|sdSd|vr t|S|\}}d|vr|dd\}}n d|vr+|dd\}}|d}|d}|d}d|vrE|d\}}nd}tt|d t|dt|dt|d t|dt|t|d dd S) N rcrdrbrersrtrrurv)rrrprlro)rqdt_datesr_ryrzr r r typecast_timestamps0        rcCsDz |d\}}Wntyd|}}Ynw|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"."rK")rp ValueErrorstrip) identifier namespacerir r r split_identifier s  rcCsVt|\}}|dust||kr|St||d}d|rd|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"."rK)rrW names_digest)rrZhash_lenrridigestr r r truncate_names  rcGs2tdd}|D] }||q|d|S)zk Generate a 32-bit digest of a set of arguments that can be used to shorten identifying names. F)usedforsecurityN)rupdateencode hexdigest)rargshargr r r r0s rcCsl|durdSt}|dur||_|dur&|jtd| |d}n d|jtj<| |}d |S)zc Format a number into a string with the requisite number of digits and decimal places. Nrd)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'. rrd) startswithendswith)Z table_nameZ has_quotesr r r strip_quotesOsr)Nr)rlrr9loggingrOr" contextlibrhashlibrZ django.appsrZ django.dbrZdjango.utils.dateparser getLoggerr[rrCrarkrrr{rrrrrrr r r r s2      d1  $