Loading sharding-jdbc-config-parent/sharding-jdbc-config-common/src/main/java/com/dangdang/ddframe/rdb/sharding/config/common/api/ShardingRuleBuilder.java +10 −2 Original line number Diff line number Diff line Loading @@ -27,7 +27,11 @@ import com.dangdang.ddframe.rdb.sharding.api.strategy.database.SingleKeyDatabase import com.dangdang.ddframe.rdb.sharding.api.strategy.table.MultipleKeysTableShardingAlgorithm; import com.dangdang.ddframe.rdb.sharding.api.strategy.table.SingleKeyTableShardingAlgorithm; import com.dangdang.ddframe.rdb.sharding.api.strategy.table.TableShardingStrategy; import com.dangdang.ddframe.rdb.sharding.config.common.api.config.*; import com.dangdang.ddframe.rdb.sharding.config.common.api.config.BindingTableRuleConfig; import com.dangdang.ddframe.rdb.sharding.config.common.api.config.GenerateKeyColumnConfig; import com.dangdang.ddframe.rdb.sharding.config.common.api.config.ShardingRuleConfig; import com.dangdang.ddframe.rdb.sharding.config.common.api.config.StrategyConfig; import com.dangdang.ddframe.rdb.sharding.config.common.api.config.TableRuleConfig; import com.dangdang.ddframe.rdb.sharding.config.common.internal.algorithm.ClosureDatabaseShardingAlgorithm; import com.dangdang.ddframe.rdb.sharding.config.common.internal.algorithm.ClosureTableShardingAlgorithm; import com.dangdang.ddframe.rdb.sharding.config.common.internal.parser.InlineParser; Loading @@ -42,7 +46,11 @@ import com.google.common.base.Strings; import com.google.common.collect.Lists; import javax.sql.DataSource; import java.util.*; import java.util.ArrayList; import java.util.Collection; import java.util.Collections; import java.util.List; import java.util.Map; import java.util.Map.Entry; /** Loading sharding-jdbc-core/src/test/java/com/dangdang/ddframe/rdb/integrate/single/AbstractSingleResultSetDBUnitTest.java +2 −2 Original line number Diff line number Diff line Loading @@ -62,8 +62,8 @@ public abstract class AbstractSingleResultSetDBUnitTest extends AbstractDBUnitTe "t_order_3")).dataSourceRule(dataSourceRule).build(); ShardingRule shardingRule = ShardingRule.builder() .dataSourceRule(dataSourceRule) .tableRules(Arrays.asList(orderTableRule)) .bindingTableRules(Collections.singletonList(new BindingTableRule(Arrays.asList(orderTableRule)))) .tableRules(Collections.singletonList(orderTableRule)) .bindingTableRules(Collections.singletonList(new BindingTableRule(Collections.singletonList(orderTableRule)))) .databaseShardingStrategy(new DatabaseShardingStrategy("user_id", new NoneDatabaseShardingAlgorithm())) .tableShardingStrategy(new TableShardingStrategy("order_id", new SingleKeyModuloTableShardingAlgorithm())).build(); shardingDataSource = new ShardingDataSource(shardingRule); Loading sharding-jdbc-core/src/test/java/com/dangdang/ddframe/rdb/sharding/jdbc/adapter/invocation/JdbcMethodInvocationTest.java +0 −1 Original line number Diff line number Diff line Loading @@ -18,7 +18,6 @@ package com.dangdang.ddframe.rdb.sharding.jdbc.adapter.invocation; import com.dangdang.ddframe.rdb.sharding.exception.ShardingJdbcException; import com.dangdang.ddframe.rdb.sharding.jdbc.adapter.invocation.JdbcMethodInvocation; import org.junit.Test; public final class JdbcMethodInvocationTest { Loading sharding-jdbc-core/src/test/java/com/dangdang/ddframe/rdb/sharding/parsing/parser/statement/AllStatementParserTests.java +1 −1 Original line number Diff line number Diff line Loading @@ -24,7 +24,7 @@ import org.junit.runners.Suite; @Suite.SuiteClasses({ InsertStatementParserTest.class, UpdateStatementParserTest.class, DeleteStatementParserTest.class, DeleteStatementParserTest.class }) public class AllStatementParserTests { } sharding-jdbc-core/src/test/java/com/dangdang/ddframe/rdb/sharding/parsing/parser/statement/InsertStatementParserTest.java +1 −1 Original line number Diff line number Diff line Loading @@ -92,7 +92,7 @@ public final class InsertStatementParserTest extends AbstractStatementParserTest } @Test public void assertparseWithGenerateKeyColumnsWithParameter() throws SQLException { public void assertParseWithGenerateKeyColumnsWithParameter() throws SQLException { String sql = "INSERT INTO `TABLE_XXX` (`field1`) VALUES (?)"; ShardingRule shardingRule = createShardingRuleWithGenerateKeyColumns(); SQLParsingEngine statementParser = new SQLParsingEngine(DatabaseType.MySQL, "INSERT INTO `TABLE_XXX` (`field1`) VALUES (?)", shardingRule); Loading Loading
sharding-jdbc-config-parent/sharding-jdbc-config-common/src/main/java/com/dangdang/ddframe/rdb/sharding/config/common/api/ShardingRuleBuilder.java +10 −2 Original line number Diff line number Diff line Loading @@ -27,7 +27,11 @@ import com.dangdang.ddframe.rdb.sharding.api.strategy.database.SingleKeyDatabase import com.dangdang.ddframe.rdb.sharding.api.strategy.table.MultipleKeysTableShardingAlgorithm; import com.dangdang.ddframe.rdb.sharding.api.strategy.table.SingleKeyTableShardingAlgorithm; import com.dangdang.ddframe.rdb.sharding.api.strategy.table.TableShardingStrategy; import com.dangdang.ddframe.rdb.sharding.config.common.api.config.*; import com.dangdang.ddframe.rdb.sharding.config.common.api.config.BindingTableRuleConfig; import com.dangdang.ddframe.rdb.sharding.config.common.api.config.GenerateKeyColumnConfig; import com.dangdang.ddframe.rdb.sharding.config.common.api.config.ShardingRuleConfig; import com.dangdang.ddframe.rdb.sharding.config.common.api.config.StrategyConfig; import com.dangdang.ddframe.rdb.sharding.config.common.api.config.TableRuleConfig; import com.dangdang.ddframe.rdb.sharding.config.common.internal.algorithm.ClosureDatabaseShardingAlgorithm; import com.dangdang.ddframe.rdb.sharding.config.common.internal.algorithm.ClosureTableShardingAlgorithm; import com.dangdang.ddframe.rdb.sharding.config.common.internal.parser.InlineParser; Loading @@ -42,7 +46,11 @@ import com.google.common.base.Strings; import com.google.common.collect.Lists; import javax.sql.DataSource; import java.util.*; import java.util.ArrayList; import java.util.Collection; import java.util.Collections; import java.util.List; import java.util.Map; import java.util.Map.Entry; /** Loading
sharding-jdbc-core/src/test/java/com/dangdang/ddframe/rdb/integrate/single/AbstractSingleResultSetDBUnitTest.java +2 −2 Original line number Diff line number Diff line Loading @@ -62,8 +62,8 @@ public abstract class AbstractSingleResultSetDBUnitTest extends AbstractDBUnitTe "t_order_3")).dataSourceRule(dataSourceRule).build(); ShardingRule shardingRule = ShardingRule.builder() .dataSourceRule(dataSourceRule) .tableRules(Arrays.asList(orderTableRule)) .bindingTableRules(Collections.singletonList(new BindingTableRule(Arrays.asList(orderTableRule)))) .tableRules(Collections.singletonList(orderTableRule)) .bindingTableRules(Collections.singletonList(new BindingTableRule(Collections.singletonList(orderTableRule)))) .databaseShardingStrategy(new DatabaseShardingStrategy("user_id", new NoneDatabaseShardingAlgorithm())) .tableShardingStrategy(new TableShardingStrategy("order_id", new SingleKeyModuloTableShardingAlgorithm())).build(); shardingDataSource = new ShardingDataSource(shardingRule); Loading
sharding-jdbc-core/src/test/java/com/dangdang/ddframe/rdb/sharding/jdbc/adapter/invocation/JdbcMethodInvocationTest.java +0 −1 Original line number Diff line number Diff line Loading @@ -18,7 +18,6 @@ package com.dangdang.ddframe.rdb.sharding.jdbc.adapter.invocation; import com.dangdang.ddframe.rdb.sharding.exception.ShardingJdbcException; import com.dangdang.ddframe.rdb.sharding.jdbc.adapter.invocation.JdbcMethodInvocation; import org.junit.Test; public final class JdbcMethodInvocationTest { Loading
sharding-jdbc-core/src/test/java/com/dangdang/ddframe/rdb/sharding/parsing/parser/statement/AllStatementParserTests.java +1 −1 Original line number Diff line number Diff line Loading @@ -24,7 +24,7 @@ import org.junit.runners.Suite; @Suite.SuiteClasses({ InsertStatementParserTest.class, UpdateStatementParserTest.class, DeleteStatementParserTest.class, DeleteStatementParserTest.class }) public class AllStatementParserTests { }
sharding-jdbc-core/src/test/java/com/dangdang/ddframe/rdb/sharding/parsing/parser/statement/InsertStatementParserTest.java +1 −1 Original line number Diff line number Diff line Loading @@ -92,7 +92,7 @@ public final class InsertStatementParserTest extends AbstractStatementParserTest } @Test public void assertparseWithGenerateKeyColumnsWithParameter() throws SQLException { public void assertParseWithGenerateKeyColumnsWithParameter() throws SQLException { String sql = "INSERT INTO `TABLE_XXX` (`field1`) VALUES (?)"; ShardingRule shardingRule = createShardingRuleWithGenerateKeyColumns(); SQLParsingEngine statementParser = new SQLParsingEngine(DatabaseType.MySQL, "INSERT INTO `TABLE_XXX` (`field1`) VALUES (?)", shardingRule); Loading