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 <[email protected]>
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) {
