'commit'

pom.xml

@@ -284,6 +284,14 @@
             <artifactId>jjwt</artifactId>
             <version>0.7.0</version>
         </dependency>
+
+        <!-- https://mvnrepository.com/artifact/com.zendesk/mysql-binlog-connector-java -->
+        <dependency>
+            <groupId>com.zendesk</groupId>
+            <artifactId>mysql-binlog-connector-java</artifactId>
+            <version>0.30.1</version>
+        </dependency>
+
     </dependencies>
     <build>
         <plugins>

src/main/java/com/dsideal/base/DataEase/Model/DataEaseModel.java

@@ -81,7 +81,7 @@ public class DataEaseModel {
                 } else if (colName.equals("上级行政区划")) {
                     record.set(colName, parent_area_name);
                 } else {
-                    if (StrKit.isBlank(value.trim()) && colName.equals("数值")) {
+                    if (StrKit.isBlank(value.trim()) && colName.contains("数值")) {
                         record.set(colName, 0);
                     } else if (isInteger(value)) {
                         record.set(colName, Integer.parseInt(value));

src/main/java/com/dsideal/base/Test/TestBinLog.java

@@ -0,0 +1,27 @@
+package com.dsideal.base.Test;
+
+import com.github.shyiko.mysql.binlog.BinaryLogClient;
+import com.github.shyiko.mysql.binlog.event.Event;
+import com.github.shyiko.mysql.binlog.event.deserialization.EventDeserializer;
+
+import java.io.IOException;
+
+//https://github.com/osheroff/mysql-binlog-connector-java
+public class TestBinLog {
+    public static void main(String[] args) throws IOException {
+        BinaryLogClient client = new BinaryLogClient("10.10.14.203", 3306, "root", "Password123@mysql");
+        EventDeserializer eventDeserializer = new EventDeserializer();
+        eventDeserializer.setCompatibilityMode(
+                EventDeserializer.CompatibilityMode.DATE_AND_TIME_AS_LONG,
+                EventDeserializer.CompatibilityMode.CHAR_AND_BINARY_AS_BYTE_ARRAY
+        );
+        client.setEventDeserializer(eventDeserializer);
+        client.registerEventListener(new BinaryLogClient.EventListener() {
+
+            @Override
+            public void onEvent(Event event) {
+            }
+        });
+        client.connect();
+    }
+}