o h @sddlZddlZddlZddlZddlZddlZddlmZddlm Z e dZ GdddZ Gddde Z d d Zd d Zd dZddZdddZddZddZddZdS)N)contextmanager)NotSupportedErrorzdjango.db.backendsc@steZdZddZegdZddZddZdd Zd d Z dd dZ dddZ ddZ ddZ ddZddZd S) CursorWrappercCs||_||_dSN)cursordb)selfrrr `/var/www/html/magazine_api/magazine_env/lib/python3.10/site-packages/django/db/backends/utils.py__init__s zCursorWrapper.__init__)ZfetchoneZ fetchmanyZfetchallZnextsetcCs&t|j|}|tjvr|j|S|Sr)getattrrrWRAP_ERROR_ATTRSrwrap_database_errors)rattrZ cursor_attrr r r __getattr__s   zCursorWrapper.__getattr__ccs<|jj|jEdHWddS1swYdSr)rrrrr r r __iter__s "zCursorWrapper.__iter__cCs|Srr rr r r __enter__ szCursorWrapper.__enter__cCs*z|WdS|jjjyYdSwr)closerZDatabaseError)rtypevalue tracebackr r r __exit__#s zCursorWrapper.__exit__NcCs|dur |jjjs td|j|jj;|dur,|dur,|j|WdS|dur>|j||WdS|pAd}|j|||WdS1sTwYdS)NzKKeyword parameters for callproc are not supported on this database backend.r )rfeaturesZsupports_callproc_kwargsrvalidate_no_broken_transactionrrcallproc)rZprocnameparamsZkparamsr r r r/s    $zCursorWrapper.callproccC|j||d|jdS)NFmanyexecutor)_execute_with_wrappers_executersqlrr r r executeAzCursorWrapper.executecCr)NTr)r" _executemanyrr% param_listr r r executemanyDr'zCursorWrapper.executemanycCs8|j|d}t|jjD]}t||}q |||||S)N) connectionr)rreversedZexecute_wrappers functoolspartial)rr%rr r!contextwrapperr r r r"Gs z$CursorWrapper._execute_with_wrapperscGsf|j|jj |dur|j|WdS|j||WdS1s,wYdSr)rrrrr&)rr%rignored_wrapper_argsr r r r#Ms    $zCursorWrapper._executecGsD|j|jj|j||WdS1swYdSr)rrrrr+)rr%r*r2r r r r(Vs   $zCursorWrapper._executemany)NNr)__name__ __module__ __qualname__r frozensetr rrrrrr&r+r"r#r(r r r r rs   rcs8eZdZd fdd ZfddZed ddZZS) CursorDebugWrapperNcB|j||ddt||WdS1swYdS)NT)use_last_executed_query) debug_sqlsuperr&r$ __class__r r r&` $zCursorDebugWrapper.executecr8)NT)r )r:r;r+r)r<r r r+dr>zCursorDebugWrapper.executemanyFc csJt}zRdVWt}||}|r|jj|j||}z |r%t|nd}Wn ty3d}Ynw|jj |r@d||fn|d|dt j d||||||dddSt}||}|rl|jj|j||}z |rst|nd}Wn tyd}Ynw|jj |rd||fn|d|dt j d||||||ddw) N?z %s times: %sz%.3f)r%timez(%.3f) %s; args=%s)durationr%r)extra) rA monotonicropsZlast_executed_queryrlen TypeErrorZ queries_logappendloggerdebug) rr%rr9r startstoprBtimesr r r r:hsX     zCursorDebugWrapper.debug_sqlr)NNFF)r3r4r5r&r+rr: __classcell__r r r<r r7\s  r7cCs|r tjtt|dSdS)N-)datetimedatemapintsplit)sr r r typecast_datesrVc Cs`|sdS|d\}}}d|vr|d\}}nd}tt|t|t|t|dddS)N:.0000000)rTrPrArS)rUhourminutesseconds 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 rO+rWrXrYrrZr[)rVrTrPrS)rUdt_datesrMr^r_r r r typecast_timestamps(   ricCsDz |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"."r?")rT ValueErrorstrip) identifier namespacenamer r r split_identifiers  rpcCsVt|\}}|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"."r?)rprF names_digest)rmrrZhash_lenrnrodigestr r r truncate_names  &rucGs0t}|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)rrargshargr r r rssrscCsl|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. Nrb)r0z{:f}) decimal getcontextcopyprecquantizeDecimalscalebZtrapsRoundedcreate_decimalformat)rZ max_digitsZdecimal_placesr0r r r format_numbers    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'. rjrb) startswithendswith)Z table_nameZ has_quotesr r r strip_quotessr)Nrq)rPr~r.rvloggingrA contextlibrZ django.dbr getLoggerrIrr7rVr`rirprursrrr r r r s&   N,