From 4c9cf718ceb525f76da1fa4700a6e39bf964ebd8 Mon Sep 17 00:00:00 2001
From: duxinglangzi <871364441@qq.com>
Date: 星期五, 24 六月 2022 16:40:03 +0800
Subject: [PATCH] 增加动态参数配置
---
README.md | 17 +++++++++++++++--
1 files changed, 15 insertions(+), 2 deletions(-)
diff --git a/README.md b/README.md
index d1afc37..30e716e 100644
--- a/README.md
+++ b/README.md
@@ -16,6 +16,9 @@
zookeeper-address: # zookeeper 鍦板潃(寮�鍚泦缇ょ殑鎯呭喌涓嬬敓鏁�), 渚�: 192.168.0.1:2181,192.168.0.2:2181,192.168.0.3:2181
acquire-interval: 1000 # 鏈媺鍙栧埌娑堟伅鎯呭喌涓�,鑾峰彇娑堟伅鐨勬椂闂撮棿闅旀绉掑��
subscribe: .*\\..* # 榛樿鎯呭喌涓嬫媺鍙栨墍鏈夊簱銆佹墍鏈夎〃
+ prod:
+ example: example1
+ database: books
```
@@ -38,9 +41,19 @@
public class CanalListenerTest {
/**
- * 鐩墠 Listener 鏂规硶鐨勫弬鏁板繀椤讳负 CanalEntry.EventType eventType, CanalEntry.RowData rowData
+ * 鐩墠 Listener 鏂规硶鐨勫弬鏁板繀椤讳负 CanalEntry.EventType , CanalEntry.RowData
* 绋嬪簭鍦ㄥ惎鍔ㄨ繃绋嬩腑浼氬仛妫�鏌�
*/
+
+ /**
+ * 鐩戞帶鏇存柊鎿嶄綔
+ * 鏀寔鍔ㄦ�佸弬鏁伴厤缃紝閰嶇疆椤归渶鍦� yml 鎴� properties 杩涜閰嶇疆
+ * 鐩爣鏄� ${prod.example} 鐨� ${prod.database} 搴� users琛�
+ */
+ @CanalUpdateListener(destination = "${prod.example}", database = "${prod.database}", table = {"users"})
+ public void listenerExampleBooksUsers(CanalEntry.EventType eventType, CanalEntry.RowData rowData) {
+ printChange("listenerExampleBooksUsers",eventType, rowData);
+ }
/**
* 鐩戞帶鏇存柊鎿嶄綔 锛岀洰鏍囨槸 example鐨� books搴� users琛�
@@ -84,7 +97,7 @@
public void printChange(String method,CanalEntry.EventType eventType, CanalEntry.RowData rowData) {
if (eventType == CanalEntry.EventType.DELETE) {
- rowData.getAfterColumnsList().stream().collect(Collectors.toList()).forEach(ele -> {
+ rowData.getBeforeColumnsList().stream().collect(Collectors.toList()).forEach(ele -> {
System.out.println("[鏂规硶: "+method+" , delete 璇彞 ] --->> 瀛楁鍚�: " + ele.getName() + ", 鍒犻櫎鐨勫�间负: " + ele.getValue());
});
}
--
Gitblit v1.8.0