代码优化

dbsyncer-parser/src/main/java/org/dbsyncer/parser/flush/impl/GeneralBufferActuator.java

@@ -98,10 +98,10 @@ public class GeneralBufferActuator extends AbstractBufferActuator<WriterRequest,
     @Override
     protected void partition(WriterRequest request, WriterResponse response) {
         if (!CollectionUtils.isEmpty(request.getRow())) {
-            response.getDataList().add(request.getRow());
+            response.addRow(request.getRow());
         }
         if (request.getChangedOffset() != null) {
-            response.getOffsetList().add(request.getChangedOffset());
+            response.addChangedOffset(request.getChangedOffset());
         }
         if (!response.isMerged()) {
             response.setTableGroupId(request.getTableGroupId());

dbsyncer-parser/src/main/java/org/dbsyncer/parser/model/AbstractWriter.java

@@ -1,5 +1,7 @@
 package org.dbsyncer.parser.model;
 
+import org.dbsyncer.sdk.enums.ChangedEventTypeEnum;
+
 /**
  * @author AE86
  * @version 1.0.0
@@ -7,10 +9,22 @@ package org.dbsyncer.parser.model;
  */
 public abstract class AbstractWriter {
 
+    private ChangedEventTypeEnum typeEnum;
+
     private String tableGroupId;
 
     private String event;
 
+    private String sql;
+
+    public ChangedEventTypeEnum getTypeEnum() {
+        return typeEnum;
+    }
+
+    public void setTypeEnum(ChangedEventTypeEnum typeEnum) {
+        this.typeEnum = typeEnum;
+    }
+
     public String getTableGroupId() {
         return tableGroupId;
     }
@@ -26,4 +40,13 @@ public abstract class AbstractWriter {
     public void setEvent(String event) {
         this.event = event;
     }
+
+    public String getSql() {
+        return sql;
+    }
+
+    public void setSql(String sql) {
+        this.sql = sql;
+    }
+
 }

dbsyncer-parser/src/main/java/org/dbsyncer/parser/model/WriterRequest.java

@@ -1,7 +1,6 @@
 package org.dbsyncer.parser.model;
 
 import org.dbsyncer.parser.flush.BufferRequest;
-import org.dbsyncer.sdk.enums.ChangedEventTypeEnum;
 import org.dbsyncer.sdk.listener.ChangedEvent;
 import org.dbsyncer.sdk.model.ChangedOffset;
 
@@ -14,21 +13,17 @@ import java.util.Map;
  */
 public class WriterRequest extends AbstractWriter implements BufferRequest {
 
-    private ChangedEventTypeEnum typeEnum;
-
     private Map row;
 
     private ChangedOffset changedOffset;
 
-    private String sql;
-
     public WriterRequest(String tableGroupId, ChangedEvent event) {
+        setTypeEnum(event.getType());
         setTableGroupId(tableGroupId);
         setEvent(event.getEvent());
-        this.typeEnum = event.getType();
+        setSql(event.getSql());
         this.row = event.getChangedRow();
         this.changedOffset = event.getChangedOffset();
-        this.sql = event.getSql();
     }
 
     @Override
@@ -36,10 +31,6 @@ public class WriterRequest extends AbstractWriter implements BufferRequest {
         return changedOffset.getMetaId();
     }
 
-    public ChangedEventTypeEnum getTypeEnum() {
-        return typeEnum;
-    }
-
     public Map getRow() {
         return row;
     }
@@ -48,7 +39,4 @@ public class WriterRequest extends AbstractWriter implements BufferRequest {
         return changedOffset;
     }
 
-    public String getSql() {
-        return sql;
-    }
 }

dbsyncer-parser/src/main/java/org/dbsyncer/parser/model/WriterResponse.java

@@ -1,9 +1,8 @@
 package org.dbsyncer.parser.model;
 
-import org.dbsyncer.sdk.enums.ChangedEventTypeEnum;
-import org.dbsyncer.sdk.model.ChangedOffset;
 import org.dbsyncer.common.util.StringUtil;
 import org.dbsyncer.parser.flush.BufferResponse;
+import org.dbsyncer.sdk.model.ChangedOffset;
 
 import java.util.LinkedList;
 import java.util.List;
@@ -16,14 +15,10 @@ import java.util.Map;
  */
 public class WriterResponse extends AbstractWriter implements BufferResponse {
 
-    private ChangedEventTypeEnum typeEnum;
-
     private List<Map> dataList = new LinkedList<>();
 
     private List<ChangedOffset> offsetList = new LinkedList<>();
 
-    private String sql;
-
     private boolean isMerged;
 
     @Override
@@ -36,12 +31,12 @@ public class WriterResponse extends AbstractWriter implements BufferResponse {
         return StringUtil.SYMBOL.concat(getEvent());
     }
 
-    public ChangedEventTypeEnum getTypeEnum() {
-        return typeEnum;
+    public void addRow(Map row){
+        dataList.add(row);
     }
 
-    public void setTypeEnum(ChangedEventTypeEnum typeEnum) {
-        this.typeEnum = typeEnum;
+    public void addChangedOffset(ChangedOffset changedOffset){
+        offsetList.add(changedOffset);
     }
 
     public List<Map> getDataList() {
@@ -52,14 +47,6 @@ public class WriterResponse extends AbstractWriter implements BufferResponse {
         return offsetList;
     }
 
-    public String getSql() {
-        return sql;
-    }
-
-    public void setSql(String sql) {
-        this.sql = sql;
-    }
-
     public boolean isMerged() {
         return isMerged;
     }