(inlong) branch master updated: [INLONG-11648][Manager] Oceanbase adds URL verification (#11650)

[aloyszhang]

This is an automated email from the ASF dual-hosted git repository.

aloyszhang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git


The following commit(s) were added to refs/heads/master by this push:
     new 513b894959 [INLONG-11648][Manager] Oceanbase adds URL verification 
(#11650)
513b894959 is described below

commit 513b894959b05553e121201acc01d93a75c99358
Author: fuweng11 <76141879+fuwen...@users.noreply.github.com>
AuthorDate: Mon Jan 6 14:04:08 2025 +0800

    [INLONG-11648][Manager] Oceanbase adds URL verification (#11650)
---
 .../manager/service/resource/sink/oceanbase/OceanBaseJdbcUtils.java    | 3 +++
 1 file changed, 3 insertions(+)

diff --git 
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/sink/oceanbase/OceanBaseJdbcUtils.java
 
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/sink/oceanbase/OceanBaseJdbcUtils.java
index bc2f7ae440..d2e2ecd762 100644
--- 
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/sink/oceanbase/OceanBaseJdbcUtils.java
+++ 
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/sink/oceanbase/OceanBaseJdbcUtils.java
@@ -20,6 +20,7 @@ package 
org.apache.inlong.manager.service.resource.sink.oceanbase;
 import org.apache.inlong.manager.common.util.UrlVerificationUtils;
 import org.apache.inlong.manager.pojo.sink.oceanbase.OceanBaseColumnInfo;
 import org.apache.inlong.manager.pojo.sink.oceanbase.OceanBaseTableInfo;
+import org.apache.inlong.manager.pojo.util.MySQLSensitiveUrlUtils;
 
 import com.google.common.collect.Lists;
 import org.apache.commons.lang3.StringUtils;
@@ -75,6 +76,8 @@ public class OceanBaseJdbcUtils {
             throw new Exception("OceanusBase URL is invalid, it should start 
with jdbc:oceanbase");
         }
         try {
+            UrlVerificationUtils.extractHostAndValidatePortFromJdbcUrl(url, 
OCEANBASE_JDBC_PREFIX);
+            url = MySQLSensitiveUrlUtils.filterSensitive(url);
             Class.forName(OCEANBASE_DRIVER_CLASS);
             conn = DriverManager.getConnection(url, user, password);
         } catch (Exception e) {