(inlong) branch master updated: [INLONG-11377][Manager] Add verification for oceanusBase URL (#11378)

[dockerzhang]

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

dockerzhang 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 cf1f7877ba [INLONG-11377][Manager] Add verification for oceanusBase 
URL (#11378)
cf1f7877ba is described below

commit cf1f7877ba846a509021d86918f21d74f718f2bc
Author: fuweng11 <76141879+fuwen...@users.noreply.github.com>
AuthorDate: Mon Oct 21 19:36:02 2024 +0800

    [INLONG-11377][Manager] Add verification for oceanusBase URL (#11378)
---
 .../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 35e67a5a57..bc2f7ae440 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
@@ -71,6 +71,9 @@ public class OceanBaseJdbcUtils {
      */
     private static Connection establishDatabaseConnection(String url, String 
user, String password) throws Exception {
         Connection conn;
+        if (StringUtils.isBlank(url) || 
!url.startsWith(OCEANBASE_JDBC_PREFIX)) {
+            throw new Exception("OceanusBase URL is invalid, it should start 
with jdbc:oceanbase");
+        }
         try {
             Class.forName(OCEANBASE_DRIVER_CLASS);
             conn = DriverManager.getConnection(url, user, password);