Skip to content

Commit 91b3036

Browse files
committed
[fix-36591][logminer]事务回滚日志delete where row_id=''转为正常业务字段
1 parent b62b3ba commit 91b3036

File tree

2 files changed

+6
-1
lines changed

2 files changed

+6
-1
lines changed

flinkx-oraclelogminer/flinkx-oraclelogminer-reader/src/main/java/com/dtstack/flinkx/oraclelogminer/format/LogMinerConnection.java

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -332,6 +332,11 @@ public void queryData(BigDecimal startScn, String logMinerSelectSql) {
332332
}
333333
}
334334

335+
/**
336+
* 根据rollback的信息 找出对应的dml语句
337+
* @param recordLog
338+
* @param sql
339+
*/
335340
public void queryDataForDeleteRollback(RecordLog recordLog, String sql) {
336341
try {
337342
closeStmt();

flinkx-oraclelogminer/flinkx-oraclelogminer-reader/src/main/java/com/dtstack/flinkx/oraclelogminer/util/SqlUtil.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -256,7 +256,7 @@ public class SqlUtil {
256256

257257

258258

259-
/** 查找delete的rollback语句对应的insert语句 存在一个事务里rowid相同的 所以需要子查询过滤掉scn相同rowid相同的语句*/
259+
/** 查找delete的rollback语句对应的insert语句 存在一个事务里rowid相同的其他语句 所以需要子查询过滤掉scn相同rowid相同的语句(这是一对rollback和DML)*/
260260
public static String queryDataForRollback =
261261
"SELECT\n" +
262262
" scn,\n" +

0 commit comments

Comments
 (0)