[ci] ReselectColumnProcessor - cleanup before each test

debezium · Feb 12, 2024 · 42fe9dd · 42fe9dd
1 parent f6ae93f
commit 42fe9dd
Showing 1 changed file with 7 additions and 0 deletions.
diff --git a/src/test/java/io/debezium/connector/db2/Db2ReselectColumnsProcessorIT.java b/src/test/java/io/debezium/connector/db2/Db2ReselectColumnsProcessorIT.java
@@ -27,6 +27,13 @@ public class Db2ReselectColumnsProcessorIT extends AbstractReselectProcessorTest
     @Before
     public void beforeEach() throws Exception {
         connection = TestHelper.testConnection();
+
+        TestHelper.disableDbCdc(connection);
+        TestHelper.disableTableCdc(connection, "dbz4321");
+        connection.execute("DROP TABLE IF EXIST dbz4321");
+
+        connection.execute("DELETE FROM ASNCDC.IBMSNAP_REGISTER");
+
         initializeConnectorTestFramework();
         Testing.Files.delete(TestHelper.DB_HISTORY_PATH);
         super.beforeEach();