From 56278df05a2ee78ff1cb7e91d5a0a358c8255fd7 Mon Sep 17 00:00:00 2001
From: ChenYunHey <1908166778@qq.com>
Date: Sat, 20 Jan 2024 21:15:28 +0800
Subject: [PATCH] Reformar Code

Signed-off-by: ChenYunHey <1908166778@qq.com>
---
 .../flink/lakesoul/entry/SyncDatabase.java    | 34 +++++++++----------
 1 file changed, 16 insertions(+), 18 deletions(-)

diff --git a/lakesoul-flink/src/main/java/org/apache/flink/lakesoul/entry/SyncDatabase.java b/lakesoul-flink/src/main/java/org/apache/flink/lakesoul/entry/SyncDatabase.java
index fb22ef623..ba3770d05 100644
--- a/lakesoul-flink/src/main/java/org/apache/flink/lakesoul/entry/SyncDatabase.java
+++ b/lakesoul-flink/src/main/java/org/apache/flink/lakesoul/entry/SyncDatabase.java
@@ -77,7 +77,7 @@ public static String pgAndMsqlCreateTableSql(String[] stringFieldTypes, String[]
                 createTableQuery.append(", ");
             }
         }
-        if (pk!=null){
+        if (pk != null) {
             createTableQuery.append(" ,PRIMARY KEY(").append(pk);
             createTableQuery.append(")");
         }
@@ -91,7 +91,7 @@ public static String[] getMysqlFieldsTypes(DataType[] fieldTypes, String[] field
         for (int i = 0; i < fieldTypes.length; i++) {
             if (fieldTypes[i].getLogicalType() instanceof VarCharType) {
                 String mysqlType = "VARCHAR(255)";
-                if (pk!=null){
+                if (pk != null) {
                     if (pk.contains(fieldNames[i])) {
                         mysqlType = "VARCHAR(100)";
                     }
@@ -103,8 +103,7 @@ public static String[] getMysqlFieldsTypes(DataType[] fieldTypes, String[] field
                 stringFieldTypes[i] = "BINARY";
             } else if (fieldTypes[i].getLogicalType() instanceof LocalZonedTimestampType | fieldTypes[i].getLogicalType() instanceof TimestampType) {
                 stringFieldTypes[i] = "TIMESTAMP";
-            }
-            else if (fieldTypes[i].getLogicalType() instanceof BooleanType) {
+            } else if (fieldTypes[i].getLogicalType() instanceof BooleanType) {
                 stringFieldTypes[i] = "BOOLEAN";
             } else {
                 stringFieldTypes[i] = fieldTypes[i].toString();
@@ -119,7 +118,7 @@ public static String[] getPgFieldsTypes(DataType[] fieldTypes, String[] fieldNam
         for (int i = 0; i < fieldTypes.length; i++) {
             if (fieldTypes[i].getLogicalType() instanceof VarCharType) {
                 String mysqlType = "TEXT";
-                if (pk!=null){
+                if (pk != null) {
                     if (pk.contains(fieldNames[i])) {
                         mysqlType = "VARCHAR(100)";
                     }
@@ -143,13 +142,12 @@ public static String[] getPgFieldsTypes(DataType[] fieldTypes, String[] fieldNam
     public static String[] getDorisFieldTypes(DataType[] fieldTypes) {
         String[] stringFieldTypes = new String[fieldTypes.length];
         for (int i = 0; i < fieldTypes.length; i++) {
-            if (fieldTypes[i].getLogicalType() instanceof TimestampType){
+            if (fieldTypes[i].getLogicalType() instanceof TimestampType) {
                 stringFieldTypes[i] = "DATETIME";
-            }
-            else if (fieldTypes[i].getLogicalType() instanceof VarCharType){
+            } else if (fieldTypes[i].getLogicalType() instanceof VarCharType) {
                 stringFieldTypes[i] = "VARCHAR";
 
-            }   else {
+            } else {
                 stringFieldTypes[i] = fieldTypes[i].toString();
             }
         }
@@ -165,7 +163,7 @@ public static String getTablePk(String sourceDataBae, String sourceTableName) {
         StringBuilder stringBuilder = new StringBuilder();
         for (int i = 0; i < primaryKeys.size(); i++) {
             stringBuilder.append(primaryKeys.get(i));
-            if (i<primaryKeys.size()-1){
+            if (i < primaryKeys.size() - 1) {
                 stringBuilder.append(",");
             }
         }
@@ -204,8 +202,8 @@ public static void xsyncToPg(StreamExecutionEnvironment env, boolean bathXync, S
                 "'" + username + "'" + "," + "'password'=" + "'" + password + "'" + "," + "'base-url'=" + "'" + url + "'" + ")";
         // Move data from LakeSoul to MySQL
         tEnvs.executeSql(createCatalog);
-        String insertQuery = "INSERT INTO postgres_catalog.`" + targetDatabase+ "`.`" + targetTableName +
-                "` SELECT * FROM lakeSoul.`"  +sourceDatabase + "`.`" + sourceTableName + "`";
+        String insertQuery = "INSERT INTO postgres_catalog.`" + targetDatabase + "`.`" + targetTableName +
+                "` SELECT * FROM lakeSoul.`" + sourceDatabase + "`.`" + sourceTableName + "`";
 
         tEnvs.executeSql(insertQuery);
         statement.close();
@@ -243,21 +241,21 @@ public static void xsyncToMysql(StreamExecutionEnvironment env, boolean batchXyn
         StringBuilder coulmns = new StringBuilder();
         for (int i = 0; i < mysqlFieldTypes.length; i++) {
             coulmns.append("`").append(fieldNames[i]).append("` ").append(mysqlFieldTypes[i]);
-            if (i< fieldDataTypes.length-1){
+            if (i < fieldDataTypes.length - 1) {
                 coulmns.append(",");
             }
         }
         String sql;
-        if (tablePk!=null){
+        if (tablePk != null) {
             sql = String.format(
                     "create table %s(%s ,PRIMARY KEY (%s) NOT ENFORCED) with ('connector' = '%s', 'url' = '%s', 'table-name' = '%s', 'username' = '%s', 'password' = '%s')",
                     targetTableName, coulmns, tablePk, "jdbc", jdbcUrl, targetTableName, username, password);
-        }else {
+        } else {
             sql = String.format("create table %s(%s) with ('connector' = '%s', 'url' = '%s', 'table-name' = '%s', 'username' = '%s', 'password' = '%s')",
                     targetTableName, coulmns, "jdbc", jdbcUrl, targetTableName, username, password);
         }
         tEnvs.executeSql(sql);
-        tEnvs.executeSql("insert into "+targetTableName+" select * from lakeSoul.`"+sourceDatabase+"`."+sourceTableName);
+        tEnvs.executeSql("insert into " + targetTableName + " select * from lakeSoul.`" + sourceDatabase + "`." + sourceTableName);
 
         statement.close();
         conn.close();
@@ -284,7 +282,7 @@ public static void xsyncToDoris(StreamExecutionEnvironment env, boolean batchXyn
         StringBuilder coulmns = new StringBuilder();
         for (int i = 0; i < fieldDataTypes.length; i++) {
             coulmns.append("`").append(fieldNames[i]).append("` ").append(dorisFieldTypes[i]);
-            if (i< fieldDataTypes.length-1){
+            if (i < fieldDataTypes.length - 1) {
                 coulmns.append(",");
             }
         }
@@ -292,6 +290,6 @@ public static void xsyncToDoris(StreamExecutionEnvironment env, boolean batchXyn
                 "create table %s(%s) with ('connector' = '%s', 'jdbc-url' = '%s', 'fenodes' = '%s', 'table.identifier' = '%s', 'username' = '%s', 'password' = '%s')",
                 targetTableName, coulmns, "doris", jdbcUrl, fenodes, targetDatabase + "." + targetTableName, username, password);
         tEnvs.executeSql(sql);
-        tEnvs.executeSql("insert into "+targetTableName+" select * from lakeSoul.`"+sourceDatabase+"`."+sourceTableName);
+        tEnvs.executeSql("insert into " + targetTableName + " select * from lakeSoul.`" + sourceDatabase + "`." + sourceTableName);
     }
 }
\ No newline at end of file