github/DataX
5
0
Fork 0
mirror of https://github.com/alibaba/DataX.git synced 2025-05-02 23:52:00 +08:00
Code Issues Packages Projects Releases Wiki Activity

Update SingleTableSplitUtil.java

Browse Source 
sql plan cause baddly,  remove where (AND IS NOT NULL) suffix in select  min(pk),max(pk)...
This commit is contained in:
justdba 2022-02-08 23:13:37 +08:00 committed by GitHub
parent 24e9ec63b8
commit 692a95692d
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
plugin-rdbms-util/src/main/java/com/alibaba/datax/plugin/rdbms/reader/util/SingleTableSplitUtil.java
View File

@ -282,8 +282,8 @@ public class SingleTableSplitUtil {
String pkRangeSQL = String.format(minMaxTemplate, splitPK, splitPK, String pkRangeSQL = String.format(minMaxTemplate, splitPK, splitPK,
table); table);
if (StringUtils.isNotBlank(where)) { if (StringUtils.isNotBlank(where)) {
pkRangeSQL = String.format("%s WHERE (%s AND %s IS NOT NULL)", pkRangeSQL = String.format("%s WHERE (%s)",
pkRangeSQL, where, splitPK); pkRangeSQL, where);
} }
return pkRangeSQL; return pkRangeSQL;
} }