DBZ-7305 Disable table cdc for always snapshot test table

rohan-flutterint · Mar 14, 2024 · 59d6c09 · 59d6c09
1 parent 5fc580c
commit 59d6c09
Showing 1 changed file with 1 addition and 5 deletions.
diff --git a/src/test/java/io/debezium/connector/db2/Db2ConnectorIT.java b/src/test/java/io/debezium/connector/db2/Db2ConnectorIT.java
@@ -966,6 +966,7 @@ public void shouldNotUseOffsetWhenSnapshotIsAlways() throws Exception {
             e.printStackTrace();
         }
         finally {
+            TestHelper.disableTableCdc(connection, "ALWAYS_SNAPSHOT");
             connection.execute("DROP TABLE ALWAYS_SNAPSHOT");
         }
     }
@@ -1085,11 +1086,6 @@ record = s2recs.get(0);
         VerifyRecord.isValidRead(s2recs.get(1), pkField, 2);
     }
 
-    private void purgeDatabaseLogs() throws SQLException {
-        connection.execute("ALTER DATABASE testDB1 SET RECOVERY SIMPLE");
-        connection.execute("DBCC SHRINKFILE (testDB1, 1)");
-    }
-
     private void assertRecord(Struct record, List<SchemaAndValueField> expected) {
         expected.forEach(schemaAndValueField -> schemaAndValueField.assertFor(record));
     }