From 2b8be40dfc78e2f4ccde4554a2ec6bb4b58a9e0f Mon Sep 17 00:00:00 2001
From: liangdaliang <liangdaliang@wondersoft.cn>
Date: Fri, 7 Mar 2025 10:49:14 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BC=98=E5=8C=96http=E5=9C=B0=E5=9D=80?=
 =?UTF-8?q?=E6=8B=BC=E6=8E=A5=E5=8F=8Asql=E6=89=A7=E8=A1=8C?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../src/main/java/com/test/common/utils/MySQLExecutor.java | 2 +-
 .../test/test/service/impl/TestCaseStepServiceImpl.java    | 7 ++++++-
 2 files changed, 7 insertions(+), 2 deletions(-)

diff --git a/test-common/src/main/java/com/test/common/utils/MySQLExecutor.java b/test-common/src/main/java/com/test/common/utils/MySQLExecutor.java
index 7dfe516..c45f2fe 100644
--- a/test-common/src/main/java/com/test/common/utils/MySQLExecutor.java
+++ b/test-common/src/main/java/com/test/common/utils/MySQLExecutor.java
@@ -29,7 +29,7 @@ public class MySQLExecutor {
         try (Connection connection = DriverManager.getConnection(url, user, password);
              Statement statement = connection.createStatement()) {
             // 执行查询，限制最大100行
-            try (ResultSet resultSet = statement.executeQuery(sql + " LIMIT 100")) {
+            try (ResultSet resultSet = statement.executeQuery(sql.replaceAll(";", "") + " LIMIT 100")) {
                 // 获取结果集的元数据
                 ResultSetMetaData metaData = resultSet.getMetaData();
                 int columnCount = metaData.getColumnCount();
diff --git a/test-test/src/main/java/com/test/test/service/impl/TestCaseStepServiceImpl.java b/test-test/src/main/java/com/test/test/service/impl/TestCaseStepServiceImpl.java
index 06df93b..97401a1 100644
--- a/test-test/src/main/java/com/test/test/service/impl/TestCaseStepServiceImpl.java
+++ b/test-test/src/main/java/com/test/test/service/impl/TestCaseStepServiceImpl.java
@@ -139,7 +139,12 @@ public class TestCaseStepServiceImpl implements ITestCaseStepService {
         }
         if (!url.startsWith("http")) {
             String apiProtocol = testCaseStep.getApiProtocol();
-            url = apiProtocol + "://" + url;
+            String appendUrl = apiProtocol + "://" + testCaseStep.getApiHost();
+            if (testCaseStep.getApiPort() != null) {
+                url = appendUrl + ":" + testCaseStep.getApiPort() + url;
+            } else {
+                url = appendUrl + url;
+            }
         }
         JmeterRequest jmeterRequest = new JmeterRequest();
         jmeterRequest.setId(id);