修复 @CanalEventListener 仅指定 schema 或 table 服务映射方法的 BUG

buession · Nov 20, 2023 · 9b89e77 · 9b89e77
1 parent 4570630
commit 9b89e77
Show file tree

Hide file tree

Showing 3 changed files with 13 additions and 3 deletions.
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -9,6 +9,12 @@
 - [依赖库版本升级和安全漏洞修复](https://github.com/buession/buession-parent/releases/tag/v2.3.2)
 
 
+### 🐞 Bug 修复
+
+- **buession-canal-core：** 修复 buession-beans bean 转换导致的数据丢失的 BUG
+- **buession-canal-core：** 修复 @CanalEventListener 仅指定 schema 或 table 服务映射方法的 BUG
+
+
 ---
 
 

diff --git a/...n-canal-core/src/main/java/com/buession/canal/core/listener/utils/EventListenerUtils.java b/...n-canal-core/src/main/java/com/buession/canal/core/listener/utils/EventListenerUtils.java
@@ -45,9 +45,13 @@ public static String buildEventListenerName(final String destination, final Stri
 
 		sb.append(destination).append("$$");
 		if(Validate.hasText(schema) && Validate.hasText(table)){
-			sb.append(schema).append('.').append(table).append("$$");
+			sb.append(schema).append('.').append(table);
+		}else if(Validate.hasText(schema)){
+			sb.append("schema:").append(schema);
+		}else if(Validate.hasText(table)){
+			sb.append("table:").append(table);
 		}
-		sb.append(eventType.name());
+		sb.append("$$").append(eventType.name());
 
 		return sb.toString();
 	}

diff --git a/buession-canal-parent/pom.xml b/buession-canal-parent/pom.xml
@@ -61,7 +61,7 @@
 	</modules>
 
 	<properties>
-		<buession.version>2.3.1</buession.version>
+		<buession.version>2.3.2</buession.version>
 		<alibaba.canal.version>1.1.7</alibaba.canal.version>
 	</properties>