Commit e06b3e16 authored by terrymanu's avatar terrymanu
Browse files

refactor BroadcastRoutingEngine => TableBroadcastRoutingEngine

parent 69e32f82

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

+2 −2
Original line number Diff line number Diff line
@@ -36,7 +36,7 @@ import io.shardingjdbc.core.routing.type.RoutingEngine; 
import io.shardingjdbc.core.routing.type.RoutingResult;

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

import io.shardingjdbc.core.routing.type.all.DatabaseAllRoutingEngine;

import io.shardingjdbc.core.routing.type.broadcast.BroadcastRoutingEngine;

import io.shardingjdbc.core.routing.type.broadcast.TableBroadcastRoutingEngine;

import io.shardingjdbc.core.routing.type.complex.CartesianDataSource;

import io.shardingjdbc.core.routing.type.complex.CartesianRoutingResult;

import io.shardingjdbc.core.routing.type.complex.CartesianTableReference;
@@ -120,7 +120,7 @@ public final class ParsingSQLRouter implements SQLRouter { 
        if (sqlStatement instanceof IgnoreStatement) {

            routingEngine = new IgnoreRoutingEngine();

        } else if (sqlStatement instanceof DDLStatement) {

            routingEngine = new BroadcastRoutingEngine(shardingRule, sqlStatement);

            routingEngine = new TableBroadcastRoutingEngine(shardingRule, sqlStatement);

        } else if (sqlStatement instanceof ShowStatement) {

            routingEngine = new ShowRoutingEngine(shardingRule, (ShowStatement) sqlStatement);

        } else if (sqlStatement instanceof DescStatement) {

sharding-jdbc-core/src/main/java/io/shardingjdbc/core/routing/type/broadcast/BroadcastRoutingEngine.java→sharding-jdbc-core/src/main/java/io/shardingjdbc/core/routing/type/broadcast/TableBroadcastRoutingEngine.java

+2 −2
Original line number Diff line number Diff line
@@ -34,12 +34,12 @@ import java.util.Collections; 
import java.util.LinkedList;



/**

 * Broadcast routing engine.

 * Broadcast routing engine for tables.

 * 

 * @author zhangliang

 */

@RequiredArgsConstructor

public final class BroadcastRoutingEngine implements RoutingEngine {

public final class TableBroadcastRoutingEngine implements RoutingEngine {

    

    private final ShardingRule shardingRule;