alexey.rassokhin/tet123
1
0
Fork 0
Code Issues Pull Requests 1 Packages Projects Releases Wiki Activity

DBZ-1775 Filter out rds_monitor DML events

Browse Source
This commit is contained in:
Jiri Pechanec 2020-02-14 13:59:41 +01:00 committed by Gunnar Morling
parent 8da6c232f4
commit 566efd6a3f
2 changed files with 9 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
debezium-core/src/main/java/io/debezium/relational/history/DatabaseHistory.java
View File

@ -64,6 +64,7 @@ public interface DatabaseHistory {
"INSERT INTO mysql.rds_heartbeat2\\(.*\\) values \\(.*\\) ON DUPLICATE KEY UPDATE value = .*," +
"DELETE FROM mysql.rds_sysinfo.*," +
"INSERT INTO mysql.rds_sysinfo\\(.*\\) values \\(.*\\)," +
"DELETE FROM mysql.rds_monitor.*," +
"FLUSH RELAY LOGS.*," +
"flush relay logs.*," +
"SAVEPOINT .*")

8
debezium-core/src/test/java/io/debezium/config/ConfigurationTest.java
View File

@ -154,6 +154,14 @@ public void defaultDdlFilterShouldFilterOutRdsSysinfoStatements() {
assertThat(ddlFilter.test("INSERT INTO mysql.rds_sysinfo(name, value) values ('innodb_txn_key','Thu Sep 19 19:38:23 UTC 2019')")).isTrue();
}
@Test
@FixFor("DBZ-1775")
public void defaultDdlFilterShouldFilterOutRdsMonitorStatements() {
String defaultDdlFilter = Configuration.create().build().getString(DatabaseHistory.DDL_FILTER);
Predicate<String> ddlFilter = Predicates.includes(defaultDdlFilter);
assertThat(ddlFilter.test("DELETE FROM mysql.rds_monitor")).isTrue();
}
@Test
@FixFor("DBZ-1015")
public void testMsgKeyColumnsField() {