From 485237ec55ed932aaf13c3f24fa28c0348419841 Mon Sep 17 00:00:00 2001
From: cmg <527198563@qq.com>
Date: 星期二, 23 四月 2024 16:12:54 +0800
Subject: [PATCH] 标准产品初始化
---
README.md | 16 ++++++++--------
1 files changed, 8 insertions(+), 8 deletions(-)
diff --git a/README.md b/README.md
index 2877874..94b83cb 100644
--- a/README.md
+++ b/README.md
@@ -28,11 +28,11 @@
import com.alibaba.otter.canal.protocol.CanalEntry;
-import com.duxinglangzi.canal.starter.annotation.CanalInsertListener;
-import com.duxinglangzi.canal.starter.annotation.CanalListener;
-import com.duxinglangzi.canal.starter.annotation.CanalUpdateListener;
-import com.duxinglangzi.canal.starter.annotation.EnableCanalListener;
-import com.duxinglangzi.canal.starter.mode.CanalMessage;
+import CanalInsertListener;
+import CanalListener;
+import CanalUpdateListener;
+import EnableCanalListener;
+import CanalMessage;
import org.springframework.stereotype.Service;
import java.util.stream.Collectors;
@@ -48,7 +48,7 @@
/**
* 蹇呴』鍦ㄧ被涓� 浣跨敤 EnableCanalListener 娉ㄨВ鎵嶈兘寮�鍚� canal listener
*
- * 鐩墠 Listener 鏂规硶鐨勫弬鏁板繀椤讳负 com.duxinglangzi.canal.starter.mode.CanalMessage
+ * 鐩墠 Listener 鏂规硶鐨勫弬鏁板繀椤讳负 CanalMessage
* 绋嬪簭鍦ㄥ惎鍔ㄨ繃绋嬩腑浼氬仛妫�鏌�
*/
@@ -107,9 +107,9 @@
CanalEntry.RowData rowData = message.getRowData();
- System.out.println(" >>>>>>>>>>>>>[褰撳墠鏁版嵁搴�: "+message.getDataBaseName()+" ," +
+ System.out.println(" >>>>>>>>>>>>>[褰撳墠鏁版嵁搴�: " + message.getDataBaseName() + " ," +
"鏁版嵁搴撹〃鍚�: " + message.getTableName() + " , " +
- "鏂规硶: " + method );
+ "鏂规硶: " + method);
if (eventType == CanalEntry.EventType.DELETE) {
rowData.getBeforeColumnsList().stream().collect(Collectors.toList()).forEach(ele -> {
--
Gitblit v1.8.0