Fixed: Modify the code formatting

apache · Jul 22, 2024 · 0006d51 · 0006d51
1 parent 3ca4bd7
commit 0006d51
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 7 deletions.
diff --git a/...ojo/src/main/java/org/apache/inlong/manager/pojo/node/oceanbase/OceanBaseDataNodeDTO.java b/...ojo/src/main/java/org/apache/inlong/manager/pojo/node/oceanbase/OceanBaseDataNodeDTO.java
@@ -45,7 +45,7 @@
 public class OceanBaseDataNodeDTO {
 
     private static final Logger LOGGER = LoggerFactory.getLogger(OceanBaseDataNodeDTO.class);
-    private static final String OceanBase_JDBC_PREFIX = "jdbc:oceanbase://";
+    private static final String OCEANBASE_JDBC_PREFIX = "jdbc:oceanbase://";
 
     @ApiModelProperty("URL of backup DB server")
     private String backupUrl;
@@ -77,8 +77,8 @@ public static OceanBaseDataNodeDTO getFromJson(@NotNull String extParams) {
      */
     public static String convertToJdbcurl(String url) {
         String jdbcUrl = url;
-        if (StringUtils.isNotBlank(jdbcUrl) && !jdbcUrl.startsWith(OceanBase_JDBC_PREFIX)) {
-            jdbcUrl = OceanBase_JDBC_PREFIX + jdbcUrl;
+        if (StringUtils.isNotBlank(jdbcUrl) && !jdbcUrl.startsWith(OCEANBASE_JDBC_PREFIX)) {
+            jdbcUrl = OCEANBASE_JDBC_PREFIX + jdbcUrl;
         }
         return jdbcUrl;
     }

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
@@ -38,8 +38,8 @@
  */
 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 OCEANBASE_JDBC_PREFIX = "jdbc:mysql://";
+    private static final String OCEANBASE_DRIVER_CLASS = "com.oceanbase.jdbc.Driver";
     private static final Logger LOGGER = LoggerFactory.getLogger(OceanBaseJdbcUtils.class);
 
     /**
@@ -52,7 +52,7 @@ public class OceanBaseJdbcUtils {
      * @throws Exception on get connection error
      */
     public static Connection getConnection(String url, String user, String password) throws Exception {
-        UrlVerificationUtils.extractHostAndValidatePortFromJdbcUrl(url, OceanBase_JDBC_PREFIX);
+        UrlVerificationUtils.extractHostAndValidatePortFromJdbcUrl(url, OCEANBASE_JDBC_PREFIX);
         Connection conn = establishDatabaseConnection(url, user, password);
         return conn;
     }
@@ -69,7 +69,7 @@ public static Connection getConnection(String url, String user, String password)
     private static Connection establishDatabaseConnection(String url, String user, String password) throws Exception {
         Connection conn;
         try {
-            Class.forName(OceanBase_DRIVER_CLASS);
+            Class.forName(OCEANBASE_DRIVER_CLASS);
             conn = DriverManager.getConnection(url, user, password);
         } catch (Exception e) {
             String errorMsg =