fix forward

eldenmoon · Oct 16, 2024 · 3b0e042 · 3b0e042
1 parent cbf75a9
commit 3b0e042
Showing 1 changed file with 11 additions and 9 deletions.
diff --git a/regression-test/framework/src/main/groovy/org/apache/doris/regression/suite/Suite.groovy b/regression-test/framework/src/main/groovy/org/apache/doris/regression/suite/Suite.groovy
@@ -1292,15 +1292,17 @@ class Suite implements GroovyInterceptable {
 
     String getServerPrepareJdbcUrl(String jdbcUrl, String database) {
         String urlWithoutSchema = jdbcUrl.substring(jdbcUrl.indexOf("://") + 3)
-        def sql_ip = urlWithoutSchema.substring(0, urlWithoutSchema.indexOf(":"))
-        def sql_port
-        if (urlWithoutSchema.indexOf("/") >= 0) {
-            // e.g: jdbc:mysql://locahost:8080/?a=b
-            sql_port = urlWithoutSchema.substring(urlWithoutSchema.indexOf(":") + 1, urlWithoutSchema.indexOf("/"))
-        } else {
-            // e.g: jdbc:mysql://locahost:8080
-            sql_port = urlWithoutSchema.substring(urlWithoutSchema.indexOf(":") + 1)
-        }
+        def masterFe = cluster.getMasterFe()
+        // def sql_ip = urlWithoutSchema.substring(0, urlWithoutSchema.indexOf(":"))
+        def sql_ip = masterFe.host
+        def sql_port = masterFe.queryPort
+        // if (urlWithoutSchema.indexOf("/") >= 0) {
+        //     // e.g: jdbc:mysql://locahost:8080/?a=b
+        //     sql_port = urlWithoutSchema.substring(urlWithoutSchema.indexOf(":") + 1, urlWithoutSchema.indexOf("/"))
+        // } else {
+        //     // e.g: jdbc:mysql://locahost:8080
+        //     sql_port = urlWithoutSchema.substring(urlWithoutSchema.indexOf(":") + 1)
+        // }
         // set server side prepared statement url
         return "jdbc:mysql://" + sql_ip + ":" + sql_port + "/" + database + "?&useServerPrepStmts=true"
     }