[INLONG-11648][Manager] Add sensitive parameter verification

apache · Jan 6, 2025 · 2815f36 · 2815f36
1 parent 42c6999
commit 2815f36
Showing 1 changed file with 2 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
@@ -23,6 +23,7 @@
 
 import com.google.common.collect.Lists;
 import org.apache.commons.lang3.StringUtils;
+import org.apache.inlong.manager.pojo.util.MySQLSensitiveUrlUtils;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
@@ -76,6 +77,7 @@ private static Connection establishDatabaseConnection(String url, String user, S
         }
         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) {