3 g @sddlZddlZddlZddlZddlZddlZddlmZddlm Z ej dZ GdddZ Gddde Z d d Zd d Zd dZddZdddZddZddZddZdS)N)contextmanager)NotSupportedErrorzdjango.db.backendsc@sxeZdZddZeddddgZddZd d Zd d Zd dZ dddZ dddZ ddZ ddZ ddZddZdS) CursorWrappercCs||_||_dS)N)cursordb)selfrrrV/var/www/tester-filtro-web/env/lib/python3.6/site-packages/django/db/backends/utils.py__init__szCursorWrapper.__init__ZfetchoneZ fetchmanyZfetchallZnextsetcCs*t|j|}|tjkr"|jj|S|SdS)N)getattrrrWRAP_ERROR_ATTRSrwrap_database_errors)rattrZ cursor_attrrrr __getattr__s   zCursorWrapper.__getattr__c cs$|jj|jEdHWdQRXdS)N)rr r)rrrr __iter__s zCursorWrapper.__iter__cCs|S)Nr)rrrr __enter__ szCursorWrapper.__enter__c Cs,y |jWn|jjjk r&YnXdS)N)closerZDatabaseError)rtypevalue tracebackrrr __exit__#s zCursorWrapper.__exit__Nc Cs|dk r|jjj rtd|jj|jjP|dkrL|dkrL|jj|S|dkrb|jj||S|phf}|jj|||SWdQRXdS)NzKKeyword parameters for callproc are not supported on this database backend.)rfeaturesZsupports_callproc_kwargsrvalidate_no_broken_transactionr rcallproc)rZprocnameparamsZkparamsrrr r/s   zCursorWrapper.callproccCs|j||d|jdS)NF)manyexecutor)_execute_with_wrappers_execute)rsqlrrrr executeAszCursorWrapper.executecCs|j||d|jdS)NT)rr)r _executemany)rr param_listrrr executemanyDszCursorWrapper.executemanycCs<|j|d}x t|jjD]}tj||}qW|||||S)N) connectionr)rreversedZexecute_wrappers functoolspartial)rr rrrcontextwrapperrrr rGs z$CursorWrapper._execute_with_wrappersc GsD|jj|jj(|dkr(|jj|S|jj||SWdQRXdS)N)rrr rr!)rr rignored_wrapper_argsrrr rMs    zCursorWrapper._executec Gs,|jj|jj|jj||SQRXdS)N)rrr rr$)rr r#r+rrr r"Vs  zCursorWrapper._executemany)NN)N)__name__ __module__ __qualname__r frozensetr rrrrrr!r$rrr"rrrr rs   rcs8eZdZd fdd ZfddZed ddZZS) CursorDebugWrapperNc s*|j||ddtj||SQRXdS)NT)use_last_executed_query) debug_sqlsuperr!)rr r) __class__rr r!`szCursorDebugWrapper.executec s*|j||ddtj||SQRXdS)NT)r)r2r3r$)rr r#)r4rr r$dszCursorDebugWrapper.executemanyFc cstj}z dVWdtj}||}|r<|jjj|j||}y|rJt|nd}Wntk rhd}YnX|jjj |rd||fn|d|dt j d||||||ddXdS) N?z %s times: %sz%.3f)r timez(%.3f) %s; args=%s)durationr r)extra) r7 monotonicropsZlast_executed_queryrlen TypeErrorZ queries_logappendloggerdebug) rr rr1rstartstopr8timesrrr r2hs(  zCursorDebugWrapper.debug_sql)N)NNFF)r,r-r.r!r$rr2 __classcell__rr)r4r r0\s r0cCs|rtjtt|jdSdS)N-)datetimedatemapintsplit)srrr typecast_datesrLcCs`|sdS|jd\}}}d|kr0|jd\}}nd}tjt|t|t|t|dddS)N:.0000000)rJrFr7rI)rKhourminutesseconds microsecondsrrr typecast_timesrVc Cs|sdSd|krt|S|j\}}d|kr>|jdd\}}nd|krV|jdd\}}|jd}|jd}|d}d|kr|jd\}}nd}tjt|d t|dt|dt|d t|dt|t|d dd S) N rE+rMrNrOrrPrQ)rLrJrFrI)rKdt_datesrCrTrUrrr typecast_timestamps&   r_c CsFy|jd\}}Wntk r0d|}}YnX|jd|jdfS)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"."r5")rJ ValueErrorstrip) identifier namespacenamerrr split_identifiers rfcCsVt|\}}|dks 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"."r5)rfr< names_digest)rcrhZhash_lenrdredigestrrr truncate_names   rkcGs4tj}x|D]}|j|jqW|jd|S)zk Generate a 32-bit digest of a set of arguments that can be used to shorten identifying names. N)hashlibmd5updateencode hexdigest)rhargshargrrr ris ricCsl|dkr dStjj}|dk r&||_|dk rL|jtjdj| |d}nd|jtj<|j |}dj |S)zc Format a number into a string with the requisite number of digits and decimal places. NrX)r)z{:f}) decimal getcontextcopyprecquantizeDecimalscalebZtrapsRoundedcreate_decimalformat)rZ max_digitsZdecimal_placesr)rrr format_numbers   r~cCs(|jdo|jd}|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'. r`rX) startswithendswith)Z table_nameZ has_quotesrrr strip_quotessr)Nrg)rFrtr'rlloggingr7 contextlibrZ django.dbr getLoggerr?rr0rLrVr_rfrkrir~rrrrr s$   N,