Use RecordWrapper

memiiso · Oct 5, 2024 · 3c678ea · 3c678ea
1 parent 612775a
commit 3c678ea
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/...sink/src/test/java/io/debezium/server/iceberg/tableoperator/IcebergTableOperatorTest.java b/...sink/src/test/java/io/debezium/server/iceberg/tableoperator/IcebergTableOperatorTest.java
@@ -14,6 +14,7 @@
 import io.debezium.server.iceberg.testresources.BaseSparkTest;
 import io.debezium.server.iceberg.testresources.IcebergChangeEventBuilder;
 import io.debezium.server.iceberg.testresources.S3Minio;
+import io.debezium.server.iceberg.testresources.SourcePostgresqlDB;
 import io.quarkus.test.common.WithTestResource;
 import io.quarkus.test.junit.QuarkusTest;
 import jakarta.inject.Inject;
@@ -39,6 +40,7 @@
  */
 @QuarkusTest
 @WithTestResource(value = S3Minio.class)
+@WithTestResource(value = SourcePostgresqlDB.class)
 class IcebergTableOperatorTest extends BaseSparkTest {
 
   static String testTable = "inventory.test_table_operator";
@@ -69,6 +71,7 @@ public void testIcebergTableOperator() {
             .destination(testTable)
             .addKeyField("id", 1)
             .addField("data", "record1")
+            .addField("__op", "c")
             .addField("preferences", "feature1", true)
             .build()
     );
@@ -77,17 +80,20 @@ public void testIcebergTableOperator() {
         .destination(testTable)
         .addKeyField("id", 1)
         .addField("data", "record1")
+        .addField("__op", "c")
         .build()
     );
     events.add(new IcebergChangeEventBuilder()
         .destination(testTable)
         .addKeyField("id", 2)
         .addField("data", "record2")
+        .addField("__op", "c")
         .build()
     );
     events.add(new IcebergChangeEventBuilder()
         .destination(testTable)
         .addKeyField("id", 3)
+        .addField("__op", "c")
         .addField("user_name", "Alice")
         .addField("data", "record3_adding_field")
         .build()