From d1a17c5c917a56edba051edc9bfc72e5fe4c3e5a Mon Sep 17 00:00:00 2001
From: johnrobbet <johnxu.xj@alibaba-inc.com>
Date: Mon, 7 Mar 2022 18:33:40 +0800
Subject: [PATCH] fix where missing in single table split

---
 .../datax/plugin/rdbms/reader/util/SingleTableSplitUtil.java   | 3 +++
 1 file changed, 3 insertions(+)

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..df01ffd0 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
@@ -93,6 +93,7 @@ public class SingleTableSplitUtil {
 
                 allQuerySql.add(tempQuerySql);
                 tempConfig.set(Key.QUERY_SQL, tempQuerySql);
+                tempConfig.set(Key.WHERE, (hasWhere ? ("(" + where + ") and") : "") + range);
                 pluginParams.add(tempConfig);
             }
         } else {
@@ -103,6 +104,7 @@ public class SingleTableSplitUtil {
                     + String.format(" %s IS NOT NULL", splitPkName);
             allQuerySql.add(tempQuerySql);
             tempConfig.set(Key.QUERY_SQL, tempQuerySql);
+            tempConfig.set(Key.WHERE, (hasWhere ? "(" + where + ") and" : "") + String.format(" %s IS NOT NULL", splitPkName));
             pluginParams.add(tempConfig);
         }
 
@@ -118,6 +120,7 @@ public class SingleTableSplitUtil {
                 StringUtils.join(allQuerySql, "\n"));
 
         tempConfig.set(Key.QUERY_SQL, tempQuerySql);
+        tempConfig.set(Key.WHERE, (hasWhere ? "(" + where + ") and" : "") + String.format(" %s IS NULL", splitPkName));
         pluginParams.add(tempConfig);
         
         return pluginParams;