o i4@s:dZddlZddlmZddlmZddlmZddlm Z ddl m Z ddl m Z dd l mZd d lmZd d lmZd d lmZd dlmZd dlmZd dlmZd dlmZddlmZddlmZe eZededdddddZ Gdddej!Z"Gddde"Z#Gdd d ej!Z$d!d"Z%d#d$Z&dS)%z Generic dbapi tracing code. N)config)core) COMPONENT) get_logger) ArgumentError)get_argument_value)tracer)Pin)_SPAN_MEASURED_KEY) SPAN_KIND)SpanKind) SpanTypes)db)sql) ext_service) iswrappeddbapi2rr)_default_service_dbapi_span_name_prefixtrace_fetch_methodscCsdS)NrrrI/home/ubuntu/.local/lib/python3.10/site-packages/ddtrace/contrib/dbapi.py get_version'srcs`eZdZdZfddZddZddZdd Zd d Zd d Z ddZ ddZ ddZ Z S) TracedCursorz8TracedCursor wraps a psql cursor and traces its queries.cstt|||||rd|vr|dntjd}|r&d|vr&|dnd|}||_d|_|p5tj|_ t |j dd|_ dS)Nr_dbapi_span_operation_namez{}.query_dbm_propagator) superr__init__ontorrformat_self_datadog_name_self_last_execute_operation _self_configgetattr_self_dbm_propagator)selfcursorpincfgspan_name_prefix span_name __class__rrr /s$  zTracedCursor.__init__cC |jSN) __wrapped____iter__r(rrrr3B zTracedCursor.__iter__cCr0r1)r2__next__r4rrrr6Er5zTracedCursor.__next__c Os(t|}|r |s||i|S||jk} tj|t||j|tj de} | r.| t d| |j | || t|jj| ttjtd|||jj|f|rot|jjd|j| ||fj} | ro| j\} }}z||i|W|| WdS|| w1swYdS)a Internal function to trace the call to the underlying cursor method :param method: The callable to be wrapped :param name: The name of the resulting span. :param resource: The sql query. Sql queries are obfuscated on the agent side. :param extra_tags: A dict of tags to store into the span's meta :param dbm_propagator: _DBM_Propagator, prepends dbm comments to sql statements :param args: The args that will be passed as positional args to the wrapped method :param kwargs: The args that will be passed as kwargs to the wrapped method :return: The result of the wrapped method invocation )serviceresource span_typerdb_query_checkz.executeN)r get_fromenabledr#rtracerr%rSQL set_metricr set_tagstags _set_tag_strrintegration_namer r CLIENTrdispatchdispatch_with_resultsresultvalue_set_post_execute_tags) r(methodnamer8 extra_tagsdbm_propagatorargskwargsr*measuredsrGrrr _trace_methodHs:        zTracedCursor._trace_methodcOsH||_td||||f|j|jj|j|ddi|j|g|Ri|S)z#Wraps the cursor.executemany methodasm.block.dbapi.executezsql.executemanytrue)r$rrErRr2 executemanyr#r'r(queryrNrOrrrrU{szTracedCursor.executemanycOsD||_td||||f|j|jj|j|i|j|g|Ri|S)zWraps the cursor.execute methodrS)r$rrErRr2executer#r'rVrrrrXszTracedCursor.executecGs(||_|j|jj|j|id|g|RS)z Wraps the cursor.callproc methodN)r$rRr2callprocr#)r(procrNrrrrYs"zTracedCursor.callproccCsTt|jdd}|dur dS|tj|t|tr&|dkr(|tj|dSdSdS)Nrowcountr)r&r2r?rROWCOUNT isinstanceintset_tag)r(span row_countrrrrIsz#TracedCursor._set_post_execute_tagscCs |jj|Sr1)r2 __enter__r4rrrrbszTracedCursor.__enter__)__name__ __module__ __qualname____doc__r r3r6rRrUrXrYrIrb __classcell__rrr.rr,s 3rc@s(eZdZdZddZddZddZdS) FetchTracedCursorz Sub-class of :class:`TracedCursor` that also instruments `fetchone`, `fetchall`, and `fetchmany` methods. We do not trace these functions by default since they can get very noisy (e.g. `fetchone` with 100k rows). cO4d|jd}|j|jj||jidg|Ri|S)z Wraps the cursor.fetchone method{}.{}fetchoneN)r"r#rRr2rkr$r(rNrOr-rrrrkzFetchTracedCursor.fetchonecOri)z Wraps the cursor.fetchall methodrjfetchallN)r"r#rRr2rnr$rlrrrrnrmzFetchTracedCursor.fetchallcOsd|jd}d}z |t||ddi}Wnty,t|jdd}|r(||ini}Ynw|j|jj||j|dg|Ri|S)z!Wraps the cursor.fetchmany methodrj fetchmanyz db.fetch.sizersize arraysizeN) r"r#rrr&r2rRror$)r(rNrOr- size_tag_keyrLdefault_array_sizerrrros zFetchTracedCursor.fetchmanyN)rcrdrerfrkrnrorrrrrhs  rhcsJeZdZdZdfdd ZddZddZd d Zd d Zd dZ Z S)TracedConnectionz6TracedConnection wraps a Connection with tracing code.Ncsh|stj}|s|jr tnt}tt||t|}d ||_ |p&t |d}| |||_ ||_dS)Nz {}.connectionr7)rrrrhrrrtr _get_vendorr"r#r r!_self_cursor_clsr%)r(connr*r+ cursor_clsrKdb_pinr.rrr s   zTracedConnection.__init__cCsb|j}t|dr||jur|S|St|dr/t|r|St|}|s'|S||||jS|S)aContext management is not defined by the dbapi spec. This means unfortunately that the database clients each define their own implementations. The ones we know about are: - mysqlclient<2.0 which returns a cursor instance. >=2.0 returns a connection instance. - psycopg returns a connection. - pyodbc returns a connection. - pymysql doesn't implement it. - sqlite3 returns the connection. r)rX)r2rbhasattrrr r;rwr%)r(rr*rrrrbs     zTracedConnection.__enter__cOst|}|r |s||i|Stj|t||jd)}|t|jj |t t j | |j| |||i|WdS1sIwYdS)Nru)r r;r<rr=rr%rBrrCr r rDr@rA)r(rJrKrLrNrOr*rQrrrrR&s     $zTracedConnection._trace_methodcOs6|jj|i|}t|}|s|S|j|||jdS)N)r)r*r+)r2r)r r;rwr%)r(rNrOr)r*rrrr)6s  zTracedConnection.cursorcO.d|jd}|j|jj|ig|Ri|S)Nrjcommit)r"r#rRr2r~rlrrrr~= zTracedConnection.commitcOr})Nrjrollback)r"r#rRr2rrlrrrrArzTracedConnection.rollback)NNN) rcrdrerfr rbrRr)r~rrgrrr.rrts*rtcCs<zt|}Wntytjdddd}Ynwt|S)zGReturn the vendor (e.g postgres, mysql) of the given database. zcouldn't parse module nameT)exc_infor)_get_module_name Exceptionlogdebugrnormalize_vendor)rxrKrrrrvFs   rvcCs|jjddS)N.r)r/rdsplit)rxrrrrRsr)'rfwraptddtracerddtrace.internalrddtrace.internal.constantsrddtrace.internal.loggerrddtrace.internal.utilsrr ddtrace.tracer _trace.pinr constantsr r extr rrrinternal.trace_utilsrrrcr_adddictr ObjectProxyrrhrtrvrrrrrsD                 '_