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

DBZ-1414 Fix test for correct DDL output

Browse Source
This commit is contained in:
Jiri Pechanec 2019-08-06 07:37:42 +02:00 committed by Gunnar Morling
parent 93fc39d92c
commit 6276b4817a
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
debezium-connector-mysql/src/test/java/io/debezium/connector/mysql/ZZZGtidSetIT.java
View File

@ -196,11 +196,11 @@ public void shouldProcessPurgedLogsWhenDownAndSnapshotNeeded() throws SQLExcepti
}
purgeDatabaseLogs();
start(MySqlConnector.class, config);
// SET + DROP/CREATE/USE DB + DROP/CREATE 4 tables + 1 additional DROP whitelisted table + 8 data
records = consumeRecordsByTopic(1 + 3 + 2 * 4 + 1 + 8);
// SET + DROP/CREATE/USE DB + DROP/CREATE 4 tables + 8 data
records = consumeRecordsByTopic(1 + 3 + 2 * 4 + 8);
assertThat(records.recordsForTopic(database.topicForTable("customers")).size()).isEqualTo(8);
assertThat(records.topics().size()).isEqualTo(1 + 1);
assertThat(records.ddlRecordsForDatabase(database.getDatabaseName()).size()).isEqualTo(12);
assertThat(records.ddlRecordsForDatabase(database.getDatabaseName()).size()).isEqualTo(11);
stopConnector();
try (MySQLConnection db = MySQLConnection.forTestDatabase(database.getDatabaseName())) {
@ -217,11 +217,11 @@ public void shouldProcessPurgedLogsWhenDownAndSnapshotNeeded() throws SQLExcepti
);
}
start(MySqlConnector.class, config);
// SET + DROP/CREATE/USE DB + DROP/CREATE 4 tables + 1 additional DROP whitelisted table + 8 data
records = consumeRecordsByTopic(1 + 3 + 2 * 4 + 1 + 12);
// SET + DROP/CREATE/USE DB + DROP/CREATE 4 tables + 8 data
records = consumeRecordsByTopic(1 + 3 + 2 * 4 + 12);
assertThat(records.recordsForTopic(database.topicForTable("customers")).size()).isEqualTo(12);
assertThat(records.topics().size()).isEqualTo(1 + 1);
assertThat(records.ddlRecordsForDatabase(database.getDatabaseName()).size()).isEqualTo(12);
assertThat(records.ddlRecordsForDatabase(database.getDatabaseName()).size()).isEqualTo(11);
stopConnector();
}
}