Added dlink-app module code style. (#899)

dlink-app/dlink-app-1.11/src/main/java/com/dlink/app/MainApp.java

@@ -17,7 +17,6 @@
  *
  */
 
-
 package com.dlink.app;
 
 import com.dlink.app.db.DBConfig;

dlink-app/dlink-app-1.12/src/main/java/com/dlink/app/MainApp.java

@@ -17,7 +17,6 @@
  *
  */
 
-
 package com.dlink.app;
 
 import com.dlink.app.db.DBConfig;

dlink-app/dlink-app-1.13/src/main/java/com/dlink/app/MainApp.java

@@ -17,7 +17,6 @@
  *
  */
 
-
 package com.dlink.app;
 
 import com.dlink.app.db.DBConfig;

dlink-app/dlink-app-1.14/src/main/java/com/dlink/app/MainApp.java

@@ -17,7 +17,6 @@
  *
  */
 
-
 package com.dlink.app;
 
 import com.dlink.app.db.DBConfig;

dlink-app/dlink-app-1.15/src/main/java/com/dlink/app/MainApp.java

@@ -17,7 +17,6 @@
  *
  */
 
-
 package com.dlink.app;
 
 import java.io.IOException;

dlink-app/dlink-app-base/src/main/java/com/dlink/app/db/DBConfig.java

@@ -17,7 +17,6 @@
  *
  */
 
-
 package com.dlink.app.db;
 
 import com.dlink.constant.FlinkParamConstant;
@@ -48,7 +47,6 @@ public class DBConfig {
         return new DBConfig(driver, url, username, password);
     }
 
-
     public static DBConfig build(Map<String, String> params) {
         return new DBConfig(params.get(FlinkParamConstant.DRIVER),
                 params.get(FlinkParamConstant.URL),
@@ -74,11 +72,11 @@ public class DBConfig {
 
     @Override
     public String toString() {
-        return "DBConfig{" +
-                "driver='" + driver + '\'' +
-                ", url='" + url + '\'' +
-                ", username='" + username + '\'' +
-                ", password='" + password + '\'' +
-                '}';
+        return "DBConfig{"
+                + "driver='" + driver + '\''
+                + ", url='" + url + '\''
+                + ", username='" + username + '\''
+                + ", password='" + password + '\''
+                + '}';
     }
 }

dlink-app/dlink-app-base/src/main/java/com/dlink/app/db/DBUtil.java

@@ -17,11 +17,14 @@
  *
  */
 
-
 package com.dlink.app.db;
 
 import java.io.IOException;
-import java.sql.*;
+import java.sql.Connection;
+import java.sql.DriverManager;
+import java.sql.ResultSet;
+import java.sql.SQLException;
+import java.sql.Statement;
 import java.util.ArrayList;
 import java.util.HashMap;
 import java.util.List;

dlink-app/dlink-app-base/src/main/java/com/dlink/app/flinksql/StatementParam.java

@@ -17,7 +17,6 @@
  *
  */
 
-
 package com.dlink.app.flinksql;
 
 import com.dlink.parser.SqlType;

dlink-app/dlink-app-base/src/main/java/com/dlink/app/flinksql/Submiter.java

@@ -17,7 +17,6 @@
  *
  */
 
-
 package com.dlink.app.flinksql;
 
 import com.dlink.app.db.DBConfig;
@@ -29,14 +28,21 @@ import com.dlink.executor.ExecutorSetting;
 import com.dlink.interceptor.FlinkInterceptor;
 import com.dlink.parser.SqlType;
 import com.dlink.trans.Operations;
+
 import org.apache.flink.configuration.CheckpointingOptions;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
 
 import java.io.IOException;
 import java.sql.SQLException;
 import java.time.LocalDateTime;
-import java.util.*;
+import java.util.ArrayList;
+import java.util.Arrays;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.UUID;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 
 /**
  * FlinkSQLFactory
@@ -59,9 +65,9 @@ public class Submiter {
         if (id == null) {
             throw new SQLException("请指定任务ID");
         }
-        return "select id, name, alias as jobName, type,check_point as checkpoint," +
-                "save_point_path as savePointPath, parallelism,fragment as useSqlFragment,statement_set as useStatementSet,config_json as config," +
-                " env_id as envId,batch_model AS useBatchModel from dlink_task where id = " + id;
+        return "select id, name, alias as jobName, type,check_point as checkpoint,"
+                + "save_point_path as savePointPath, parallelism,fragment as useSqlFragment,statement_set as useStatementSet,config_json as config,"
+                + " env_id as envId,batch_model AS useBatchModel from dlink_task where id = " + id;
     }
 
     private static String getFlinkSQLStatement(Integer id, DBConfig config) {