Commit de8eac34 authored by terrymanu's avatar terrymanu
Browse files

fix #610

parent 626ecbc6

sharding-jdbc-core/src/main/java/io/shardingjdbc/core/routing/router/ParsingSQLRouter.java

+2 −0
Original line number Diff line number Diff line
@@ -127,6 +127,8 @@ public final class ParsingSQLRouter implements SQLRouter { 
            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)) {