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

DBZ-2979 Fix Oracle tests

Browse Source
This commit is contained in:
Jiri Pechanec 2023-04-19 10:50:14 +02:00
parent 12bec973ff
commit 2181251a9f
1 changed files with 22 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

40
debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/OracleSkipMessagesWithoutChangeConfigIT.java
View File

@ -7,6 +7,7 @@
import static org.assertj.core.api.Assertions.assertThat;
import java.math.BigDecimal;
import java.util.List;
import java.util.concurrent.TimeUnit;
@ -56,11 +57,12 @@ public void after() throws Exception {
@Test
@FixFor("DBZ-2979")
public void shouldSkipEventsWithNoChangeInWhitelistedColumnsWhenSkipEnabled() throws Exception {
public void shouldSkipEventsWithNoChangeInIncludedColumnsWhenSkipEnabled() throws Exception {
String ddl = "CREATE TABLE debezium.test (" +
" id INT NOT NULL, white INT, black INT PRIMARY KEY (id))";
" id INT NOT NULL, white INT, black INT, PRIMARY KEY (id))";
connection.execute(ddl);
connection.execute("ALTER TABLE debezium.test ADD SUPPLEMENTAL LOG DATA (ALL) COLUMNS");
Configuration config = TestHelper.defaultConfig()
.with(OracleConnectorConfig.TABLE_INCLUDE_LIST, "debezium\\.test")
@ -84,23 +86,24 @@ public void shouldSkipEventsWithNoChangeInWhitelistedColumnsWhenSkipEnabled() th
* 1,2,2 (U)
* 1,3,3 (U)
*/
SourceRecords records = consumeRecordsByTopic(5);
SourceRecords records = consumeRecordsByTopic(3);
List<SourceRecord> recordsForTopic = records.recordsForTopic(topicName("test"));
assertThat(recordsForTopic).hasSize(3);
Struct secondMessage = ((Struct) recordsForTopic.get(1).value()).getStruct(Envelope.FieldName.AFTER);
assertThat(secondMessage.get("white")).isEqualTo(2);
assertThat(secondMessage.get("WHITE")).isEqualTo(new BigDecimal("2"));
Struct thirdMessage = ((Struct) recordsForTopic.get(2).value()).getStruct(Envelope.FieldName.AFTER);
assertThat(thirdMessage.get("white")).isEqualTo(3);
assertThat(thirdMessage.get("WHITE")).isEqualTo(new BigDecimal("3"));
}
@Test
@FixFor("DBZ-2979")
public void shouldSkipEventsWithNoChangeInWhitelistedColumnsWhenSkipEnabledWithExcludeConfig() throws Exception {
public void shouldSkipEventsWithNoChangeInIncludedColumnsWhenSkipEnabledWithExcludeConfig() throws Exception {
String ddl = "CREATE TABLE debezium.test (" +
" id INT NOT NULL, white INT, black INT PRIMARY KEY (id))";
" id INT NOT NULL, white INT, black INT, PRIMARY KEY (id))";
connection.execute(ddl);
connection.execute("ALTER TABLE debezium.test ADD SUPPLEMENTAL LOG DATA (ALL) COLUMNS");
Configuration config = TestHelper.defaultConfig()
.with(OracleConnectorConfig.TABLE_INCLUDE_LIST, "debezium\\.test")
@ -124,23 +127,24 @@ public void shouldSkipEventsWithNoChangeInWhitelistedColumnsWhenSkipEnabledWithE
* 1,2,2 (U)
* 1,3,3 (U)
*/
SourceRecords records = consumeRecordsByTopic(5);
SourceRecords records = consumeRecordsByTopic(3);
List<SourceRecord> recordsForTopic = records.recordsForTopic(topicName("test"));
assertThat(recordsForTopic).hasSize(3);
Struct secondMessage = ((Struct) recordsForTopic.get(1).value()).getStruct(Envelope.FieldName.AFTER);
assertThat(secondMessage.get("white")).isEqualTo(2);
assertThat(secondMessage.get("WHITE")).isEqualTo(new BigDecimal("2"));
Struct thirdMessage = ((Struct) recordsForTopic.get(2).value()).getStruct(Envelope.FieldName.AFTER);
assertThat(thirdMessage.get("white")).isEqualTo(3);
assertThat(thirdMessage.get("WHITE")).isEqualTo(new BigDecimal("3"));
}
@Test
@FixFor("DBZ-2979")
public void shouldNotSkipEventsWithNoChangeInWhitelistedColumnsWhenSkipDisabled() throws Exception {
public void shouldNotSkipEventsWithNoChangeInIncludedColumnsWhenSkipDisabled() throws Exception {
String ddl = "CREATE TABLE debezium.test (" +
" id INT NOT NULL, white INT, black INT PRIMARY KEY (id))";
" id INT NOT NULL, white INT, black INT, PRIMARY KEY (id))";
connection.execute(ddl);
connection.execute("ALTER TABLE debezium.test ADD SUPPLEMENTAL LOG DATA (ALL) COLUMNS");
Configuration config = TestHelper.defaultConfig()
.with(OracleConnectorConfig.TABLE_INCLUDE_LIST, "debezium\\.test")
@ -164,19 +168,19 @@ public void shouldNotSkipEventsWithNoChangeInWhitelistedColumnsWhenSkipDisabled(
* 1,2,2 (U)
* 1,3,3 (U)
*/
SourceRecords records = consumeRecordsByTopic(5);
SourceRecords records = consumeRecordsByTopic(4);
List<SourceRecord> recordsForTopic = records.recordsForTopic(topicName("test"));
assertThat(recordsForTopic).hasSize(3);
assertThat(recordsForTopic).hasSize(4);
Struct secondMessage = ((Struct) recordsForTopic.get(1).value()).getStruct(Envelope.FieldName.AFTER);
assertThat(secondMessage.get("white")).isEqualTo(1);
assertThat(secondMessage.get("WHITE")).isEqualTo(new BigDecimal("1"));
Struct thirdMessage = ((Struct) recordsForTopic.get(2).value()).getStruct(Envelope.FieldName.AFTER);
assertThat(thirdMessage.get("white")).isEqualTo(2);
assertThat(thirdMessage.get("WHITE")).isEqualTo(new BigDecimal("2"));
Struct forthMessage = ((Struct) recordsForTopic.get(3).value()).getStruct(Envelope.FieldName.AFTER);
assertThat(forthMessage.get("white")).isEqualTo(3);
assertThat(forthMessage.get("WHITE")).isEqualTo(new BigDecimal("3"));
}
private static String topicName(String tableName) {
return TestHelper.SERVER_NAME + ".DEBEZIUM." + tableName;
return TestHelper.SERVER_NAME + ".DEBEZIUM." + tableName.toUpperCase();
}
}