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

DBZ-4205 Add missing assertions

Browse Source
This commit is contained in:
Jiri Pechanec 2021-12-03 19:06:15 +01:00 committed by Gunnar Morling
parent a516e78d94
commit 39140a07b4
1 changed files with 9 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
debezium-connector-mongodb/src/test/java/io/debezium/connector/mongodb/transforms/ExtractNewDocumentStateTestIT.java
View File

@ -1531,9 +1531,17 @@ public void testAddPatchFieldAfterUpdate() throws Exception {
assertThat(value.schema().fields()).hasSize(3);
}
else {
System.err.println(value.schema().fields());
// 4 data fields + 1 __patch
assertThat(value.schema().fields()).hasSize(4 + 1);
assertThat(value.schema().field("__patch").schema()).isEqualTo(io.debezium.data.Json.builder().optional().build());
assertThat(value.get("__patch")).isNull();
assertThat(value.get("b")).isEqualTo(2);
assertThat(value.schema().field("b").schema()).isEqualTo(SchemaBuilder.OPTIONAL_INT32_SCHEMA);
assertThat(value.get("c")).isEqualTo(3);
assertThat(value.schema().field("c").schema()).isEqualTo(SchemaBuilder.OPTIONAL_INT32_SCHEMA);
}
}