chenjl/canal
1
0
Fork 0
mirror of https://github.com/alibaba/canal.git synced 2026-11-04 00:30:15 +08:00
Code Issues Packages Projects Releases Wiki Activity

Update AbstractMysqlEventParser.java

Browse Source
This commit is contained in:
zhangyukun
2016-02-25 13:56:07 +08:00
parent 652101035e
commit 51cfa7fa96
1 changed files with 6 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/AbstractMysqlEventParser.java
View File

@@ -22,6 +22,7 @@ public abstract class AbstractMysqlEventParser extends AbstractEventParser {
protected boolean filterQueryDcl = false; protected boolean filterQueryDcl = false;
protected boolean filterQueryDml = false; protected boolean filterQueryDml = false;
protected boolean filterQueryDdl = false; protected boolean filterQueryDdl = false;
protected boolean filterRows = false;
protected boolean filterTableError = false; protected boolean filterTableError = false;
protected BinlogParser buildParser() { protected BinlogParser buildParser() {
@@ -38,6 +39,7 @@ public abstract class AbstractMysqlEventParser extends AbstractEventParser {
convert.setFilterQueryDcl(filterQueryDcl); convert.setFilterQueryDcl(filterQueryDcl);
convert.setFilterQueryDml(filterQueryDml); convert.setFilterQueryDml(filterQueryDml);
convert.setFilterQueryDdl(filterQueryDdl); convert.setFilterQueryDdl(filterQueryDdl);
convert.setFilterRows(filterRows);
convert.setFilterTableError(filterTableError); convert.setFilterTableError(filterTableError);
return convert; return convert;
} }
@@ -86,6 +88,10 @@ public abstract class AbstractMysqlEventParser extends AbstractEventParser {
public void setFilterQueryDdl(boolean filterQueryDdl) { public void setFilterQueryDdl(boolean filterQueryDdl) {
this.filterQueryDdl = filterQueryDdl; this.filterQueryDdl = filterQueryDdl;
} }
public void setFilterRows(boolean filterRows) {
this.filterRows = filterRows;
}
public void setFilterTableError(boolean filterTableError) { public void setFilterTableError(boolean filterTableError) {
this.filterTableError = filterTableError; this.filterTableError = filterTableError;