fix #610

apache · Mar 1, 2018 · de8eac3 · de8eac3
1 parent 626ecbc
commit de8eac3
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/sharding-jdbc-core/src/main/java/io/shardingjdbc/core/routing/router/ParsingSQLRouter.java b/sharding-jdbc-core/src/main/java/io/shardingjdbc/core/routing/router/ParsingSQLRouter.java
@@ -127,6 +127,8 @@ private RoutingResult route(final List<Object> parameters, final SQLStatement sq
             routingEngine = new DatabaseBroadcastRoutingEngine(shardingRule);
         } else if (sqlStatement instanceof ShowColumnsStatement || sqlStatement instanceof ShowOtherStatement || sqlStatement instanceof DescribeStatement) {
             routingEngine = new UnicastRoutingEngine(shardingRule, sqlStatement);
+        } else if (tableNames.isEmpty() && sqlStatement instanceof SelectStatement) {
+            routingEngine = new UnicastRoutingEngine(shardingRule, sqlStatement);
         } else if (tableNames.isEmpty()) {
             routingEngine = new DatabaseBroadcastRoutingEngine(shardingRule);
         } else if (1 == tableNames.size() || shardingRule.isAllBindingTables(tableNames) || shardingRule.isAllInDefaultDataSource(tableNames)) {