Skip to content

Commit 1237996

Browse files
dujieyanghuaiGit
authored andcommitted
[feat-874][jdbc]the sql WHERE condition add [splitKey is null] for the first split
1 parent 899d0a7 commit 1237996

File tree

1 file changed

+7
-2
lines changed
  • chunjun-connectors/chunjun-connector-jdbc-base/src/main/java/com/dtstack/chunjun/connector/jdbc/util

1 file changed

+7
-2
lines changed

chunjun-connectors/chunjun-connector-jdbc-base/src/main/java/com/dtstack/chunjun/connector/jdbc/util/SqlUtil.java

Lines changed: 7 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -253,10 +253,15 @@ public static String buildSplitFilterSql(
253253
JdbcDialect jdbcDialect,
254254
JdbcInputSplit jdbcInputSplit,
255255
String splitColumn) {
256+
String sql;
256257
if ("range".equalsIgnoreCase(splitStrategy)) {
257-
return jdbcDialect.getSplitRangeFilter(jdbcInputSplit, splitColumn);
258+
sql = jdbcDialect.getSplitRangeFilter(jdbcInputSplit, splitColumn);
258259
} else {
259-
return jdbcDialect.getSplitModFilter(jdbcInputSplit, splitColumn);
260+
sql = jdbcDialect.getSplitModFilter(jdbcInputSplit, splitColumn);
260261
}
262+
if (jdbcInputSplit.getSplitNumber() == 0) {
263+
sql += " OR " + jdbcDialect.quoteIdentifier(splitColumn) + " IS NULL";
264+
}
265+
return sql;
261266
}
262267
}

0 commit comments

Comments
 (0)