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

DBZ-1297 Add boolean type in test

Browse Source
This commit is contained in:
Laurent Broudoux 2021-10-01 17:14:40 +02:00 committed by Gunnar Morling
parent 8fbbe5887a
commit 77eaa0a293
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
debezium-core/src/test/java/io/debezium/transforms/outbox/EventRouterTest.java
View File

@ -911,7 +911,7 @@ public void canExpandJSONPayloadIfConfigured() {
"UserCreated",
"10711fa5",
"User",
"{\"fullName\": \"John Doe\", \"rating\": 4.9, \"age\": 42, \"pets\": [\"dog\", \"cat\"]}",
"{\"fullName\": \"John Doe\", \"enabled\": true, \"rating\": 4.9, \"age\": 42, \"pets\": [\"dog\", \"cat\"]}",
new HashMap<>(),
new HashMap<>());
final SourceRecord eventRouted = router.apply(eventRecord);
@ -921,14 +921,16 @@ public void canExpandJSONPayloadIfConfigured() {
Schema valueSchema = eventRouted.valueSchema();
assertThat(valueSchema.type()).isEqualTo(SchemaBuilder.struct().type());
assertThat(valueSchema.fields().size()).isEqualTo(4);
assertThat(valueSchema.fields().size()).isEqualTo(5);
assertThat(valueSchema.field("fullName").schema().type().getName()).isEqualTo("string");
assertThat(valueSchema.field("enabled").schema().type().getName()).isEqualTo("boolean");
assertThat(valueSchema.field("rating").schema().type().getName()).isEqualTo("float64");
assertThat(valueSchema.field("age").schema().type().getName()).isEqualTo("int32");
assertThat(valueSchema.field("pets").schema().type().getName()).isEqualTo("array");
Struct valueStruct = (Struct) eventRouted.value();
assertThat(valueStruct.get("fullName")).isEqualTo("John Doe");
assertThat(valueStruct.get("enabled")).isEqualTo(true);
assertThat(valueStruct.get("rating")).isEqualTo(4.9);
assertThat(valueStruct.get("age")).isEqualTo(42);
assertThat(valueStruct.getArray("pets").size()).isEqualTo(2);