DBZ-695 Removing some unused code

This commit is contained in:
Gunnar Morling 2020-01-30 14:35:36 +01:00
parent be0752b0e7
commit 0dcb4d459f
3 changed files with 1 additions and 18 deletions

View File

@ -54,9 +54,6 @@ public class Db2Connection extends JdbcConnection {
private static final String LSN_TO_TIMESTAMP = "SELECT CURRENT TIMEstamp FROM sysibm.sysdummy1 WHERE ? > X'00000000000000000000000000000000'";
private static final String INCREMENT_LSN = " SELECT *" +
" FROM (select CAST(CAST( ? AS VARCHAR(16) FOR BIT DATA) AS VARCHAR(32)) AS LSN from sysibm.sysdummy1) FETCH FIRST ROW ONLY;";
private static final String GET_ALL_CHANGES_FOR_TABLE = "SELECT "
+ "CASE "
+ "WHEN IBMSNAP_OPERATION = 'D' AND (LEAD(cdc.IBMSNAP_OPERATION,1,'X') OVER (PARTITION BY cdc.IBMSNAP_COMMITSEQ ORDER BY cdc.IBMSNAP_INTENTSEQ)) ='I' THEN 3 "

View File

@ -5,9 +5,6 @@
*/
package io.debezium.connector.db2;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import io.debezium.pipeline.spi.SchemaChangeEventEmitter;
import io.debezium.relational.Table;
import io.debezium.schema.SchemaChangeEvent;
@ -20,8 +17,6 @@
*/
public class Db2SchemaChangeEventEmitter implements SchemaChangeEventEmitter {
private static final Logger LOGGER = LoggerFactory.getLogger(Db2SchemaChangeEventEmitter.class);
private final Db2OffsetContext offsetContext;
private final ChangeTable changeTable;
private final Table tableSchema;

View File

@ -165,16 +165,7 @@ protected void readTableStructure(ChangeEventSourceContext sourceContext, Snapsh
}
LOGGER.info("Reading structure of schema '{}'", schema);
/**
jdbcConnection.readSchema(
snapshotContext.tables,
snapshotContext.catalogName,
schema,
connectorConfig.getTableFilters().dataCollectionFilter(),
null,
false
);
**/
jdbcConnection.readSchema(
snapshotContext.tables,
null,