@@ -19,7 +19,7 @@ public class SQLCommenter {
19
19
private static final String DATABASE_SERVICE = encode ("dddbs" );
20
20
private static final String DD_HOSTNAME = encode ("ddh" );
21
21
private static final String DD_DB_NAME = encode ("dddb" );
22
- private static final String DD_DB_INSTANCE = "ddprs" ;
22
+ private static final String DD_PEER_SERVICE = "ddprs" ;
23
23
private static final String DD_ENV = encode ("dde" );
24
24
private static final String DD_VERSION = encode ("ddpv" );
25
25
private static final String TRACEPARENT = encode ("traceparent" );
@@ -100,9 +100,9 @@ public static String inject(
100
100
}
101
101
102
102
AgentSpan currSpan = activeSpan ();
103
- Object peerService = null ;
103
+ Object peerServiceObj = null ;
104
104
if (currSpan != null ) {
105
- peerService = currSpan .getTag (Tags .PEER_SERVICE );
105
+ peerServiceObj = currSpan .getTag (Tags .PEER_SERVICE );
106
106
}
107
107
108
108
final Config config = Config .get ();
@@ -112,7 +112,7 @@ public static String inject(
112
112
final int commentSize = capacity (traceParent , parentService , dbService , env , version );
113
113
StringBuilder sb = new StringBuilder (sql .length () + commentSize );
114
114
boolean commentAdded = false ;
115
- String peerServiceString = peerService != null ? peerService .toString () : null ;
115
+ String peerService = peerServiceObj != null ? peerServiceObj .toString () : null ;
116
116
117
117
if (appendComment ) {
118
118
sb .append (sql );
@@ -126,7 +126,7 @@ public static String inject(
126
126
dbService ,
127
127
hostname ,
128
128
dbName ,
129
- peerServiceString ,
129
+ peerService ,
130
130
env ,
131
131
version ,
132
132
traceParent );
@@ -141,7 +141,7 @@ public static String inject(
141
141
dbService ,
142
142
hostname ,
143
143
dbName ,
144
- peerServiceString ,
144
+ peerService ,
145
145
env ,
146
146
version ,
147
147
traceParent );
@@ -208,38 +208,14 @@ private static String encode(final String val) {
208
208
return val ;
209
209
}
210
210
211
- /*
212
211
protected static boolean toComment (
213
212
StringBuilder sb ,
214
213
final boolean injectTrace ,
215
214
final String parentService ,
216
215
final String dbService ,
217
216
final String hostname ,
218
217
final String dbName ,
219
- final String env,
220
- final String version,
221
- final String traceparent) {
222
- int emptySize = sb.length();
223
- append(sb, PARENT_SERVICE, parentService, false);
224
- append(sb, DATABASE_SERVICE, dbService, sb.length() > emptySize);
225
- append(sb, DD_HOSTNAME, hostname, sb.length() > emptySize);
226
- append(sb, DD_DB_NAME, dbName, sb.length() > emptySize);
227
- append(sb, DD_ENV, env, sb.length() > emptySize);
228
- append(sb, DD_VERSION, version, sb.length() > emptySize);
229
- if (injectTrace) {
230
- append(sb, TRACEPARENT, traceparent, sb.length() > emptySize);
231
- }
232
- return sb.length() > emptySize;
233
- }*/
234
-
235
- protected static boolean toComment (
236
- StringBuilder sb ,
237
- final boolean injectTrace ,
238
- final String parentService ,
239
- final String dbService ,
240
- final String hostname ,
241
- final String dbName ,
242
- final String dbInstance ,
218
+ final String peerService ,
243
219
final String env ,
244
220
final String version ,
245
221
final String traceparent ) {
@@ -249,8 +225,8 @@ protected static boolean toComment(
249
225
append (sb , DATABASE_SERVICE , dbService , sb .length () > emptySize );
250
226
append (sb , DD_HOSTNAME , hostname , sb .length () > emptySize );
251
227
append (sb , DD_DB_NAME , dbName , sb .length () > emptySize );
252
- if (dbInstance != null ) {
253
- append (sb , DD_DB_INSTANCE , dbInstance , sb .length () > emptySize );
228
+ if (peerService != null ) {
229
+ append (sb , DD_PEER_SERVICE , peerService , sb .length () > emptySize );
254
230
}
255
231
append (sb , DD_ENV , env , sb .length () > emptySize );
256
232
append (sb , DD_VERSION , version , sb .length () > emptySize );
0 commit comments