From 1c162ceb3fc378dc681c5efd130eaef1491f2220 Mon Sep 17 00:00:00 2001 From: Chisu Yu Date: Mon, 8 Oct 2012 09:50:31 +0000 Subject: [PATCH] =?UTF-8?q?[=EC=9C=A0=EC=B9=98=EC=88=98]=20[NOBTS]=20set?= =?UTF-8?q?=20endpoint=20from=20db=20interceptor.?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit git-svn-id: http://svn.bds.nhncorp.com/pe/hippo-tomcat-profiler/trunk@738 84d0f5b1-2673-498c-a247-62c4ff18d310 --- .../db/interceptor/StatementExecuteQueryInterceptor.java | 1 + .../db/interceptor/StatementExecuteUpdateInterceptor.java | 1 + .../modifier/db/interceptor/TransactionInterceptor.java | 5 +++++ 3 files changed, 7 insertions(+) diff --git a/src/main/java/com/profiler/modifier/db/interceptor/StatementExecuteQueryInterceptor.java b/src/main/java/com/profiler/modifier/db/interceptor/StatementExecuteQueryInterceptor.java index 2b1639f01..70840c8ef 100644 --- a/src/main/java/com/profiler/modifier/db/interceptor/StatementExecuteQueryInterceptor.java +++ b/src/main/java/com/profiler/modifier/db/interceptor/StatementExecuteQueryInterceptor.java @@ -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]); diff --git a/src/main/java/com/profiler/modifier/db/interceptor/StatementExecuteUpdateInterceptor.java b/src/main/java/com/profiler/modifier/db/interceptor/StatementExecuteUpdateInterceptor.java index b093ac64c..d32b3107d 100644 --- a/src/main/java/com/profiler/modifier/db/interceptor/StatementExecuteUpdateInterceptor.java +++ b/src/main/java/com/profiler/modifier/db/interceptor/StatementExecuteUpdateInterceptor.java @@ -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); diff --git a/src/main/java/com/profiler/modifier/db/interceptor/TransactionInterceptor.java b/src/main/java/com/profiler/modifier/db/interceptor/TransactionInterceptor.java index a10521085..6cbe0bac0 100644 --- a/src/main/java/com/profiler/modifier/db/interceptor/TransactionInterceptor.java +++ b/src/main/java/com/profiler/modifier/db/interceptor/TransactionInterceptor.java @@ -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) {