DBZ-7491 Always clean-up after each Db2ReselectColumnsProcessorIT test

debezium · Feb 15, 2024 · e7871da · e7871da
1 parent 8db316b
commit e7871da
Showing 1 changed file with 13 additions and 9 deletions.
diff --git a/src/test/java/io/debezium/connector/db2/Db2ReselectColumnsProcessorIT.java b/src/test/java/io/debezium/connector/db2/Db2ReselectColumnsProcessorIT.java
@@ -34,15 +34,19 @@ public void beforeEach() throws Exception {
 
     @After
     public void afterEach() throws Exception {
-        super.afterEach();
-        if (connection != null) {
-            TestHelper.disableDbCdc(connection);
-            TestHelper.disableTableCdc(connection, "DBZ4321");
-            connection.execute("DROP TABLE dbz4321");
-            connection.execute("DELETE FROM ASNCDC.IBMSNAP_REGISTER");
-            connection.execute("DELETE FROM ASNCDC.IBMQREP_COLVERSION");
-            connection.execute("DELETE FROM ASNCDC.IBMQREP_TABVERSION");
-            connection.close();
+        try {
+            super.afterEach();
+        }
+        finally {
+            if (connection != null) {
+                TestHelper.disableDbCdc(connection);
+                TestHelper.disableTableCdc(connection, "DBZ4321");
+                connection.execute("DROP TABLE dbz4321");
+                connection.execute("DELETE FROM ASNCDC.IBMSNAP_REGISTER");
+                connection.execute("DELETE FROM ASNCDC.IBMQREP_COLVERSION");
+                connection.execute("DELETE FROM ASNCDC.IBMQREP_TABVERSION");
+                connection.close();
+            }
         }
     }