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) {