fix:username and password verify

apache · Jul 23, 2024 · ce799b2 · ce799b2
1 parent 1546def
commit ce799b2
Showing 1 changed file with 11 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
@@ -33,13 +33,16 @@
 import java.util.List;
 import java.util.Objects;
 
+import static org.reflections.Reflections.log;
+
 /**
  * Utils for OceanBase JDBC.
  */
 public class OceanBaseJdbcUtils {
 
     private static final String OCEANBASE_JDBC_PREFIX = "jdbc:mysql://";
     private static final String OCEANBASE_DRIVER_CLASS = "com.oceanbase.jdbc.Driver";
+    private static final String AUTO_DESERIALIZE = "autoDeserialize";
     private static final Logger LOGGER = LoggerFactory.getLogger(OceanBaseJdbcUtils.class);
 
     /**
@@ -70,6 +73,14 @@ private static Connection establishDatabaseConnection(String url, String user, S
         Connection conn;
         try {
             Class.forName(OCEANBASE_DRIVER_CLASS);
+            if (user.contains(AUTO_DESERIALIZE)) {
+                log.warn("sensitive param : {} in username field is filtered", AUTO_DESERIALIZE);
+                user = user.replace(AUTO_DESERIALIZE, "");
+            }
+            if (password.contains(AUTO_DESERIALIZE)) {
+                log.warn("sensitive param : {} in password field is filtered", AUTO_DESERIALIZE);
+                password = password.replace(AUTO_DESERIALIZE, "");
+            }
             conn = DriverManager.getConnection(url, user, password);
         } catch (Exception e) {
             String errorMsg =