commit

src/main/java/com/cxzx/canal/CanalClientMain.java

@@ -155,6 +155,7 @@ public class CanalClientMain {
                 continue;
             }
             var tableName = entry.getHeader().getSchemaName() + "." + entry.getHeader().getTableName();
+            var updateTime = entry.getHeader().getExecuteTime() / 1000;
             //获取操作类型：insert/update/delete类型
             CanalEntry.EventType eventType = rowChage.getEventType();
 
@@ -162,6 +163,7 @@ public class CanalClientMain {
             //获取RowChange对象里的每一行数据，打印出来
             for (CanalEntry.RowData rowData : rowChage.getRowDatasList()) {
                 var logItem = new LogItem();
+                logItem.SetTime((int) updateTime);
                 logItem.PushBack("table_name", tableName);
                 //如果是删除语句
                 if (eventType == CanalEntry.EventType.DELETE) {
@@ -193,7 +195,6 @@ public class CanalClientMain {
 
     private void setColumnUpdate(CanalEntry.RowData rowData, LogItem logItem) {
         var root = new JSONObject();
-
         var oldData = new JSONObject();
         for (CanalEntry.Column column : rowData.getBeforeColumnsList()) {
             oldData.put(column.getName(), column.getValue());