Browse Source

添加dml过滤判断

修复parseRowsEvent方法中没有dml过滤的判断而导致dml操作的数据总是会输出到store中的bug
zhangyukun 9 years ago
parent
commit
6b9c1305ff

+ 3 - 0
parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/dbsync/LogEventConvert.java

@@ -305,6 +305,9 @@ public class LogEventConvert extends AbstractCanalLifeCycle implements BinlogPar
     }
     }
 
 
     private Entry parseRowsEvent(RowsLogEvent event) {
     private Entry parseRowsEvent(RowsLogEvent event) {
+        if (filterQueryDml) {
+            return null;
+        }
         try {
         try {
             TableMapLogEvent table = event.getTable();
             TableMapLogEvent table = event.getTable();
             if (table == null) {
             if (table == null) {