提交 c0904aeb 编写于 作者: T terrymanu

refactor router module for checkstyle

上级 87619c14
......@@ -62,4 +62,3 @@ public final class PreparedSQLRouter {
return routeEngine.route(logicSQL, sqlContext, parameters);
}
}
......@@ -39,7 +39,6 @@ import com.dangdang.ddframe.rdb.sharding.router.single.SingleTableRouter;
import com.google.common.base.Function;
import com.google.common.collect.Collections2;
import com.google.common.collect.Sets;
import lombok.Getter;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
......@@ -55,19 +54,18 @@ import java.util.Set;
@Slf4j
public final class RouteEngine {
@Getter
private final ShardingRule shardingRule;
private final DatabaseType databaseType;
SQLContext parse(final String logicSQL, final List<Object> parameters) {
SQLParsingEngine sqlParsingEngine = new SQLParsingEngine(databaseType, logicSQL, shardingRule);
SQLParsingEngine parsingEngine = new SQLParsingEngine(databaseType, logicSQL, shardingRule);
if (HintManagerHolder.isDatabaseShardingOnly()) {
return sqlParsingEngine.prepareParse();
return parsingEngine.prepareParse();
}
Context context = MetricsContext.start("Parse SQL");
log.debug("Logic SQL: {}, {}", logicSQL, parameters);
SQLContext result = sqlParsingEngine.parse();
SQLContext result = parsingEngine.parse();
MetricsContext.stop(context);
if (result instanceof InsertSQLContext) {
GenerateKeysUtils.appendGenerateKeys(shardingRule, parameters, (InsertSQLContext) result);
......
......@@ -55,8 +55,7 @@ public class DatabaseRouter {
Optional<ShardingValue<?>> shardingValueOptional = HintManagerHolder.getDatabaseShardingValue(new ShardingKey(HintManagerHolder.DB_TABLE_NAME, HintManagerHolder.DB_COLUMN_NAME));
Preconditions.checkState(shardingValueOptional.isPresent());
log.debug("Before database sharding only db:{} sharding values: {}", dataSourceRule.getDataSourceNames(), shardingValueOptional.get());
Collection<String> routedResult = databaseShardingStrategy
.doStaticSharding(sqlType, dataSourceRule.getDataSourceNames(), Collections.<ShardingValue<?>>singleton(shardingValueOptional.get()));
Collection<String> routedResult = databaseShardingStrategy.doStaticSharding(sqlType, dataSourceRule.getDataSourceNames(), Collections.<ShardingValue<?>>singleton(shardingValueOptional.get()));
Preconditions.checkState(!routedResult.isEmpty(), "no database route info");
log.debug("After database sharding only result: {}", routedResult);
return new DatabaseRoutingResult(routedResult);
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册