CodeCow/DataX
1
0
Fork 0
mirror of https://github.com/alibaba/DataX.git synced 2026-06-04 21:03:49 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

fix:solve the problem of increasing or losing data in incremental situations

Browse Source
This commit is contained in:
xxsc0529 2025-06-20 10:25:03 +08:00
parent c1e34c96c4
commit 4554981133
2 changed files with 110 additions and 55 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

161
oceanbasev10reader/src/main/java/com/alibaba/datax/plugin/reader/oceanbasev10reader/util/ObReaderUtils.java
View File

File diff suppressed because one or more lines are too long

4
oceanbasev10reader/src/main/java/com/alibaba/datax/plugin/reader/oceanbasev10reader/util/TaskContext.java
View File

@ -80,8 +80,10 @@ public class TaskContext {
}
public String getQuerySql() {
if (readBatchSize == -1 || ObReaderUtils.isOracleMode(compatibleMode)) {
if (readBatchSize == -1) {
return querySql;
} else if (ObReaderUtils.isOracleMode(compatibleMode)) {
return String.format("select * from (%s) where rownum <= %d", querySql, readBatchSize);
} else {
return querySql + " limit " + readBatchSize;
}