diff --git a/sharding-jdbc-core/src/main/java/com/dangdang/ddframe/rdb/sharding/routing/router/UnparsingSQLRouter.java b/sharding-jdbc-core/src/main/java/com/dangdang/ddframe/rdb/sharding/routing/router/DatabaseHintSQLRouter.java similarity index 85% rename from sharding-jdbc-core/src/main/java/com/dangdang/ddframe/rdb/sharding/routing/router/UnparsingSQLRouter.java rename to sharding-jdbc-core/src/main/java/com/dangdang/ddframe/rdb/sharding/routing/router/DatabaseHintSQLRouter.java index c6b0340e5c2ecda58e55e4cf517e6b1d9811cc79..c910e01909f2e5590559f9f89560fd8d09f5c6bf 100644 --- a/sharding-jdbc-core/src/main/java/com/dangdang/ddframe/rdb/sharding/routing/router/UnparsingSQLRouter.java +++ b/sharding-jdbc-core/src/main/java/com/dangdang/ddframe/rdb/sharding/routing/router/DatabaseHintSQLRouter.java @@ -27,22 +27,22 @@ import com.dangdang.ddframe.rdb.sharding.routing.SQLExecutionUnit; import com.dangdang.ddframe.rdb.sharding.routing.SQLRouteResult; import com.dangdang.ddframe.rdb.sharding.routing.type.RoutingResult; import com.dangdang.ddframe.rdb.sharding.routing.type.TableUnit; -import com.dangdang.ddframe.rdb.sharding.routing.type.direct.DirectRoutingEngine; +import com.dangdang.ddframe.rdb.sharding.routing.type.hint.DatabaseHintRoutingEngine; import lombok.extern.slf4j.Slf4j; import java.util.List; /** - * 无需解析的SQL路由器. + * 通过提示且仅路由至数据库的SQL路由器. * * @author zhangiang */ @Slf4j -public final class UnparsingSQLRouter implements SQLRouter { +public final class DatabaseHintSQLRouter implements SQLRouter { private final ShardingRule shardingRule; - public UnparsingSQLRouter(final ShardingContext shardingContext) { + public DatabaseHintSQLRouter(final ShardingContext shardingContext) { shardingRule = shardingContext.getShardingRule(); } @@ -56,7 +56,7 @@ public final class UnparsingSQLRouter implements SQLRouter { public SQLRouteResult route(final String logicSQL, final List parameters, final SQLStatement sqlStatement) { Context context = MetricsContext.start("Route SQL"); SQLRouteResult result = new SQLRouteResult(sqlStatement); - RoutingResult routingResult = new DirectRoutingEngine(shardingRule.getDataSourceRule(), shardingRule.getDatabaseShardingStrategy(), sqlStatement.getType()).route(); + RoutingResult routingResult = new DatabaseHintRoutingEngine(shardingRule.getDataSourceRule(), shardingRule.getDatabaseShardingStrategy(), sqlStatement.getType()).route(); for (TableUnit each : routingResult.getTableUnits().getTableUnits()) { result.getExecutionUnits().add(new SQLExecutionUnit(each.getDataSourceName(), logicSQL)); } diff --git a/sharding-jdbc-core/src/main/java/com/dangdang/ddframe/rdb/sharding/routing/router/SQLRouterFactory.java b/sharding-jdbc-core/src/main/java/com/dangdang/ddframe/rdb/sharding/routing/router/SQLRouterFactory.java index 2bfda2e3ae4ab0d041772f4dc1b5543afb716797..3839232f03e4172aabefad51c7bb5a83243f469f 100644 --- a/sharding-jdbc-core/src/main/java/com/dangdang/ddframe/rdb/sharding/routing/router/SQLRouterFactory.java +++ b/sharding-jdbc-core/src/main/java/com/dangdang/ddframe/rdb/sharding/routing/router/SQLRouterFactory.java @@ -37,6 +37,6 @@ public final class SQLRouterFactory { * @return SQL路由器 */ public static SQLRouter createSQLRouter(final ShardingContext shardingContext) { - return HintManagerHolder.isDatabaseShardingOnly() ? new UnparsingSQLRouter(shardingContext) : new ParsingSQLRouter(shardingContext); + return HintManagerHolder.isDatabaseShardingOnly() ? new DatabaseHintSQLRouter(shardingContext) : new ParsingSQLRouter(shardingContext); } } diff --git a/sharding-jdbc-core/src/main/java/com/dangdang/ddframe/rdb/sharding/routing/type/RoutingEngine.java b/sharding-jdbc-core/src/main/java/com/dangdang/ddframe/rdb/sharding/routing/type/RoutingEngine.java index 73b23497711afebb3ad6f6b2c553c84624907154..9f5b3a9b8be285669d2ffd96ddd39109f4e68313 100644 --- a/sharding-jdbc-core/src/main/java/com/dangdang/ddframe/rdb/sharding/routing/type/RoutingEngine.java +++ b/sharding-jdbc-core/src/main/java/com/dangdang/ddframe/rdb/sharding/routing/type/RoutingEngine.java @@ -1,7 +1,7 @@ package com.dangdang.ddframe.rdb.sharding.routing.type; /** - * 路由接口. + * 路由引擎接口. * * @author zhangliang */ diff --git a/sharding-jdbc-core/src/main/java/com/dangdang/ddframe/rdb/sharding/routing/type/complex/ComplexRoutingEngine.java b/sharding-jdbc-core/src/main/java/com/dangdang/ddframe/rdb/sharding/routing/type/complex/ComplexRoutingEngine.java index 7259bd3ab9902e7969beb6dca18c01ddbada485f..71b90f6789bbfab6e166d1833e365a18d1bfc0c7 100644 --- a/sharding-jdbc-core/src/main/java/com/dangdang/ddframe/rdb/sharding/routing/type/complex/ComplexRoutingEngine.java +++ b/sharding-jdbc-core/src/main/java/com/dangdang/ddframe/rdb/sharding/routing/type/complex/ComplexRoutingEngine.java @@ -37,7 +37,7 @@ import java.util.List; import java.util.TreeSet; /** - * 混合多库表路由类. + * 混合多库表路由引擎. * * @author gaohongtao * @author zhangliang diff --git a/sharding-jdbc-core/src/main/java/com/dangdang/ddframe/rdb/sharding/routing/type/direct/DirectRoutingEngine.java b/sharding-jdbc-core/src/main/java/com/dangdang/ddframe/rdb/sharding/routing/type/hint/DatabaseHintRoutingEngine.java similarity index 93% rename from sharding-jdbc-core/src/main/java/com/dangdang/ddframe/rdb/sharding/routing/type/direct/DirectRoutingEngine.java rename to sharding-jdbc-core/src/main/java/com/dangdang/ddframe/rdb/sharding/routing/type/hint/DatabaseHintRoutingEngine.java index 4fa3c292789b0e7f45955a98b7c787747859fa12..97a92e62d5bb2582d854beafe5d54512adbda602 100644 --- a/sharding-jdbc-core/src/main/java/com/dangdang/ddframe/rdb/sharding/routing/type/direct/DirectRoutingEngine.java +++ b/sharding-jdbc-core/src/main/java/com/dangdang/ddframe/rdb/sharding/routing/type/hint/DatabaseHintRoutingEngine.java @@ -15,7 +15,7 @@ *

*/ -package com.dangdang.ddframe.rdb.sharding.routing.type.direct; +package com.dangdang.ddframe.rdb.sharding.routing.type.hint; import com.dangdang.ddframe.rdb.sharding.api.ShardingValue; import com.dangdang.ddframe.rdb.sharding.api.rule.DataSourceRule; @@ -35,13 +35,14 @@ import java.util.Collection; import java.util.Collections; /** - * 直接路由. + * 基于数据库提示的路由引擎. * * @author gaohongtao + * @author zhangliang */ @RequiredArgsConstructor @Slf4j -public final class DirectRoutingEngine implements RoutingEngine { +public final class DatabaseHintRoutingEngine implements RoutingEngine { private final DataSourceRule dataSourceRule;