Remove mongodb java driver from dependencies, use upstream driver (#507)

* Remove java driver from dependencies, use upstream driver * Fix naming, Mangodb to Mongodb
memiiso · Feb 21, 2025 · 81e7962 · 81e7962
1 parent 9cbfd48
commit 81e7962
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 11 deletions.
diff --git a/debezium-server-iceberg-sink/pom.xml b/debezium-server-iceberg-sink/pom.xml
@@ -304,12 +304,6 @@
             <artifactId>minio</artifactId>
             <scope>test</scope>
         </dependency>
-        <dependency>
-            <groupId>org.mongodb</groupId>
-            <artifactId>mongo-java-driver</artifactId>
-            <version>3.12.14</version>
-            <scope>test</scope>
-        </dependency>
         <dependency>
             <groupId>io.debezium</groupId>
             <artifactId>debezium-connector-postgres</artifactId>

diff --git a/...erg/IcebergChangeConsumerMangodbTest.java → ...erg/IcebergChangeConsumerMongodbTest.java b/...erg/IcebergChangeConsumerMangodbTest.java → ...erg/IcebergChangeConsumerMongodbTest.java
@@ -11,7 +11,7 @@
 import io.debezium.server.iceberg.testresources.BaseSparkTest;
 import io.debezium.server.iceberg.testresources.CatalogJdbc;
 import io.debezium.server.iceberg.testresources.S3Minio;
-import io.debezium.server.iceberg.testresources.SourceMangoDB;
+import io.debezium.server.iceberg.testresources.SourceMongoDB;
 import io.quarkus.test.common.QuarkusTestResource;
 import io.quarkus.test.junit.QuarkusTest;
 import io.quarkus.test.junit.QuarkusTestProfile;
@@ -31,10 +31,10 @@
  */
 @QuarkusTest
 @QuarkusTestResource(value = S3Minio.class, restrictToAnnotatedClass = true)
-@QuarkusTestResource(value = SourceMangoDB.class, restrictToAnnotatedClass = true)
+@QuarkusTestResource(value = SourceMongoDB.class, restrictToAnnotatedClass = true)
 @QuarkusTestResource(value = CatalogJdbc.class, restrictToAnnotatedClass = true)
-@TestProfile(IcebergChangeConsumerMangodbTest.TestProfile.class)
-public class IcebergChangeConsumerMangodbTest extends BaseSparkTest {
+@TestProfile(IcebergChangeConsumerMongodbTest.TestProfile.class)
+public class IcebergChangeConsumerMongodbTest extends BaseSparkTest {
 
   @Test
   public void testSimpleUpload() {

diff --git a/.../iceberg/testresources/SourceMangoDB.java → .../iceberg/testresources/SourceMongoDB.java b/.../iceberg/testresources/SourceMangoDB.java → .../iceberg/testresources/SourceMongoDB.java
@@ -19,7 +19,7 @@
 import org.testcontainers.containers.wait.strategy.Wait;
 import org.testcontainers.images.builder.ImageFromDockerfile;
 
-public class SourceMangoDB implements QuarkusTestResourceLifecycleManager {
+public class SourceMongoDB implements QuarkusTestResourceLifecycleManager {
 
   public static final int MONGODB_PORT = 27017;
   public static final GenericContainer<?> container = new GenericContainer(