From 652101035eed9e454f324b76abcfc67b1585c065 Mon Sep 17 00:00:00 2001 From: zhangyukun Date: Thu, 25 Feb 2016 11:44:22 +0800 Subject: [PATCH] =?UTF-8?q?=E6=B7=BB=E5=8A=A0Rows=E8=BF=87=E6=BB=A4?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../canal/parse/inbound/mysql/dbsync/LogEventConvert.java | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) diff --git a/parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/dbsync/LogEventConvert.java b/parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/dbsync/LogEventConvert.java index 41d39e27..37ea0d00 100644 --- a/parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/dbsync/LogEventConvert.java +++ b/parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/dbsync/LogEventConvert.java @@ -84,6 +84,8 @@ public class LogEventConvert extends AbstractCanalLifeCycle implements BinlogPar private boolean filterQueryDdl = false; // 是否跳过table相关的解析异常,比如表不存在或者列数量不匹配,issue 92 private boolean filterTableError = false; + // 新增rows过滤，用于仅订阅除rows以外的数据 + private boolean filterRows = false; public Entry parse(LogEvent logEvent) throws CanalParseException { if (logEvent == null || logEvent instanceof UnknownLogEvent) { @@ -305,7 +307,7 @@ public class LogEventConvert extends AbstractCanalLifeCycle implements BinlogPar } private Entry parseRowsEvent(RowsLogEvent event) { - if (filterQueryDml) { + if (filterRows) { return null; } try { @@ -716,5 +718,9 @@ public class LogEventConvert extends AbstractCanalLifeCycle implements BinlogPar public void setFilterTableError(boolean filterTableError) { this.filterTableError = filterTableError; } + + public void setFilterRows(boolean filterRows) { + this.filterRows = filterRows; + } }