Commit bb5f14e2 authored by terrymanu's avatar terrymanu
Browse files

refactor SimpleRoutingEngine => StandardRoutingEngine

parent 517e178e

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

+2 −2
Original line number Diff line number Diff line
@@ -43,7 +43,7 @@ import io.shardingjdbc.core.routing.type.complex.CartesianTableReference; 
import io.shardingjdbc.core.routing.type.complex.ComplexRoutingEngine;

import io.shardingjdbc.core.routing.type.ignore.IgnoreRoutingEngine;

import io.shardingjdbc.core.routing.type.show.ShowRoutingEngine;

import io.shardingjdbc.core.routing.type.simple.SimpleRoutingEngine;

import io.shardingjdbc.core.routing.type.standard.StandardRoutingEngine;

import io.shardingjdbc.core.routing.type.unicast.UnicastRoutingEngine;

import io.shardingjdbc.core.rule.ShardingRule;

import io.shardingjdbc.core.util.SQLLogger;
@@ -128,7 +128,7 @@ public final class ParsingSQLRouter implements SQLRouter { 
        } else if (tableNames.isEmpty()) {

            routingEngine = new DatabaseBroadcastRoutingEngine(shardingRule);

        } else if (1 == tableNames.size() || shardingRule.isAllBindingTables(tableNames) || shardingRule.isAllInDefaultDataSource(tableNames)) {

            routingEngine = new SimpleRoutingEngine(shardingRule, parameters, tableNames.iterator().next(), sqlStatement);

            routingEngine = new StandardRoutingEngine(shardingRule, parameters, tableNames.iterator().next(), sqlStatement);

        } else {

            // TODO config for cartesian set

            routingEngine = new ComplexRoutingEngine(shardingRule, parameters, tableNames, sqlStatement);

sharding-jdbc-core/src/main/java/io/shardingjdbc/core/routing/type/complex/ComplexRoutingEngine.java

+2 −2
Original line number Diff line number Diff line
@@ -24,7 +24,7 @@ import io.shardingjdbc.core.exception.ShardingJdbcException; 
import io.shardingjdbc.core.parsing.parser.sql.SQLStatement;

import io.shardingjdbc.core.routing.type.RoutingResult;

import io.shardingjdbc.core.routing.type.RoutingEngine;

import io.shardingjdbc.core.routing.type.simple.SimpleRoutingEngine;

import io.shardingjdbc.core.routing.type.standard.StandardRoutingEngine;

import com.google.common.base.Function;

import com.google.common.base.Optional;

import com.google.common.collect.Lists;
@@ -62,7 +62,7 @@ public final class ComplexRoutingEngine implements RoutingEngine { 
            Optional<TableRule> tableRule = shardingRule.tryFindTableRuleByLogicTable(each);

            if (tableRule.isPresent()) {

                if (!bindingTableNames.contains(each)) {

                    result.add(new SimpleRoutingEngine(shardingRule, parameters, tableRule.get().getLogicTable(), sqlStatement).route());

                    result.add(new StandardRoutingEngine(shardingRule, parameters, tableRule.get().getLogicTable(), sqlStatement).route());

                }

                Optional<BindingTableRule> bindingTableRule = shardingRule.findBindingTableRule(each);

                if (bindingTableRule.isPresent()) {

sharding-jdbc-core/src/main/java/io/shardingjdbc/core/routing/type/simple/SimpleRoutingEngine.java→sharding-jdbc-core/src/main/java/io/shardingjdbc/core/routing/type/standard/StandardRoutingEngine.java

+3 −3
Original line number Diff line number Diff line
@@ -15,7 +15,7 @@ 
 * </p>

 */



package io.shardingjdbc.core.routing.type.simple;

package io.shardingjdbc.core.routing.type.standard;



import io.shardingjdbc.core.api.algorithm.sharding.ShardingValue;

import io.shardingjdbc.core.hint.HintManagerHolder;
@@ -40,12 +40,12 @@ import java.util.LinkedList; 
import java.util.List;



/**

 * Simple routing engine.

 * Standard routing engine.

 * 

 * @author zhangliang

 */

@RequiredArgsConstructor

public final class SimpleRoutingEngine implements RoutingEngine {

public final class StandardRoutingEngine implements RoutingEngine {

    

    private final ShardingRule shardingRule;