home/pinpoint
2
0
Fork 0
mirror of https://github.com/wahyd4/pinpoint.git synced 2026-08-17 00:36:02 +10:00
Code Issues Packages Projects Releases Wiki Activity

[유치수] [NOBTS] set endpoint from db interceptor.

Browse Source 
git-svn-id: http://svn.bds.nhncorp.com/pe/hippo-tomcat-profiler/trunk@738 84d0f5b1-2673-498c-a247-62c4ff18d310
This commit is contained in:
Chisu Yu
2012-10-08 09:50:31 +00:00
parent d044596be8
commit 1c162ceb3f
3 changed files with 7 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/main/java/com/profiler/modifier/db/interceptor/StatementExecuteQueryInterceptor.java
+1
View File
@@ -41,6 +41,7 @@ public class StatementExecuteQueryInterceptor implements StaticAroundInterceptor
*/
String url = (String) this.getUrl.invoke(target);
Trace.recordRpcName("MYSQL", url);
Trace.recordEndPoint(url);
if (args.length > 0) {
Trace.recordAttibute("Statement", args[0]);
src/main/java/com/profiler/modifier/db/interceptor/StatementExecuteUpdateInterceptor.java
+1
View File
@@ -40,6 +40,7 @@ public class StatementExecuteUpdateInterceptor implements StaticAroundIntercepto
if (args.length > 0) {
String url = (String) this.getUrl.invoke(target);
Trace.recordAttibute("Query", url);
Trace.recordEndPoint(url);
}
Trace.record(Annotation.ClientSend);
src/main/java/com/profiler/modifier/db/interceptor/TransactionInterceptor.java
+5
View File
@@ -64,6 +64,7 @@ public class TransactionInterceptor implements StaticAroundInterceptor {
try {
String connectionUrl = this.getUrl.invoke(target);
Trace.recordRpcName("MYSQL", connectionUrl);
Trace.recordEndPoint(connectionUrl);
Trace.record(Annotation.ClientSend);
} finally {
Trace.traceBlockEnd();
@@ -109,6 +110,7 @@ public class TransactionInterceptor implements StaticAroundInterceptor {
try {
String connectionUrl = this.getUrl.invoke(target);
Trace.recordRpcName("MYSQL", connectionUrl);
Trace.recordEndPoint(connectionUrl);
Trace.record(Annotation.ClientSend);
} finally {
Trace.traceBlockEnd();
@@ -120,6 +122,7 @@ public class TransactionInterceptor implements StaticAroundInterceptor {
try {
String connectionUrl = this.getUrl.invoke(target);
Trace.recordRpcName("MYSQL", connectionUrl);
Trace.recordEndPoint(connectionUrl);
boolean success = InterceptorUtils.isSuccess(result);
if (success) {
@@ -145,6 +148,7 @@ public class TransactionInterceptor implements StaticAroundInterceptor {
try {
String connectionUrl = this.getUrl.invoke(target);
Trace.recordRpcName("MYSQL", connectionUrl);
Trace.recordEndPoint(connectionUrl);
Trace.record(Annotation.ClientSend);
} finally {
Trace.traceBlockEnd();
@@ -164,6 +168,7 @@ public class TransactionInterceptor implements StaticAroundInterceptor {
String connectionUrl = this.getUrl.invoke(target);
Trace.recordRpcName("MYSQL", connectionUrl);
Trace.recordEndPoint(connectionUrl);
boolean success = InterceptorUtils.isSuccess(result);
if (success) {