mirror/dble
1
0
Fork 0
mirror of https://github.com/actiontech/dble.git synced 2026-01-06 04:40:17 -06:00
Code Issues Packages Projects Releases Wiki Activity

import from #1997

Browse Source
This commit is contained in:
yanhuqing
2020-09-08 19:39:22 +08:00
committed by guoaomen
parent b2b926b2dc
commit ef57857cb0
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
src/main/java/com/actiontech/dble/route/util/RouterUtil.java
View File

@@ -399,8 +399,8 @@ public final class RouterUtil {
String shardingNode = ruleCalculateSingleValue(schemaName, tc, value, clientCharset);
routeNodeSet.add(shardingNode);
}
} else if (!ignoreNull) {
String shardingNode = ruleCalculateSingleValue(schemaName, tc, columnRoute.getColValue(), clientCharset);
} else if (!ignoreNull || originValue instanceof Number) {
String shardingNode = ruleCalculateSingleValue(schemaName, tc, originValue, clientCharset);
routeNodeSet.add(shardingNode);
}
} else if (columnRoute.getInValues() != null) {
@@ -409,11 +409,11 @@ public final class RouterUtil {
routeNodeSet.add(shardingNode);
}
}
ruleCalculateInValue(rrs, tc, columnRoute, routeNodeSet);
ruleCalculateRangeValue(rrs, tc, columnRoute, routeNodeSet);
return routeNodeSet;
}
private static void ruleCalculateInValue(RouteResultset rrs, ShardingTableConfig tc, ColumnRoute columnRoute, Set<String> routeNodeSet) {
private static void ruleCalculateRangeValue(RouteResultset rrs, ShardingTableConfig tc, ColumnRoute columnRoute, Set<String> routeNodeSet) {
if (columnRoute.getRangeValues() != null) {
Set<String> rangeNodeSet = new LinkedHashSet<>();
boolean isFirst = true;