DBZ-4999 Provide hook to allow Informix to avoid blocking

couchbase · Oct 20, 2023 · 13d1b4e · 13d1b4e
1 parent 4beb3ae
commit 13d1b4e
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/debezium-core/src/main/java/io/debezium/relational/RelationalSnapshotChangeEventSource.java b/debezium-core/src/main/java/io/debezium/relational/RelationalSnapshotChangeEventSource.java
@@ -538,7 +538,7 @@ private void doCreateDataEventsForTable(ChangeEventSourceContext sourceContext,
         Instant sourceTableSnapshotTimestamp = getSnapshotSourceTimestamp(jdbcConnection, offset, table.id());
 
         try (Statement statement = readTableStatement(jdbcConnection, rowCount);
-                ResultSet rs = CancellableResultSet.from(statement.executeQuery(selectStatement))) {
+                ResultSet rs = resultSetForDataEvents(selectStatement, statement)) {
 
             ColumnUtils.ColumnArray columnArray = ColumnUtils.toArray(rs, table);
             long rows = 0;
@@ -588,6 +588,11 @@ private void doCreateDataEventsForTable(ChangeEventSourceContext sourceContext,
         }
     }
 
+    protected ResultSet resultSetForDataEvents(String selectStatement, Statement statement)
+            throws SQLException {
+        return CancellableResultSet.from(statement.executeQuery(selectStatement));
+    }
+
     private void setSnapshotMarker(OffsetContext offset, boolean firstTable, boolean lastTable, boolean firstRecordInTable,
                                    boolean lastRecordInTable) {
         if (lastRecordInTable && lastTable) {