From 692a95692d9066efbc13c42ae17a3ca17d5f9451 Mon Sep 17 00:00:00 2001 From: justdba <49357318+justdba@users.noreply.github.com> Date: Tue, 8 Feb 2022 23:13:37 +0800 Subject: [PATCH] Update SingleTableSplitUtil.java sql plan cause baddly, remove where (AND IS NOT NULL) suffix in select min(pk),max(pk)... --- .../plugin/rdbms/reader/util/SingleTableSplitUtil.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/plugin-rdbms-util/src/main/java/com/alibaba/datax/plugin/rdbms/reader/util/SingleTableSplitUtil.java b/plugin-rdbms-util/src/main/java/com/alibaba/datax/plugin/rdbms/reader/util/SingleTableSplitUtil.java index d9846b39..450f545e 100755 --- a/plugin-rdbms-util/src/main/java/com/alibaba/datax/plugin/rdbms/reader/util/SingleTableSplitUtil.java +++ b/plugin-rdbms-util/src/main/java/com/alibaba/datax/plugin/rdbms/reader/util/SingleTableSplitUtil.java @@ -282,8 +282,8 @@ public class SingleTableSplitUtil { String pkRangeSQL = String.format(minMaxTemplate, splitPK, splitPK, table); if (StringUtils.isNotBlank(where)) { - pkRangeSQL = String.format("%s WHERE (%s AND %s IS NOT NULL)", - pkRangeSQL, where, splitPK); + pkRangeSQL = String.format("%s WHERE (%s)", + pkRangeSQL, where); } return pkRangeSQL; } @@ -387,4 +387,4 @@ public class SingleTableSplitUtil { } return rangeSql; } -} \ No newline at end of file +}