[INLONG-11648][Manager] Oceanbase adds URL verification (#11650)

apache · Jan 6, 2025 · 513b894 · 513b894
1 parent 3662bcd
commit 513b894
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/...in/java/org/apache/inlong/manager/service/resource/sink/oceanbase/OceanBaseJdbcUtils.java b/...in/java/org/apache/inlong/manager/service/resource/sink/oceanbase/OceanBaseJdbcUtils.java
@@ -20,6 +20,7 @@
 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 @@ private static Connection establishDatabaseConnection(String url, String user, S
             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) {