alexey.rassokhin/tet123
1
0
Fork 0
Code Issues Pull Requests 1 Packages Projects Releases Wiki Activity

DBZ-6990 Use DB2 specif statement for table truncation

Browse Source
This commit is contained in:
mfvitale 2023-10-10 16:35:43 +02:00 committed by Fiore Mario Vitale
parent 3bc252871f
commit 5450b748a3
2 changed files with 7 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
debezium-connector-jdbc/src/main/java/io/debezium/connector/jdbc/JdbcChangeEventSink.java
View File

@ -326,7 +326,7 @@ private void writeTruncate(String sql, SinkRecordDescriptor record) throws SQLEx
final Transaction transaction = session.beginTransaction();
try {
LOGGER.trace("SQL: {}", sql);
final NativeQuery<?> query = session.createNativeQuery(sql);
final NativeQuery<?> query = session.createNativeQuery(sql, Object.class);
query.executeUpdate();
transaction.commit();

10
debezium-connector-jdbc/src/main/java/io/debezium/connector/jdbc/dialect/db2/Db2DatabaseDialect.java
View File

@ -190,11 +190,13 @@ protected String resolveColumnNameFromField(String fieldName) {
@Override
public String getTruncateStatement(TableDescriptor table) {
String truncateStatement = super.getTruncateStatement(table);
// For some reason the TRUNCATE statement doesn't work for DB2 even if it is supported from 9.7 https://www.ibm.com/support/pages/apar/JR37942
// The problem verifies with Hibernate, plain JDBC works good.
// Qlik uses the below approach https://community.qlik.com/t5/Qlik-Replicate/Using-Qlik-for-DB2-TRUNCATE-option/td-p/1989498
final SqlStatementBuilder builder = new SqlStatementBuilder();
builder.append(truncateStatement);
builder.append(" IMMEDIATE");
builder.append("ALTER TABLE ");
builder.append(getQualifiedTableName(table.getId()));
builder.append(" ACTIVATE NOT LOGGED INITIALLY WITH EMPTY TABLE");
return builder.build();
}
}