Added test to cover RENAME table with database.override.map

Altinity · Oct 9, 2024 · a5ec2af · a5ec2af
1 parent aa0945e
commit a5ec2af
Showing 1 changed file with 9 additions and 1 deletion.
diff --git a/...eight/src/test/java/com/altinity/clickhouse/debezium/embedded/cdc/DatabaseOverrideIT.java b/...eight/src/test/java/com/altinity/clickhouse/debezium/embedded/cdc/DatabaseOverrideIT.java
@@ -148,7 +148,15 @@ public void testDatabaseOverride() throws Exception {
         assertTrue(customersCol2 == 1);
 
 
-
+        Thread.sleep(10000);
+        // Execute the query in MySQL to rename table.
+        conn.prepareStatement("rename table products.prodtable to products.prodtable2").execute();
+        Thread.sleep(10000);
+        ResultSet customersVersionResult2 = writer.executeQueryWithResultSet("select col2 from customers.custtable2 final where col1 = 'a'");
+        while(customersVersionResult2.next()) {
+            customersCol2 = customersVersionResult2.getLong("col2");
+        }
+        assertTrue(customersCol2 == 2);
         clickHouseDebeziumEmbeddedApplication.getDebeziumEventCapture().engine.close();
 
         conn.close();