From 8bc1198c9f31a97c96cf5bee0576623d731a2eb9 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E9=BB=84=E6=B5=B7?= <10402852@qq.com>
Date: Fri, 8 Nov 2024 08:24:37 +0800
Subject: [PATCH] 'commit'

---
 pom.xml                                       |  8 ++++++
 .../base/DataEase/Model/DataEaseModel.java    |  2 +-
 .../com/dsideal/base/Test/TestBinLog.java     | 27 +++++++++++++++++++
 3 files changed, 36 insertions(+), 1 deletion(-)
 create mode 100644 src/main/java/com/dsideal/base/Test/TestBinLog.java

diff --git a/pom.xml b/pom.xml
index 31210a58..5120a35c 100644
--- a/pom.xml
+++ b/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>
diff --git a/src/main/java/com/dsideal/base/DataEase/Model/DataEaseModel.java b/src/main/java/com/dsideal/base/DataEase/Model/DataEaseModel.java
index ccc9c84d..4415c173 100644
--- a/src/main/java/com/dsideal/base/DataEase/Model/DataEaseModel.java
+++ b/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));
diff --git a/src/main/java/com/dsideal/base/Test/TestBinLog.java b/src/main/java/com/dsideal/base/Test/TestBinLog.java
new file mode 100644
index 00000000..08b97d67
--- /dev/null
+++ b/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();
+    }
+}