executor format

dlink-executor/src/main/java/com/dlink/parser/BaseSingleSqlParser.java

@@ -39,11 +39,11 @@ public abstract class BaseSingleSqlParser {
     /**
      * 将originalSql劈分成一个个片段
      **/
-    protected Map<String,List<String>> splitSql2Segment() {
-        Map<String,List<String>> map = new HashMap<>();
+    protected Map<String, List<String>> splitSql2Segment() {
+        Map<String, List<String>> map = new HashMap<>();
         for (SqlSegment sqlSegment : segments) {
             sqlSegment.parse(originalSql);
-            if(Asserts.isNotNullString(sqlSegment.getStart())) {
+            if (Asserts.isNotNullString(sqlSegment.getStart())) {
 //                map.put(sqlSegment.getStart().toUpperCase(), sqlSegment.getBodyPieces());
                 map.put(sqlSegment.getType().toUpperCase(), sqlSegment.getBodyPieces());
             }

dlink-executor/src/main/java/com/dlink/parser/CreateCDCSourceSqlParser.java

@@ -14,7 +14,7 @@ public class CreateCDCSourceSqlParser extends BaseSingleSqlParser {
 
     @Override
     protected void initializeSegments() {
-        segments.add(new SqlSegment("CDCSOURCE","(execute\\s+cdcsource\\s+)(.+)(\\s+with\\s+\\()", "[,]"));
-        segments.add(new SqlSegment("WITH","(with\\s+\\()(.+)(\\))", "[,]"));
+        segments.add(new SqlSegment("CDCSOURCE", "(execute\\s+cdcsource\\s+)(.+)(\\s+with\\s+\\()", "[,]"));
+        segments.add(new SqlSegment("WITH", "(with\\s+\\()(.+)(\\))", "[,]"));
     }
 }

dlink-executor/src/main/java/com/dlink/parser/SqlSegment.java

@@ -82,7 +82,7 @@ public class SqlSegment {
             start = matcher.group(1);
             body = matcher.group(2);
             end = matcher.group(3);
-            if(Asserts.isNullString(type)) {
+            if (Asserts.isNullString(type)) {
                 type = start.replace("\n", " ").replaceAll("\\s{1,}", " ").toUpperCase();
             }
             parseBody();

dlink-executor/src/main/java/com/dlink/trans/ddl/AggTable.java

@@ -31,19 +31,19 @@ public class AggTable {
         this.aggBy = aggBy;
     }
 
-    public static AggTable build(String statement){
-        Map<String,List<String>> map = SingleSqlParserFactory.generateParser(statement);
+    public static AggTable build(String statement) {
+        Map<String, List<String>> map = SingleSqlParserFactory.generateParser(statement);
         return new AggTable(statement,
-                getString(map,"CREATE AGGTABLE"),
-                getString(map,"SELECT"),
-                getString(map,"FROM"),
+                getString(map, "CREATE AGGTABLE"),
+                getString(map, "SELECT"),
+                getString(map, "FROM"),
                 map.get("WHERE"),
-                getString(map,"GROUP BY"),
-                getString(map,"AGG BY"));
+                getString(map, "GROUP BY"),
+                getString(map, "AGG BY"));
     }
 
-    private static String getString(Map<String,List<String>> map,String key){
-        return StringUtils.join(map.get(key),",");
+    private static String getString(Map<String, List<String>> map, String key) {
+        return StringUtils.join(map.get(key), ",");
     }
 
     public String getStatement() {