11package datadog .trace .instrumentation .jdbc ;
22
33import datadog .trace .api .Config ;
4- import datadog .trace .bootstrap .instrumentation .api .AgentSpan ;
5- import datadog .trace .bootstrap .instrumentation .api .AgentTracer ;
64import java .io .UnsupportedEncodingException ;
75import java .net .URLEncoder ;
86import java .nio .charset .StandardCharsets ;
@@ -17,7 +15,7 @@ public class SQLCommenter {
1715 private static final String DATABASE_SERVICE = encode ("dddbs" );
1816 private static final String DD_HOSTNAME = encode ("ddh" );
1917 private static final String DD_DB_NAME = encode ("dddb" );
20- private static final String DD_PEER_SERVICE = encode ( "ddprs" ) ;
18+ private static final String DD_DB_INSTANCE = "ddprs" ;
2119 private static final String DD_ENV = encode ("dde" );
2220 private static final String DD_VERSION = encode ("ddpv" );
2321 private static final String TRACEPARENT = encode ("traceparent" );
@@ -28,7 +26,6 @@ public class SQLCommenter {
2826 private static final String OPEN_COMMENT = "/*" ;
2927 private static final String CLOSE_COMMENT = "*/" ;
3028 private static final int INITIAL_CAPACITY = computeInitialCapacity ();
31- private static final String DD_DB_INSTANCE = "ddprs" ;
3229
3330 public static String append (
3431 final String sql ,
@@ -154,19 +151,6 @@ public static String inject(
154151 final String traceParent ,
155152 final boolean injectTrace ,
156153 boolean appendComment ) {
157- System .out .println ("HELLO IN INJECT PEER SERVICE" );
158-
159- // Map<String, Object> tagMap = span.getTags();
160- // Object peerService = tagMap.get(Tags.PEER_SERVICE);
161-
162- // String peerService = span.getTag(Tags.PEER_SERVICE);
163- AgentSpan currSpan = AgentTracer .activeSpan ();
164- // System.out.println(currSpan.getTags());
165- // String myPeerService = currSpan.getTag(Tags.PEER_SERVICE).toString();
166- //
167- // if (myPeerService != null) {
168- // System.out.print(myPeerService);
169- // }
170154
171155 if (sql == null || sql .isEmpty ()) {
172156 return sql ;
@@ -200,8 +184,6 @@ public static String inject(
200184 final String parentService = config .getServiceName ();
201185 final String env = config .getEnv ();
202186 final String version = config .getVersion ();
203- // String configPeerService = config.getPeerServiceMapping().get(Tags.PEER_SERVICE);
204- // System.out.println(configPeerService);
205187
206188 final int commentSize = capacity (traceParent , parentService , dbService , env , version );
207189 StringBuilder sb = new StringBuilder (sql .length () + commentSize );
@@ -333,9 +315,8 @@ protected static boolean toComment(
333315 final String env ,
334316 final String version ,
335317 final String traceparent ) {
336- System .out .println ("in the new to Comment" );
337318 int emptySize = sb .length ();
338- System . out . println ( "DB INSTANCE PEER SERVICE:" + dbInstance );
319+
339320 append (sb , PARENT_SERVICE , parentService , false );
340321 append (sb , DATABASE_SERVICE , dbService , sb .length () > emptySize );
341322 append (sb , DD_HOSTNAME , hostname , sb .length () > emptySize );
0 commit comments