fix

apache · Jun 16, 2023 · 62337c8 · 62337c8
1 parent f7eae1b
commit 62337c8
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 4 deletions.
diff --git a/...tunnel-connector-v2-e2e/connector-cdc-mongodb-e2e/src/test/java/mongodb/MongodbCDCIT.java b/...tunnel-connector-v2-e2e/connector-cdc-mongodb-e2e/src/test/java/mongodb/MongodbCDCIT.java
@@ -45,6 +45,7 @@
 import java.sql.ResultSet;
 import java.sql.SQLException;
 import java.util.ArrayList;
+import java.util.Collections;
 import java.util.List;
 import java.util.Map;
 import java.util.Set;
@@ -99,7 +100,7 @@ private static MySqlContainer createMySqlContainer() {
         mySqlContainer.withUsername(MYSQL_USER_NAME);
         mySqlContainer.withPassword(MYSQL_USER_PASSWORD);
         // For local test use
-        // mySqlContainer.setPortBindings(Collections.singletonList("3308:3306"));
+        mySqlContainer.setPortBindings(Collections.singletonList("3308:3306"));
         return mySqlContainer;
     }
 
@@ -115,7 +116,7 @@ public void startUp() {
         log.info("The second stage:Starting Mongodb containers...");
         mongodbContainer = new MongoDBContainer(NETWORK);
         // For local test use
-        // mongodbContainer.setPortBindings(Collections.singletonList("27017:27017"));
+        mongodbContainer.setPortBindings(Collections.singletonList("27017:27017"));
         Startables.deepStart(Stream.of(mongodbContainer)).join();
         mongodbContainer.executeCommandFileInSeparateDatabase(MONGODB_DATABASE);
         initConnection();
@@ -204,15 +205,16 @@ private List<List<Object>> querySql() {
     }
 
     private void upsertDeleteSourceTable() {
-        mongodbContainer.executeCommandFileInDatabase("InventoryDDL", MONGODB_DATABASE);
+        mongodbContainer.executeCommandFileInDatabase("inventoryDDL", MONGODB_DATABASE);
     }
 
     public void initConnection() {
         String ipAddress = mongodbContainer.getHost();
+        Integer port = mongodbContainer.getFirstMappedPort();
         String url =
                 String.format(
                         "mongodb://%s:%s@%s:%d/%s?authSource=admin",
-                        "stuser", "stpw", ipAddress, 27017, "inventory.products");
+                        "stuser", "stpw", ipAddress, port, MONGODB_DATABASE+"."+MONGODB_COLLECTION);
         client = MongoClients.create(url);
     }
 

diff --git a/...2e/src/test/resources/ddl/InventoryDDL.js → ...2e/src/test/resources/ddl/inventoryDDL.js b/...2e/src/test/resources/ddl/InventoryDDL.js → ...2e/src/test/resources/ddl/inventoryDDL.js