diff --git a/README_ZH.md b/README_ZH.md index f153b3504588f64d1f5e41bbbd0a3a997722efa3..d64a7fdbcca9b9cebe8345c59059aad9824de8aa 100644 --- a/README_ZH.md +++ b/README_ZH.md @@ -135,8 +135,8 @@ try ( - - + + diff --git a/sharding-jdbc-core/src/main/java/io/shardingjdbc/core/api/config/TableRuleConfiguration.java b/sharding-jdbc-core/src/main/java/io/shardingjdbc/core/api/config/TableRuleConfiguration.java index 1549686308c8cbe3f533649a84e1423708889647..d1935a13b6b99063d18a7c7cc7a6d3b6656279a5 100644 --- a/sharding-jdbc-core/src/main/java/io/shardingjdbc/core/api/config/TableRuleConfiguration.java +++ b/sharding-jdbc-core/src/main/java/io/shardingjdbc/core/api/config/TableRuleConfiguration.java @@ -43,7 +43,7 @@ public class TableRuleConfiguration { private String logicTable; - private String actualTables; + private String actualDataNodes; private ShardingStrategyConfiguration databaseShardingStrategyConfig; @@ -61,10 +61,10 @@ public class TableRuleConfiguration { */ public TableRule build(final Map dataSourceMap) { Preconditions.checkNotNull(logicTable, "Logic table cannot be null."); - List actualTables = new InlineExpressionParser(this.actualTables).evaluate(); + List actualDataNodes = new InlineExpressionParser(this.actualDataNodes).evaluate(); ShardingStrategy databaseShardingStrategy = null == databaseShardingStrategyConfig ? null : databaseShardingStrategyConfig.build(); ShardingStrategy tableShardingStrategy = null == tableShardingStrategyConfig ? null : tableShardingStrategyConfig.build(); KeyGenerator keyGenerator = !Strings.isNullOrEmpty(keyGeneratorColumnName) && !Strings.isNullOrEmpty(keyGeneratorClass) ? KeyGeneratorFactory.newInstance(keyGeneratorClass) : null; - return new TableRule(logicTable, actualTables, dataSourceMap, databaseShardingStrategy, tableShardingStrategy, keyGeneratorColumnName, keyGenerator); + return new TableRule(logicTable, actualDataNodes, dataSourceMap, databaseShardingStrategy, tableShardingStrategy, keyGeneratorColumnName, keyGenerator); } } diff --git a/sharding-jdbc-core/src/main/java/io/shardingjdbc/core/rule/TableRule.java b/sharding-jdbc-core/src/main/java/io/shardingjdbc/core/rule/TableRule.java index 5c60f8f8b768f9f34edfe979218d55522798c615..428bee5e42608bdc289fc5199d277694efec89d9 100644 --- a/sharding-jdbc-core/src/main/java/io/shardingjdbc/core/rule/TableRule.java +++ b/sharding-jdbc-core/src/main/java/io/shardingjdbc/core/rule/TableRule.java @@ -51,10 +51,10 @@ public final class TableRule { private final KeyGenerator keyGenerator; - public TableRule(final String logicTable, final List actualTables, final Map dataSourceMap, + public TableRule(final String logicTable, final List actualDataNodes, final Map dataSourceMap, final ShardingStrategy databaseShardingStrategy, final ShardingStrategy tableShardingStrategy, final String generateKeyColumn, final KeyGenerator keyGenerator) { this.logicTable = logicTable; - this.actualDataNodes = null == actualTables || actualTables.isEmpty() ? generateDataNodes(logicTable, dataSourceMap) : generateDataNodes(actualTables, dataSourceMap); + this.actualDataNodes = null == actualDataNodes || actualDataNodes.isEmpty() ? generateDataNodes(logicTable, dataSourceMap) : generateDataNodes(actualDataNodes, dataSourceMap); this.databaseShardingStrategy = databaseShardingStrategy; this.tableShardingStrategy = tableShardingStrategy; this.generateKeyColumn = generateKeyColumn; @@ -69,13 +69,13 @@ public final class TableRule { return result; } - private List generateDataNodes(final List actualTables, final Map dataSourceMap) { + private List generateDataNodes(final List actualDataNodes, final Map dataSourceMap) { List result = new LinkedList<>(); - for (String actualTable : actualTables) { - Preconditions.checkArgument(DataNode.isValidDataNode(actualTable), String.format("Invalid format for actual data nodes: '%s'", actualTable)); - DataNode dataNode = new DataNode(actualTable); + for (String each : actualDataNodes) { + Preconditions.checkArgument(DataNode.isValidDataNode(each), String.format("Invalid format for actual data nodes: '%s'", each)); + DataNode dataNode = new DataNode(each); Preconditions.checkArgument(dataSourceMap.containsKey(dataNode.getDataSourceName()), - String.format("Cannot find data source name in sharding rule, invalid actual data node is: '%s'", actualTable)); + String.format("Cannot find data source name in sharding rule, invalid actual data node is: '%s'", each)); result.add(dataNode); } return result; diff --git a/sharding-jdbc-core/src/main/java/io/shardingjdbc/core/yaml/sharding/YamlTableRuleConfiguration.java b/sharding-jdbc-core/src/main/java/io/shardingjdbc/core/yaml/sharding/YamlTableRuleConfiguration.java index 21707c6e14cdd40f2bc7b260ca18892ca64f636c..e78f2c969e9d206d21cfd69b5d68bf27ab0220c0 100644 --- a/sharding-jdbc-core/src/main/java/io/shardingjdbc/core/yaml/sharding/YamlTableRuleConfiguration.java +++ b/sharding-jdbc-core/src/main/java/io/shardingjdbc/core/yaml/sharding/YamlTableRuleConfiguration.java @@ -16,9 +16,7 @@ public class YamlTableRuleConfiguration { private String logicTable; - private String actualTables; - - private String dataSourceNames; + private String actualDataNodes; private YamlShardingStrategyConfiguration databaseStrategy; @@ -37,7 +35,7 @@ public class YamlTableRuleConfiguration { Preconditions.checkNotNull(logicTable, "Logic table cannot be null."); TableRuleConfiguration tableRuleConfig = new TableRuleConfiguration(); tableRuleConfig.setLogicTable(logicTable); - tableRuleConfig.setActualTables(actualTables); + tableRuleConfig.setActualDataNodes(actualDataNodes); tableRuleConfig.setLogicTable(logicTable); if (null != databaseStrategy) { tableRuleConfig.setDatabaseShardingStrategyConfig(databaseStrategy.build()); diff --git a/sharding-jdbc-core/src/test/java/io/shardingjdbc/core/api/ShardingDataSourceFactoryTest.java b/sharding-jdbc-core/src/test/java/io/shardingjdbc/core/api/ShardingDataSourceFactoryTest.java index 79c9952ebb41c2d042c9e62fc91fea9e19721d72..ebe2e2debf69a1380ff3fde80c3763afe7ff0df4 100644 --- a/sharding-jdbc-core/src/test/java/io/shardingjdbc/core/api/ShardingDataSourceFactoryTest.java +++ b/sharding-jdbc-core/src/test/java/io/shardingjdbc/core/api/ShardingDataSourceFactoryTest.java @@ -71,7 +71,7 @@ public final class ShardingDataSourceFactoryTest { ShardingRuleConfiguration result = new ShardingRuleConfiguration(); TableRuleConfiguration tableRuleConfig = new TableRuleConfiguration(); tableRuleConfig.setLogicTable("logicTable"); - tableRuleConfig.setActualTables("ds.table_${0..2}"); + tableRuleConfig.setActualDataNodes("ds.table_${0..2}"); result.getTableRuleConfigs().add(tableRuleConfig); return result; } diff --git a/sharding-jdbc-core/src/test/java/io/shardingjdbc/core/api/fixture/ShardingRuleMockBuilder.java b/sharding-jdbc-core/src/test/java/io/shardingjdbc/core/api/fixture/ShardingRuleMockBuilder.java index fbeb783355954e06b74c12fe7220196e16fb9c14..6e9bafb2b4a1515974436dc185a3137d6e249fdb 100644 --- a/sharding-jdbc-core/src/test/java/io/shardingjdbc/core/api/fixture/ShardingRuleMockBuilder.java +++ b/sharding-jdbc-core/src/test/java/io/shardingjdbc/core/api/fixture/ShardingRuleMockBuilder.java @@ -77,7 +77,7 @@ public class ShardingRuleMockBuilder { public TableRuleConfiguration apply(final String input) { TableRuleConfiguration result = new TableRuleConfiguration(); result.setLogicTable(input); - result.setActualTables("db0." + input + ",db1." + input); + result.setActualDataNodes("db0." + input + ",db1." + input); result.setKeyGeneratorColumnName(generateKeyColumnsMap.get(input)); return result; } @@ -86,7 +86,7 @@ public class ShardingRuleMockBuilder { if (tableRuleConfigs.isEmpty()) { TableRuleConfiguration tableRuleConfig = new TableRuleConfiguration(); tableRuleConfig.setLogicTable("mock"); - tableRuleConfig.setActualTables("mock"); + tableRuleConfig.setActualDataNodes("mock"); tableRuleConfigs.add(tableRuleConfig); } ShardingRuleConfiguration shardingRuleConfig = new ShardingRuleConfiguration(); diff --git a/sharding-jdbc-core/src/test/java/io/shardingjdbc/core/common/base/AbstractShardingJDBCDatabaseAndTableTest.java b/sharding-jdbc-core/src/test/java/io/shardingjdbc/core/common/base/AbstractShardingJDBCDatabaseAndTableTest.java index 6b7863966d894d355ab0cef20554e887c02af629..8b5087abb5d1309ab78270bc6875f1932983f68d 100644 --- a/sharding-jdbc-core/src/test/java/io/shardingjdbc/core/common/base/AbstractShardingJDBCDatabaseAndTableTest.java +++ b/sharding-jdbc-core/src/test/java/io/shardingjdbc/core/common/base/AbstractShardingJDBCDatabaseAndTableTest.java @@ -63,7 +63,7 @@ public abstract class AbstractShardingJDBCDatabaseAndTableTest extends AbstractS for (String dataSourceName : entry.getValue().keySet()) { orderActualDataNodes.add(dataSourceName + ".t_order_${0..1}"); } - orderTableRuleConfig.setActualTables(Joiner.on(",").join(orderActualDataNodes)); + orderTableRuleConfig.setActualDataNodes(Joiner.on(",").join(orderActualDataNodes)); shardingRuleConfig.getTableRuleConfigs().add(orderTableRuleConfig); TableRuleConfiguration orderItemTableRuleConfig = new TableRuleConfiguration(); orderItemTableRuleConfig.setLogicTable("t_order_item"); @@ -71,7 +71,7 @@ public abstract class AbstractShardingJDBCDatabaseAndTableTest extends AbstractS for (String dataSourceName : entry.getValue().keySet()) { orderItemActualDataNodes.add(dataSourceName + ".t_order_item_${0..1}"); } - orderItemTableRuleConfig.setActualTables(Joiner.on(",").join(orderItemActualDataNodes)); + orderItemTableRuleConfig.setActualDataNodes(Joiner.on(",").join(orderItemActualDataNodes)); orderItemTableRuleConfig.setKeyGeneratorColumnName("item_id"); orderItemTableRuleConfig.setKeyGeneratorClass(IncrementKeyGenerator.class.getName()); shardingRuleConfig.getTableRuleConfigs().add(orderItemTableRuleConfig); diff --git a/sharding-jdbc-core/src/test/java/io/shardingjdbc/core/integrate/type/sharding/ShardingDatabaseAndTableTest.java b/sharding-jdbc-core/src/test/java/io/shardingjdbc/core/integrate/type/sharding/ShardingDatabaseAndTableTest.java index 6b3f53a0b2a50c829db8a9770d1324d26d5f05b6..a4aa7fc3c137bde91cf75ebff5818fc437f4231d 100644 --- a/sharding-jdbc-core/src/test/java/io/shardingjdbc/core/integrate/type/sharding/ShardingDatabaseAndTableTest.java +++ b/sharding-jdbc-core/src/test/java/io/shardingjdbc/core/integrate/type/sharding/ShardingDatabaseAndTableTest.java @@ -86,7 +86,7 @@ public class ShardingDatabaseAndTableTest extends AbstractSQLAssertTest { for (String dataSourceName : entry.getValue().keySet()) { orderActualDataNodes.add(dataSourceName + ".t_order_${0..9}"); } - orderTableRuleConfig.setActualTables(Joiner.on(",").join(orderActualDataNodes)); + orderTableRuleConfig.setActualDataNodes(Joiner.on(",").join(orderActualDataNodes)); shardingRuleConfig.getTableRuleConfigs().add(orderTableRuleConfig); TableRuleConfiguration orderItemTableRuleConfig = new TableRuleConfiguration(); orderItemTableRuleConfig.setLogicTable("t_order_item"); @@ -94,7 +94,7 @@ public class ShardingDatabaseAndTableTest extends AbstractSQLAssertTest { for (String dataSourceName : entry.getValue().keySet()) { orderItemActualDataNodes.add(dataSourceName + ".t_order_item_${0..9}"); } - orderItemTableRuleConfig.setActualTables(Joiner.on(",").join(orderItemActualDataNodes)); + orderItemTableRuleConfig.setActualDataNodes(Joiner.on(",").join(orderItemActualDataNodes)); shardingRuleConfig.getTableRuleConfigs().add(orderItemTableRuleConfig); TableRuleConfiguration configTableRuleConfig = new TableRuleConfiguration(); configTableRuleConfig.setLogicTable("t_config"); diff --git a/sharding-jdbc-core/src/test/java/io/shardingjdbc/core/integrate/type/sharding/ShardingMasterSlaveTest.java b/sharding-jdbc-core/src/test/java/io/shardingjdbc/core/integrate/type/sharding/ShardingMasterSlaveTest.java index 946b482b004b3af2c671a4055bc4fcb6676f3d3f..21856f0362417979f222858370e882a6b23f01f8 100644 --- a/sharding-jdbc-core/src/test/java/io/shardingjdbc/core/integrate/type/sharding/ShardingMasterSlaveTest.java +++ b/sharding-jdbc-core/src/test/java/io/shardingjdbc/core/integrate/type/sharding/ShardingMasterSlaveTest.java @@ -99,7 +99,7 @@ public class ShardingMasterSlaveTest extends AbstractSQLAssertTest { for (String dataSourceName : masterSlaveDataSourceMap.keySet()) { orderActualDataNodes.add(dataSourceName + ".t_order_${0..9}"); } - orderTableRuleConfig.setActualTables(Joiner.on(",").join(orderActualDataNodes)); + orderTableRuleConfig.setActualDataNodes(Joiner.on(",").join(orderActualDataNodes)); shardingRuleConfig.getTableRuleConfigs().add(orderTableRuleConfig); TableRuleConfiguration orderItemTableRuleConfig = new TableRuleConfiguration(); orderItemTableRuleConfig.setLogicTable("t_order_item"); @@ -107,7 +107,7 @@ public class ShardingMasterSlaveTest extends AbstractSQLAssertTest { for (String dataSourceName : masterSlaveDataSourceMap.keySet()) { itemOrderActualDataNodes.add(dataSourceName + ".t_order_item_${0..9}"); } - orderItemTableRuleConfig.setActualTables(Joiner.on(",").join(itemOrderActualDataNodes)); + orderItemTableRuleConfig.setActualDataNodes(Joiner.on(",").join(itemOrderActualDataNodes)); shardingRuleConfig.getTableRuleConfigs().add(orderItemTableRuleConfig); TableRuleConfiguration configTableRuleConfig = new TableRuleConfiguration(); configTableRuleConfig.setLogicTable("t_config"); diff --git a/sharding-jdbc-core/src/test/java/io/shardingjdbc/core/integrate/type/sharding/ShardingTableOnlyTest.java b/sharding-jdbc-core/src/test/java/io/shardingjdbc/core/integrate/type/sharding/ShardingTableOnlyTest.java index 2663b7d36f15c9bacb7aeb84ec80b8bc9ad328c3..e53a33856404a275cae9d2f287606443591abc04 100644 --- a/sharding-jdbc-core/src/test/java/io/shardingjdbc/core/integrate/type/sharding/ShardingTableOnlyTest.java +++ b/sharding-jdbc-core/src/test/java/io/shardingjdbc/core/integrate/type/sharding/ShardingTableOnlyTest.java @@ -75,7 +75,7 @@ public class ShardingTableOnlyTest extends AbstractSQLAssertTest { for (String dataSourceName : entry.getValue().keySet()) { orderActualDataNodes.add(dataSourceName + ".t_order_${0..9}"); } - orderTableRuleConfig.setActualTables(Joiner.on(",").join(orderActualDataNodes)); + orderTableRuleConfig.setActualDataNodes(Joiner.on(",").join(orderActualDataNodes)); shardingRuleConfig.getTableRuleConfigs().add(orderTableRuleConfig); TableRuleConfiguration orderItemTableRuleConfig = new TableRuleConfiguration(); orderItemTableRuleConfig.setLogicTable("t_order_item"); @@ -83,7 +83,7 @@ public class ShardingTableOnlyTest extends AbstractSQLAssertTest { for (String dataSourceName : entry.getValue().keySet()) { orderItemActualDataNodes.add(dataSourceName + ".t_order_item_${0..9}"); } - orderItemTableRuleConfig.setActualTables(Joiner.on(",").join(orderItemActualDataNodes)); + orderItemTableRuleConfig.setActualDataNodes(Joiner.on(",").join(orderItemActualDataNodes)); orderItemTableRuleConfig.setKeyGeneratorClass("item_id"); shardingRuleConfig.getTableRuleConfigs().add(orderItemTableRuleConfig); shardingRuleConfig.getBindingTableGroups().add("t_order, t_order_item"); diff --git a/sharding-jdbc-core/src/test/java/io/shardingjdbc/core/jdbc/core/datasource/ShardingDataSourceTest.java b/sharding-jdbc-core/src/test/java/io/shardingjdbc/core/jdbc/core/datasource/ShardingDataSourceTest.java index 5150f2073bb0e1dd9753cbfe466103479e68427b..42261657c911309e5ad57e386827574f0c73f3d0 100644 --- a/sharding-jdbc-core/src/test/java/io/shardingjdbc/core/jdbc/core/datasource/ShardingDataSourceTest.java +++ b/sharding-jdbc-core/src/test/java/io/shardingjdbc/core/jdbc/core/datasource/ShardingDataSourceTest.java @@ -194,7 +194,7 @@ public final class ShardingDataSourceTest { for (String each : dataSourceMap.keySet()) { orderActualDataNodes.add(each + ".table_${0..2}"); } - tableRuleConfig.setActualTables(Joiner.on(",").join(orderActualDataNodes)); + tableRuleConfig.setActualDataNodes(Joiner.on(",").join(orderActualDataNodes)); result.getTableRuleConfigs().add(tableRuleConfig); return result; } diff --git a/sharding-jdbc-core/src/test/java/io/shardingjdbc/core/parsing/SQLParsingEngineTest.java b/sharding-jdbc-core/src/test/java/io/shardingjdbc/core/parsing/SQLParsingEngineTest.java index 123c180df630e6d10c478dbadd183b104465971d..5c38651bdd8aa30169b265a7288f6372e6fb8c2d 100644 --- a/sharding-jdbc-core/src/test/java/io/shardingjdbc/core/parsing/SQLParsingEngineTest.java +++ b/sharding-jdbc-core/src/test/java/io/shardingjdbc/core/parsing/SQLParsingEngineTest.java @@ -68,11 +68,11 @@ public final class SQLParsingEngineTest extends AbstractBaseParseSQLTest { private ShardingRule buildShardingRule() throws SQLException { TableRuleConfiguration orderTableRuleConfig = new TableRuleConfiguration(); orderTableRuleConfig.setLogicTable("t_order"); - orderTableRuleConfig.setActualTables("db0.t_order,db1.t_order"); + orderTableRuleConfig.setActualDataNodes("db0.t_order,db1.t_order"); orderTableRuleConfig.setTableShardingStrategyConfig(new ComplexShardingStrategyConfiguration("user_id, order_id", TestComplexKeysShardingAlgorithm.class.getName())); TableRuleConfiguration orderItemTableRuleConfig = new TableRuleConfiguration(); orderItemTableRuleConfig.setLogicTable("t_order_item"); - orderItemTableRuleConfig.setActualTables("db0.t_order_item,db1.t_order_item"); + orderItemTableRuleConfig.setActualDataNodes("db0.t_order_item,db1.t_order_item"); orderItemTableRuleConfig.setTableShardingStrategyConfig(new ComplexShardingStrategyConfiguration("user_id, order_id, item_id", TestComplexKeysShardingAlgorithm.class.getName())); return new ShardingRuleMockBuilder().addTableRuleConfig(orderTableRuleConfig).addTableRuleConfig(orderItemTableRuleConfig) .addShardingColumns("user_id").addShardingColumns("order_id").addShardingColumns("item_id").addGenerateKeyColumn("t_order_item", "item_id").build(); diff --git a/sharding-jdbc-core/src/test/java/io/shardingjdbc/core/parsing/parser/sql/AbstractStatementParserTest.java b/sharding-jdbc-core/src/test/java/io/shardingjdbc/core/parsing/parser/sql/AbstractStatementParserTest.java index dacffad03f72a75844724913d279ee4ff7a42eef..17acccb16faa6f452ef54a44b6e7a677174c1fca 100644 --- a/sharding-jdbc-core/src/test/java/io/shardingjdbc/core/parsing/parser/sql/AbstractStatementParserTest.java +++ b/sharding-jdbc-core/src/test/java/io/shardingjdbc/core/parsing/parser/sql/AbstractStatementParserTest.java @@ -48,7 +48,7 @@ public abstract class AbstractStatementParserTest { } TableRuleConfiguration tableRuleConfig = new TableRuleConfiguration(); tableRuleConfig.setLogicTable("TABLE_XXX"); - tableRuleConfig.setActualTables("ds.table_${0..2}"); + tableRuleConfig.setActualDataNodes("ds.table_${0..2}"); tableRuleConfig.setTableShardingStrategyConfig( new ComplexShardingStrategyConfiguration("field1, field2, field3, field4, field5, field6, field7", TestComplexKeysShardingAlgorithm.class.getName())); ShardingRuleConfiguration shardingRuleConfig = new ShardingRuleConfiguration(); diff --git a/sharding-jdbc-core/src/test/java/io/shardingjdbc/core/parsing/parser/sql/InsertStatementParserTest.java b/sharding-jdbc-core/src/test/java/io/shardingjdbc/core/parsing/parser/sql/InsertStatementParserTest.java index 4ea53d4475f13457b4643e2c0ef0bd53a47b1581..5f040f4fb17a710a294443be57b8b65cae235c9c 100644 --- a/sharding-jdbc-core/src/test/java/io/shardingjdbc/core/parsing/parser/sql/InsertStatementParserTest.java +++ b/sharding-jdbc-core/src/test/java/io/shardingjdbc/core/parsing/parser/sql/InsertStatementParserTest.java @@ -110,7 +110,7 @@ public final class InsertStatementParserTest extends AbstractStatementParserTest final ShardingRuleConfiguration shardingRuleConfig = new ShardingRuleConfiguration(); TableRuleConfiguration tableRuleConfig = new TableRuleConfiguration(); tableRuleConfig.setLogicTable("TABLE_XXX"); - tableRuleConfig.setActualTables("ds.table_${0..2}"); + tableRuleConfig.setActualDataNodes("ds.table_${0..2}"); tableRuleConfig.setTableShardingStrategyConfig(new ComplexShardingStrategyConfiguration("field1", TestComplexKeysShardingAlgorithm.class.getName())); tableRuleConfig.setKeyGeneratorColumnName("field2"); shardingRuleConfig.getTableRuleConfigs().add(tableRuleConfig); diff --git a/sharding-jdbc-core/src/test/java/io/shardingjdbc/core/rule/BindingTableRuleTest.java b/sharding-jdbc-core/src/test/java/io/shardingjdbc/core/rule/BindingTableRuleTest.java index 420e05fb4827d319ccacb8a860ac08b5b3f15f79..b8065a1ab7bac6c3a018d298adc80a4a016f0f6f 100644 --- a/sharding-jdbc-core/src/test/java/io/shardingjdbc/core/rule/BindingTableRuleTest.java +++ b/sharding-jdbc-core/src/test/java/io/shardingjdbc/core/rule/BindingTableRuleTest.java @@ -74,14 +74,14 @@ public final class BindingTableRuleTest { private TableRule createTableRule() { TableRuleConfiguration tableRuleConfig = new TableRuleConfiguration(); tableRuleConfig.setLogicTable("logicTable"); - tableRuleConfig.setActualTables("ds1.table_0, ds1.table_1, ds2.table_0, ds2.table_1"); + tableRuleConfig.setActualDataNodes("ds1.table_0, ds1.table_1, ds2.table_0, ds2.table_1"); return tableRuleConfig.build(createDataSourceMap()); } private TableRule createSubTableRule() { TableRuleConfiguration tableRuleConfig = new TableRuleConfiguration(); tableRuleConfig.setLogicTable("subLogicTable"); - tableRuleConfig.setActualTables("ds1.sub_table_0, ds1.sub_table_1, ds2.sub_table_0, ds2.sub_table_1"); + tableRuleConfig.setActualDataNodes("ds1.sub_table_0, ds1.sub_table_1, ds2.sub_table_0, ds2.sub_table_1"); return tableRuleConfig.build(createDataSourceMap()); } diff --git a/sharding-jdbc-core/src/test/java/io/shardingjdbc/core/rule/ShardingRuleTest.java b/sharding-jdbc-core/src/test/java/io/shardingjdbc/core/rule/ShardingRuleTest.java index 2c215f854a52ce0f2cbbcf798327e1ed5c46b295..05532e35a23cf748de67e99c81e601ab996f291b 100644 --- a/sharding-jdbc-core/src/test/java/io/shardingjdbc/core/rule/ShardingRuleTest.java +++ b/sharding-jdbc-core/src/test/java/io/shardingjdbc/core/rule/ShardingRuleTest.java @@ -284,14 +284,14 @@ public final class ShardingRuleTest { private TableRuleConfiguration createTableRuleConfig() { TableRuleConfiguration result = new TableRuleConfiguration(); result.setLogicTable("logicTable"); - result.setActualTables("ds${0..1}.table_${0..2}"); + result.setActualDataNodes("ds${0..1}.table_${0..2}"); return result; } private TableRuleConfiguration createTableRuleConfigWithDatabaseShardingStrategy(final ShardingStrategyConfiguration strategyConfig) { TableRuleConfiguration result = new TableRuleConfiguration(); result.setLogicTable("logicTable"); - result.setActualTables("ds${0..1}.table_${0..2}"); + result.setActualDataNodes("ds${0..1}.table_${0..2}"); result.setDatabaseShardingStrategyConfig(strategyConfig); return result; } @@ -299,7 +299,7 @@ public final class ShardingRuleTest { private TableRuleConfiguration createTableRuleConfigWithTableShardingStrategy(final ShardingStrategyConfiguration strategyConfig) { TableRuleConfiguration result = new TableRuleConfiguration(); result.setLogicTable("logicTable"); - result.setActualTables("ds${0..1}.table_${0..2}"); + result.setActualDataNodes("ds${0..1}.table_${0..2}"); result.setTableShardingStrategyConfig(strategyConfig); return result; } @@ -307,14 +307,14 @@ public final class ShardingRuleTest { private TableRuleConfiguration createSubTableRuleConfig() { TableRuleConfiguration result = new TableRuleConfiguration(); result.setLogicTable("subLogicTable"); - result.setActualTables("ds${0..1}.sub_table_${0..2}"); + result.setActualDataNodes("ds${0..1}.sub_table_${0..2}"); return result; } private TableRuleConfiguration createTableRuleConfigWithAllStrategies() { TableRuleConfiguration result = new TableRuleConfiguration(); result.setLogicTable("logicTable"); - result.setActualTables("ds${0..1}.table_${0..2}"); + result.setActualDataNodes("ds${0..1}.table_${0..2}"); result.setDatabaseShardingStrategyConfig(new StandardShardingStrategyConfiguration("column", TestPreciseShardingAlgorithm.class.getName())); result.setTableShardingStrategyConfig(new NoneShardingStrategyConfiguration()); return result; @@ -323,7 +323,7 @@ public final class ShardingRuleTest { private TableRuleConfiguration createTableRuleConfigWithTableStrategies() { TableRuleConfiguration result = new TableRuleConfiguration(); result.setLogicTable("logicTable"); - result.setActualTables("ds${0..1}.table_${0..2}"); + result.setActualDataNodes("ds${0..1}.table_${0..2}"); result.setTableShardingStrategyConfig(new StandardShardingStrategyConfiguration("column", TestPreciseShardingAlgorithm.class.getName())); return result; } diff --git a/sharding-jdbc-core/src/test/java/io/shardingjdbc/core/rule/TableRuleTest.java b/sharding-jdbc-core/src/test/java/io/shardingjdbc/core/rule/TableRuleTest.java index 79302e06b1024926eba67fc003200c23c62fc35d..07aa6726a2140cc1d04814b7c9716d27d209a2f4 100644 --- a/sharding-jdbc-core/src/test/java/io/shardingjdbc/core/rule/TableRuleTest.java +++ b/sharding-jdbc-core/src/test/java/io/shardingjdbc/core/rule/TableRuleTest.java @@ -42,7 +42,7 @@ public final class TableRuleTest { public void assertTableRuleWithoutDataNode() { TableRuleConfiguration tableRuleConfig = new TableRuleConfiguration(); tableRuleConfig.setLogicTable("logicTable"); - tableRuleConfig.setActualTables("ds${0..1}.table_${0..2}"); + tableRuleConfig.setActualDataNodes("ds${0..1}.table_${0..2}"); TableRule actual = tableRuleConfig.build(createDataSourceMap()); assertActualTable(actual); assertNull(actual.getDatabaseShardingStrategy()); @@ -53,7 +53,7 @@ public final class TableRuleTest { public void assertTableRuleWithDatabaseShardingStrategyWithoutDataNode() { TableRuleConfiguration tableRuleConfig = new TableRuleConfiguration(); tableRuleConfig.setLogicTable("logicTable"); - tableRuleConfig.setActualTables("ds${0..1}.table_${0..2}"); + tableRuleConfig.setActualDataNodes("ds${0..1}.table_${0..2}"); tableRuleConfig.setDatabaseShardingStrategyConfig(new NoneShardingStrategyConfiguration()); TableRule actual = tableRuleConfig.build(createDataSourceMap()); assertActualTable(actual); @@ -65,7 +65,7 @@ public final class TableRuleTest { public void assertTableRuleWithTableShardingStrategyWithoutDataNode() { TableRuleConfiguration tableRuleConfig = new TableRuleConfiguration(); tableRuleConfig.setLogicTable("logicTable"); - tableRuleConfig.setActualTables("ds${0..1}.table_${0..2}"); + tableRuleConfig.setActualDataNodes("ds${0..1}.table_${0..2}"); tableRuleConfig.setTableShardingStrategyConfig(new NoneShardingStrategyConfiguration()); TableRule actual = tableRuleConfig.build(createDataSourceMap()); assertActualTable(actual); @@ -77,7 +77,7 @@ public final class TableRuleTest { public void assertTableRuleWithDataNodeString() { TableRuleConfiguration tableRuleConfig = new TableRuleConfiguration(); tableRuleConfig.setLogicTable("logicTable"); - tableRuleConfig.setActualTables("ds${0..1}.table_${0..2}"); + tableRuleConfig.setActualDataNodes("ds${0..1}.table_${0..2}"); TableRule actual = tableRuleConfig.build(createDataSourceMap()); assertActualTable(actual); assertNull(actual.getDatabaseShardingStrategy()); @@ -88,7 +88,7 @@ public final class TableRuleTest { public void assertTableRuleWithDataSourceNames() { TableRuleConfiguration tableRuleConfig = new TableRuleConfiguration(); tableRuleConfig.setLogicTable("logicTable"); - tableRuleConfig.setActualTables("ds${0..1}.table_${0..2}"); + tableRuleConfig.setActualDataNodes("ds${0..1}.table_${0..2}"); TableRule actual = tableRuleConfig.build(createDataSourceMap()); assertActualTable(actual); assertNull(actual.getDatabaseShardingStrategy()); @@ -109,7 +109,7 @@ public final class TableRuleTest { public void assertGetActualDatasourceNames() { TableRuleConfiguration tableRuleConfig = new TableRuleConfiguration(); tableRuleConfig.setLogicTable("logicTable"); - tableRuleConfig.setActualTables("ds${0..1}.table_${0..2}"); + tableRuleConfig.setActualDataNodes("ds${0..1}.table_${0..2}"); TableRule actual = tableRuleConfig.build(createDataSourceMap()); assertThat(actual.getActualDatasourceNames(), is((Collection) Sets.newLinkedHashSet(Arrays.asList("ds0", "ds1")))); } @@ -118,7 +118,7 @@ public final class TableRuleTest { public void assertGetActualTableNames() { TableRuleConfiguration tableRuleConfig = new TableRuleConfiguration(); tableRuleConfig.setLogicTable("logicTable"); - tableRuleConfig.setActualTables("ds${0..1}.table_${0..2}"); + tableRuleConfig.setActualDataNodes("ds${0..1}.table_${0..2}"); TableRule actual = tableRuleConfig.build(createDataSourceMap()); assertThat(actual.getActualTableNames("ds1"), is((Collection) Sets.newLinkedHashSet(Arrays.asList("table_0", "table_1", "table_2")))); } @@ -127,7 +127,7 @@ public final class TableRuleTest { public void assertFindActualTableIndex() { TableRuleConfiguration tableRuleConfig = new TableRuleConfiguration(); tableRuleConfig.setLogicTable("logicTable"); - tableRuleConfig.setActualTables("ds${0..1}.table_${0..2}"); + tableRuleConfig.setActualDataNodes("ds${0..1}.table_${0..2}"); TableRule actual = tableRuleConfig.build(createDataSourceMap()); assertThat(actual.findActualTableIndex("ds1", "table_1"), is(4)); } @@ -136,7 +136,7 @@ public final class TableRuleTest { public void assertFindActualTableIndexForNotFound() { TableRuleConfiguration tableRuleConfig = new TableRuleConfiguration(); tableRuleConfig.setLogicTable("logicTable"); - tableRuleConfig.setActualTables("ds${0..1}.table_${0..2}"); + tableRuleConfig.setActualDataNodes("ds${0..1}.table_${0..2}"); TableRule actual = tableRuleConfig.build(createDataSourceMap()); assertThat(actual.findActualTableIndex("ds2", "table_2"), is(-1)); } diff --git a/sharding-jdbc-core/src/test/resources/yaml/config/config-all.yaml b/sharding-jdbc-core/src/test/resources/yaml/config/config-all.yaml index b16b2267f53400ec00464f0e12ea118621db6a6d..89ca82753efbe12a9bd210262a54fcc1fe5365ad 100644 --- a/sharding-jdbc-core/src/test/resources/yaml/config/config-all.yaml +++ b/sharding-jdbc-core/src/test/resources/yaml/config/config-all.yaml @@ -18,10 +18,10 @@ defaultKeyGeneratorClass: io.shardingjdbc.core.yaml.fixture.IncrementKeyGenerato tables: config: - actualTables: db${0..1}.config_${0..1} + actualDataNodes: db${0..1}.config_${0..1} t_order: - actualTables: db${0..1}.t_order_${0..1} + actualDataNodes: db${0..1}.t_order_${0..1} databaseStrategy: standard: shardingColumn: order_id @@ -31,7 +31,7 @@ tables: shardingColumn: id algorithmInlineExpression: t_order_${id % 2} t_order_item: - actualTables: db${0..1}.t_order_item_${0..1} + actualDataNodes: db${0..1}.t_order_item_${0..1} keyGeneratorColumnName: order_item_id keyGeneratorClass: io.shardingjdbc.core.yaml.fixture.DecrementKeyGenerator #绑定表中其余的表的策略与第一张表的策略相同 diff --git a/sharding-jdbc-core/src/test/resources/yaml/config/config-bindingError.yaml b/sharding-jdbc-core/src/test/resources/yaml/config/config-bindingError.yaml index 9e117591e777cdebc8f4e4f61f6a131aa13c041d..2f4e14c57fc3620e1f648f0f6123391da4e85e66 100644 --- a/sharding-jdbc-core/src/test/resources/yaml/config/config-bindingError.yaml +++ b/sharding-jdbc-core/src/test/resources/yaml/config/config-bindingError.yaml @@ -1,6 +1,6 @@ tables: t_order: - actualTables: ds.t_order_${0..1} + actualDataNodes: ds.t_order_${0..1} databaseStrategy: standard: shardingColumn: order_id @@ -10,7 +10,7 @@ tables: shardingColumn: id algorithmInlineExpression: t_order_${id % 2} t_order_item: - actualTables: ds.t_order_item_${0..1} + actualDataNodes: ds.t_order_item_${0..1} #绑定表中其余的表的策略与第一张表的策略相同 databaseStrategy: standard: diff --git a/sharding-jdbc-core/src/test/resources/yaml/config/config-classNotFound.yaml b/sharding-jdbc-core/src/test/resources/yaml/config/config-classNotFound.yaml index 12f51ae3c9ca56884c47587706a33147957e83e5..bc7bdba125194ed38827077985331001d1b57738 100644 --- a/sharding-jdbc-core/src/test/resources/yaml/config/config-classNotFound.yaml +++ b/sharding-jdbc-core/src/test/resources/yaml/config/config-classNotFound.yaml @@ -13,7 +13,7 @@ dataSources: maxActive: 100 tables: t_order: - actualTables: t_order_${0..1} + actualDataNodes: t_order_${0..1} tableStrategy: standard: shardingColumn: order_id diff --git a/sharding-jdbc-core/src/test/resources/yaml/config/config-min.yaml b/sharding-jdbc-core/src/test/resources/yaml/config/config-min.yaml index 811274f8eb9d569c56cc87af11e47c209ffad071..a608fc41fee98712ebf398628e8019b289a2138f 100644 --- a/sharding-jdbc-core/src/test/resources/yaml/config/config-min.yaml +++ b/sharding-jdbc-core/src/test/resources/yaml/config/config-min.yaml @@ -1,3 +1,3 @@ tables: config: - actualTables: ds.config_${0..1} + actualDataNodes: ds.config_${0..1} diff --git a/sharding-jdbc-core/src/test/resources/yaml/integrate/sharding/configWithDataSourceWithProps.yaml b/sharding-jdbc-core/src/test/resources/yaml/integrate/sharding/configWithDataSourceWithProps.yaml index c52e358e0a176585863999ca99eabe6475ca55fa..db18ae35cff8f0ff6db9bc5ef1aa8f39f203d715 100644 --- a/sharding-jdbc-core/src/test/resources/yaml/integrate/sharding/configWithDataSourceWithProps.yaml +++ b/sharding-jdbc-core/src/test/resources/yaml/integrate/sharding/configWithDataSourceWithProps.yaml @@ -14,10 +14,10 @@ dataSources: tables: config: - actualTables: db${0..1}.t_config + actualDataNodes: db${0..1}.t_config t_order: - actualTables: db${0..1}.t_order_${0..1} + actualDataNodes: db${0..1}.t_order_${0..1} databaseStrategy: standard: shardingColumn: user_id @@ -30,7 +30,7 @@ tables: keyGeneratorClass: io.shardingjdbc.core.yaml.fixture.IncrementKeyGenerator t_order_item: - actualTables: db${0..1}.t_order_item_${0..1} + actualDataNodes: db${0..1}.t_order_item_${0..1} #绑定表中其余的表的策略与第一张表的策略相同 databaseStrategy: standard: diff --git a/sharding-jdbc-core/src/test/resources/yaml/integrate/sharding/configWithDataSourceWithoutProps.yaml b/sharding-jdbc-core/src/test/resources/yaml/integrate/sharding/configWithDataSourceWithoutProps.yaml index 1b9999a11a94d5e22b8387ae3aa853727bb8a7c4..fa848028bed0ccb5f12c53cbf27ab3dbaff240ec 100644 --- a/sharding-jdbc-core/src/test/resources/yaml/integrate/sharding/configWithDataSourceWithoutProps.yaml +++ b/sharding-jdbc-core/src/test/resources/yaml/integrate/sharding/configWithDataSourceWithoutProps.yaml @@ -14,10 +14,10 @@ dataSources: tables: config: - actualTables: db${0..1}.t_config + actualDataNodes: db${0..1}.t_config t_order: - actualTables: db${0..1}.t_order_${0..1} + actualDataNodes: db${0..1}.t_order_${0..1} databaseStrategy: standard: shardingColumn: user_id @@ -30,7 +30,7 @@ tables: keyGeneratorClass: io.shardingjdbc.core.yaml.fixture.IncrementKeyGenerator t_order_item: - actualTables: db${0..1}.t_order_item_${0..1} + actualDataNodes: db${0..1}.t_order_item_${0..1} #绑定表中其余的表的策略与第一张表的策略相同 databaseStrategy: standard: diff --git a/sharding-jdbc-core/src/test/resources/yaml/integrate/sharding/configWithoutDataSourceWithProps.yaml b/sharding-jdbc-core/src/test/resources/yaml/integrate/sharding/configWithoutDataSourceWithProps.yaml index 69f7063e002a63f943ce6a89dbfffc9bc560951f..31ebe2a88d878fc4fa3ca8306364744986d89e95 100644 --- a/sharding-jdbc-core/src/test/resources/yaml/integrate/sharding/configWithoutDataSourceWithProps.yaml +++ b/sharding-jdbc-core/src/test/resources/yaml/integrate/sharding/configWithoutDataSourceWithProps.yaml @@ -1,9 +1,9 @@ tables: config: - actualTables: db${0..1}.t_config + actualDataNodes: db${0..1}.t_config t_order: - actualTables: db${0..1}.t_order_${0..1} + actualDataNodes: db${0..1}.t_order_${0..1} databaseStrategy: standard: shardingColumn: user_id @@ -16,7 +16,7 @@ tables: keyGeneratorClass: io.shardingjdbc.core.yaml.fixture.IncrementKeyGenerator t_order_item: - actualTables: db${0..1}.t_order_item_${0..1} + actualDataNodes: db${0..1}.t_order_item_${0..1} #绑定表中其余的表的策略与第一张表的策略相同 databaseStrategy: standard: diff --git a/sharding-jdbc-core/src/test/resources/yaml/integrate/sharding/configWithoutDataSourceWithoutProps.yaml b/sharding-jdbc-core/src/test/resources/yaml/integrate/sharding/configWithoutDataSourceWithoutProps.yaml index d1af668b55e4603982a48d48217a9b3f52501e0e..62db41351f9eaee0204fa7c5f8906b1c8e066049 100644 --- a/sharding-jdbc-core/src/test/resources/yaml/integrate/sharding/configWithoutDataSourceWithoutProps.yaml +++ b/sharding-jdbc-core/src/test/resources/yaml/integrate/sharding/configWithoutDataSourceWithoutProps.yaml @@ -1,8 +1,8 @@ tables: config: - actualTables: db${0..1}.t_config + actualDataNodes: db${0..1}.t_config t_order: - actualTables: db${0..1}.t_order_${0..1} + actualDataNodes: db${0..1}.t_order_${0..1} databaseStrategy: standard: shardingColumn: user_id @@ -15,7 +15,7 @@ tables: keyGeneratorClass: io.shardingjdbc.core.yaml.fixture.IncrementKeyGenerator t_order_item: - actualTables: db${0..1}.t_order_item_${0..1} + actualDataNodes: db${0..1}.t_order_item_${0..1} #绑定表中其余的表的策略与第一张表的策略相同 databaseStrategy: standard: diff --git a/sharding-jdbc-core/src/test/resources/yaml/integrate/sharding_ms/configWithDataSourceWithProps.yaml b/sharding-jdbc-core/src/test/resources/yaml/integrate/sharding_ms/configWithDataSourceWithProps.yaml index 6e083132d4d8f892a41c7209cb06cbdef122231d..3255ece8ce4f1fa00a826b7c3a9b81757ec025c3 100644 --- a/sharding-jdbc-core/src/test/resources/yaml/integrate/sharding_ms/configWithDataSourceWithProps.yaml +++ b/sharding-jdbc-core/src/test/resources/yaml/integrate/sharding_ms/configWithDataSourceWithProps.yaml @@ -26,10 +26,10 @@ dataSources: tables: config: - actualTables: db_ms_${0..1}.t_config + actualDataNodes: db_ms_${0..1}.t_config t_order: - actualTables: db_ms_${0..1}.t_order_${0..1} + actualDataNodes: db_ms_${0..1}.t_order_${0..1} databaseStrategy: standard: shardingColumn: user_id @@ -42,7 +42,7 @@ tables: keyGeneratorClass: io.shardingjdbc.core.yaml.fixture.IncrementKeyGenerator t_order_item: - actualTables: db_ms_${0..1}.t_order_item_${0..1} + actualDataNodes: db_ms_${0..1}.t_order_item_${0..1} #绑定表中其余的表的策略与第一张表的策略相同 databaseStrategy: standard: diff --git a/sharding-jdbc-core/src/test/resources/yaml/integrate/sharding_ms/configWithDataSourceWithoutProps.yaml b/sharding-jdbc-core/src/test/resources/yaml/integrate/sharding_ms/configWithDataSourceWithoutProps.yaml index 4354fb6f784bf3522a9cc91619cbfe9513325001..13f7b38b9cd5894b28f6dc9302e2464f2f04af56 100644 --- a/sharding-jdbc-core/src/test/resources/yaml/integrate/sharding_ms/configWithDataSourceWithoutProps.yaml +++ b/sharding-jdbc-core/src/test/resources/yaml/integrate/sharding_ms/configWithDataSourceWithoutProps.yaml @@ -26,10 +26,10 @@ dataSources: tables: config: - actualTables: db_ms_${0..1}.t_config + actualDataNodes: db_ms_${0..1}.t_config t_order: - actualTables: db_ms_${0..1}.t_order_${0..2} + actualDataNodes: db_ms_${0..1}.t_order_${0..2} databaseStrategy: standard: shardingColumn: user_id @@ -42,7 +42,7 @@ tables: keyGeneratorClass: io.shardingjdbc.core.yaml.fixture.IncrementKeyGenerator t_order_item: - actualTables: db_ms_${0..1}.t_order_item_${0..1} + actualDataNodes: db_ms_${0..1}.t_order_item_${0..1} #绑定表中其余的表的策略与第一张表的策略相同 databaseStrategy: standard: diff --git a/sharding-jdbc-core/src/test/resources/yaml/integrate/sharding_ms/configWithoutDataSourceWithProps.yaml b/sharding-jdbc-core/src/test/resources/yaml/integrate/sharding_ms/configWithoutDataSourceWithProps.yaml index 55c1fcff87875cc7f5c89f47ec01b1019c204718..1e271aab55a4ef38c7b68a18511fe3bf5805b522 100644 --- a/sharding-jdbc-core/src/test/resources/yaml/integrate/sharding_ms/configWithoutDataSourceWithProps.yaml +++ b/sharding-jdbc-core/src/test/resources/yaml/integrate/sharding_ms/configWithoutDataSourceWithProps.yaml @@ -1,9 +1,9 @@ tables: config: - actualTables: db_ms_${0..1}.t_config + actualDataNodes: db_ms_${0..1}.t_config t_order: - actualTables: db_ms_${0..1}.t_order_${0..1} + actualDataNodes: db_ms_${0..1}.t_order_${0..1} databaseStrategy: standard: shardingColumn: user_id @@ -16,7 +16,7 @@ tables: keyGeneratorClass: io.shardingjdbc.core.yaml.fixture.IncrementKeyGenerator t_order_item: - actualTables: db_ms_${0..1}.t_order_item_${0..1} + actualDataNodes: db_ms_${0..1}.t_order_item_${0..1} #绑定表中其余的表的策略与第一张表的策略相同 databaseStrategy: standard: diff --git a/sharding-jdbc-core/src/test/resources/yaml/integrate/sharding_ms/configWithoutDataSourceWithoutProps.yaml b/sharding-jdbc-core/src/test/resources/yaml/integrate/sharding_ms/configWithoutDataSourceWithoutProps.yaml index 0fd613ce04f7b3d7b9ed320aa80fafdabe590fae..e5a21190ced09a7e3b84e7fec742ac14fd4275a0 100644 --- a/sharding-jdbc-core/src/test/resources/yaml/integrate/sharding_ms/configWithoutDataSourceWithoutProps.yaml +++ b/sharding-jdbc-core/src/test/resources/yaml/integrate/sharding_ms/configWithoutDataSourceWithoutProps.yaml @@ -1,9 +1,9 @@ tables: config: - actualTables: db_ms_${0..1}.t_config + actualDataNodes: db_ms_${0..1}.t_config t_order: - actualTables: db_ms_${0..1}.t_order_${0..1} + actualDataNodes: db_ms_${0..1}.t_order_${0..1} databaseStrategy: standard: shardingColumn: user_id @@ -16,7 +16,7 @@ tables: keyGeneratorClass: io.shardingjdbc.core.yaml.fixture.IncrementKeyGenerator t_order_item: - actualTables: db_ms_${0..1}.t_order_item_${0..1} + actualDataNodes: db_ms_${0..1}.t_order_item_${0..1} #绑定表中其余的表的策略与第一张表的策略相同 databaseStrategy: standard: diff --git a/sharding-jdbc-orchestration/src/test/java/io/shardingjdbc/orchestration/json/ShardingRuleConfigurationConverterTest.java b/sharding-jdbc-orchestration/src/test/java/io/shardingjdbc/orchestration/json/ShardingRuleConfigurationConverterTest.java index d4d0dc5044adee8d10c09165a77f7ab3451de12e..78185de762971fc122184f6a03a00edb84a30caa 100644 --- a/sharding-jdbc-orchestration/src/test/java/io/shardingjdbc/orchestration/json/ShardingRuleConfigurationConverterTest.java +++ b/sharding-jdbc-orchestration/src/test/java/io/shardingjdbc/orchestration/json/ShardingRuleConfigurationConverterTest.java @@ -19,9 +19,9 @@ import static org.junit.Assert.assertThat; public final class ShardingRuleConfigurationConverterTest { - private final String commonShardingRuleConfigJson = "{\"tableRuleConfigs\":[{\"logicTable\":\"t_order\",\"actualTables\":\"t_order_${[0, 1]}\"," + private final String commonShardingRuleConfigJson = "{\"tableRuleConfigs\":[{\"logicTable\":\"t_order\",\"actualDataNodes\":\"t_order_${[0, 1]}\"," + "\"databaseShardingStrategyConfig\":{},\"tableShardingStrategyConfig\":{}}," - + "{\"logicTable\":\"t_order_item\",\"actualTables\":\"t_order_item_${[0, 1]}\"," + + "{\"logicTable\":\"t_order_item\",\"actualDataNodes\":\"t_order_item_${[0, 1]}\"," + "\"databaseShardingStrategyConfig\":{},\"tableShardingStrategyConfig\":{}}" + "],\"bindingTableGroups\":[\"t_order, t_order_item\"],\"defaultDatabaseShardingStrategyConfig\":{},"; @@ -61,11 +61,11 @@ public final class ShardingRuleConfigurationConverterTest { ShardingRuleConfiguration actual = new ShardingRuleConfiguration(); TableRuleConfiguration orderTableRuleConfig = new TableRuleConfiguration(); orderTableRuleConfig.setLogicTable("t_order"); - orderTableRuleConfig.setActualTables("t_order_${[0, 1]}"); + orderTableRuleConfig.setActualDataNodes("t_order_${[0, 1]}"); actual.getTableRuleConfigs().add(orderTableRuleConfig); TableRuleConfiguration orderItemTableRuleConfig = new TableRuleConfiguration(); orderItemTableRuleConfig.setLogicTable("t_order_item"); - orderItemTableRuleConfig.setActualTables("t_order_item_${[0, 1]}"); + orderItemTableRuleConfig.setActualDataNodes("t_order_item_${[0, 1]}"); actual.getTableRuleConfigs().add(orderItemTableRuleConfig); actual.getBindingTableGroups().add("t_order, t_order_item"); actual.setDefaultTableShardingStrategyConfig(strategyConfig); @@ -153,10 +153,10 @@ public final class ShardingRuleConfigurationConverterTest { Iterator actualTableRuleConfigs = actual.getTableRuleConfigs().iterator(); TableRuleConfiguration orderTableRuleConfig = actualTableRuleConfigs.next(); assertThat(orderTableRuleConfig.getLogicTable(), is("t_order")); - assertThat(orderTableRuleConfig.getActualTables(), is("t_order_${[0, 1]}")); + assertThat(orderTableRuleConfig.getActualDataNodes(), is("t_order_${[0, 1]}")); TableRuleConfiguration orderItemTableRuleConfig = actualTableRuleConfigs.next(); assertThat(orderItemTableRuleConfig.getLogicTable(), is("t_order_item")); - assertThat(orderItemTableRuleConfig.getActualTables(), is("t_order_item_${[0, 1]}")); + assertThat(orderItemTableRuleConfig.getActualDataNodes(), is("t_order_item_${[0, 1]}")); assertThat(actual.getBindingTableGroups().size(), is(1)); assertThat(actual.getBindingTableGroups().iterator().next(), is("t_order, t_order_item")); } diff --git a/sharding-jdbc-spring/sharding-jdbc-spring-namespace/src/main/java/io/shardingjdbc/spring/namespace/constants/ShardingJdbcDataSourceBeanDefinitionParserTag.java b/sharding-jdbc-spring/sharding-jdbc-spring-namespace/src/main/java/io/shardingjdbc/spring/namespace/constants/ShardingJdbcDataSourceBeanDefinitionParserTag.java index 719a3069dfa7ed4f8839b727d722ca651861f1d9..174dc25b91cf428c0287b375c5d07aa3edccb42a 100644 --- a/sharding-jdbc-spring/sharding-jdbc-spring-namespace/src/main/java/io/shardingjdbc/spring/namespace/constants/ShardingJdbcDataSourceBeanDefinitionParserTag.java +++ b/sharding-jdbc-spring/sharding-jdbc-spring-namespace/src/main/java/io/shardingjdbc/spring/namespace/constants/ShardingJdbcDataSourceBeanDefinitionParserTag.java @@ -50,7 +50,7 @@ public final class ShardingJdbcDataSourceBeanDefinitionParserTag { public static final String LOGIC_TABLES_ATTRIBUTE = "logic-tables"; - public static final String ACTUAL_TABLES_ATTRIBUTE = "actual-tables"; + public static final String ACTUAL_DATA_NODES_ATTRIBUTE = "actual-data-nodes"; public static final String DATABASE_STRATEGY_REF_ATTRIBUTE = "database-strategy-ref"; diff --git a/sharding-jdbc-spring/sharding-jdbc-spring-namespace/src/main/java/io/shardingjdbc/spring/namespace/parser/ShardingJdbcDataSourceBeanDefinitionParser.java b/sharding-jdbc-spring/sharding-jdbc-spring-namespace/src/main/java/io/shardingjdbc/spring/namespace/parser/ShardingJdbcDataSourceBeanDefinitionParser.java index d2ccbed6c0378f465db0342bc515a2b5adf3e0fd..14fd92e5f2cc186587060b274e01779006545fc4 100644 --- a/sharding-jdbc-spring/sharding-jdbc-spring-namespace/src/main/java/io/shardingjdbc/spring/namespace/parser/ShardingJdbcDataSourceBeanDefinitionParser.java +++ b/sharding-jdbc-spring/sharding-jdbc-spring-namespace/src/main/java/io/shardingjdbc/spring/namespace/parser/ShardingJdbcDataSourceBeanDefinitionParser.java @@ -121,9 +121,9 @@ public class ShardingJdbcDataSourceBeanDefinitionParser extends AbstractBeanDefi private BeanDefinition parseTableRuleConfig(final Element tableElement) { BeanDefinitionBuilder factory = BeanDefinitionBuilder.rootBeanDefinition(TableRuleConfiguration.class); factory.addPropertyValue("logicTable", tableElement.getAttribute(ShardingJdbcDataSourceBeanDefinitionParserTag.LOGIC_TABLE_ATTRIBUTE)); - String actualTables = tableElement.getAttribute(ShardingJdbcDataSourceBeanDefinitionParserTag.ACTUAL_TABLES_ATTRIBUTE); - if (!Strings.isNullOrEmpty(actualTables)) { - factory.addPropertyValue("actualTables", actualTables); + String actualDataNodes = tableElement.getAttribute(ShardingJdbcDataSourceBeanDefinitionParserTag.ACTUAL_DATA_NODES_ATTRIBUTE); + if (!Strings.isNullOrEmpty(actualDataNodes)) { + factory.addPropertyValue("actualDataNodes", actualDataNodes); } String databaseStrategy = tableElement.getAttribute(ShardingJdbcDataSourceBeanDefinitionParserTag.DATABASE_STRATEGY_REF_ATTRIBUTE); if (!Strings.isNullOrEmpty(databaseStrategy)) { diff --git a/sharding-jdbc-spring/sharding-jdbc-spring-namespace/src/main/resources/META-INF/namespace/sharding.xsd b/sharding-jdbc-spring/sharding-jdbc-spring-namespace/src/main/resources/META-INF/namespace/sharding.xsd index 53645f2e415e82c38142c56cd0499614f97f6bfb..7ee3efa892f987be76deb56c1f3a1ccca38abe6d 100644 --- a/sharding-jdbc-spring/sharding-jdbc-spring-namespace/src/main/resources/META-INF/namespace/sharding.xsd +++ b/sharding-jdbc-spring/sharding-jdbc-spring-namespace/src/main/resources/META-INF/namespace/sharding.xsd @@ -38,7 +38,7 @@ - + diff --git a/sharding-jdbc-spring/sharding-jdbc-spring-namespace/src/test/resources/META-INF/rdb/withNamespaceAlgorithmClass.xml b/sharding-jdbc-spring/sharding-jdbc-spring-namespace/src/test/resources/META-INF/rdb/withNamespaceAlgorithmClass.xml index 34d8b886bb03c1f1bdba3e3917b0b66f8e3fd1ac..1070be60fcd73e0873706453079c794fb2ac2dde 100644 --- a/sharding-jdbc-spring/sharding-jdbc-spring-namespace/src/test/resources/META-INF/rdb/withNamespaceAlgorithmClass.xml +++ b/sharding-jdbc-spring/sharding-jdbc-spring-namespace/src/test/resources/META-INF/rdb/withNamespaceAlgorithmClass.xml @@ -15,8 +15,8 @@ - - + + diff --git a/sharding-jdbc-spring/sharding-jdbc-spring-namespace/src/test/resources/META-INF/rdb/withNamespaceAlgorithmClassAndProps.xml b/sharding-jdbc-spring/sharding-jdbc-spring-namespace/src/test/resources/META-INF/rdb/withNamespaceAlgorithmClassAndProps.xml index 8bbab9697f43dc5f7da6398825831e7ec161b24a..07bcb7b79f69472c767b448e749d0f51c206c7c6 100644 --- a/sharding-jdbc-spring/sharding-jdbc-spring-namespace/src/test/resources/META-INF/rdb/withNamespaceAlgorithmClassAndProps.xml +++ b/sharding-jdbc-spring/sharding-jdbc-spring-namespace/src/test/resources/META-INF/rdb/withNamespaceAlgorithmClassAndProps.xml @@ -15,8 +15,8 @@ - - + + diff --git a/sharding-jdbc-spring/sharding-jdbc-spring-namespace/src/test/resources/META-INF/rdb/withNamespaceAlgorithmExpression.xml b/sharding-jdbc-spring/sharding-jdbc-spring-namespace/src/test/resources/META-INF/rdb/withNamespaceAlgorithmExpression.xml index 2e9c2ce3afdf0560973ac437605ddcd615401bf9..3ae2a09a248d613581164e09a85eb777b274b23c 100644 --- a/sharding-jdbc-spring/sharding-jdbc-spring-namespace/src/test/resources/META-INF/rdb/withNamespaceAlgorithmExpression.xml +++ b/sharding-jdbc-spring/sharding-jdbc-spring-namespace/src/test/resources/META-INF/rdb/withNamespaceAlgorithmExpression.xml @@ -16,8 +16,8 @@ - - + + diff --git a/sharding-jdbc-spring/sharding-jdbc-spring-namespace/src/test/resources/META-INF/rdb/withNamespaceBindingTables.xml b/sharding-jdbc-spring/sharding-jdbc-spring-namespace/src/test/resources/META-INF/rdb/withNamespaceBindingTables.xml index e070aa49cbcf0e39cb1aee5b144b1c233c50dd27..5d83eaeeb5478b4267bd7d68e25397c3d82ea516 100644 --- a/sharding-jdbc-spring/sharding-jdbc-spring-namespace/src/test/resources/META-INF/rdb/withNamespaceBindingTables.xml +++ b/sharding-jdbc-spring/sharding-jdbc-spring-namespace/src/test/resources/META-INF/rdb/withNamespaceBindingTables.xml @@ -15,8 +15,8 @@ - - + + diff --git a/sharding-jdbc-spring/sharding-jdbc-spring-namespace/src/test/resources/META-INF/rdb/withNamespaceDefaultStrategy.xml b/sharding-jdbc-spring/sharding-jdbc-spring-namespace/src/test/resources/META-INF/rdb/withNamespaceDefaultStrategy.xml index 1cdfbe79b8a474baf032430f5326fe45a4a4f830..de252b52afe1f72f96e7c92c5941a666cadee327 100644 --- a/sharding-jdbc-spring/sharding-jdbc-spring-namespace/src/test/resources/META-INF/rdb/withNamespaceDefaultStrategy.xml +++ b/sharding-jdbc-spring/sharding-jdbc-spring-namespace/src/test/resources/META-INF/rdb/withNamespaceDefaultStrategy.xml @@ -15,8 +15,8 @@ - - + + diff --git a/sharding-jdbc-spring/sharding-jdbc-spring-namespace/src/test/resources/META-INF/rdb/withNamespaceDifferentTables.xml b/sharding-jdbc-spring/sharding-jdbc-spring-namespace/src/test/resources/META-INF/rdb/withNamespaceDifferentTables.xml index 0253644f1951961ce906ce5d76d68a7ec845e4d2..557502e1b25739347d299619b292876fdefdfaa1 100644 --- a/sharding-jdbc-spring/sharding-jdbc-spring-namespace/src/test/resources/META-INF/rdb/withNamespaceDifferentTables.xml +++ b/sharding-jdbc-spring/sharding-jdbc-spring-namespace/src/test/resources/META-INF/rdb/withNamespaceDifferentTables.xml @@ -16,8 +16,8 @@ - - + + diff --git a/sharding-jdbc-spring/sharding-jdbc-spring-namespace/src/test/resources/META-INF/rdb/withNamespaceForMasterSlaveWithDefaultStrategy.xml b/sharding-jdbc-spring/sharding-jdbc-spring-namespace/src/test/resources/META-INF/rdb/withNamespaceForMasterSlaveWithDefaultStrategy.xml index e47c70c8b537436f11f2ecac7653077eb9783d80..5e9543e1fe44790c8c6eed591d260f9d3309ffc7 100644 --- a/sharding-jdbc-spring/sharding-jdbc-spring-namespace/src/test/resources/META-INF/rdb/withNamespaceForMasterSlaveWithDefaultStrategy.xml +++ b/sharding-jdbc-spring/sharding-jdbc-spring-namespace/src/test/resources/META-INF/rdb/withNamespaceForMasterSlaveWithDefaultStrategy.xml @@ -22,8 +22,8 @@ - - + + diff --git a/sharding-jdbc-spring/sharding-jdbc-spring-namespace/src/test/resources/META-INF/rdb/withNamespaceForMasterSlaveWithStrategyRef.xml b/sharding-jdbc-spring/sharding-jdbc-spring-namespace/src/test/resources/META-INF/rdb/withNamespaceForMasterSlaveWithStrategyRef.xml index aefff2a3b068a423ebbcd8445f2d5eb3a97e13ef..b95121b5e1022b0fc7021ba9652f19e764166f1b 100644 --- a/sharding-jdbc-spring/sharding-jdbc-spring-namespace/src/test/resources/META-INF/rdb/withNamespaceForMasterSlaveWithStrategyRef.xml +++ b/sharding-jdbc-spring/sharding-jdbc-spring-namespace/src/test/resources/META-INF/rdb/withNamespaceForMasterSlaveWithStrategyRef.xml @@ -24,8 +24,8 @@ - - + + diff --git a/sharding-jdbc-spring/sharding-jdbc-spring-namespace/src/test/resources/META-INF/rdb/withNamespaceForMasterSlaveWithStrategyType.xml b/sharding-jdbc-spring/sharding-jdbc-spring-namespace/src/test/resources/META-INF/rdb/withNamespaceForMasterSlaveWithStrategyType.xml index 0cb48778c10f2e417414dad85a7aa43e5d7e45e8..32e657aa1714df0583928e4eec0657f382b554b8 100644 --- a/sharding-jdbc-spring/sharding-jdbc-spring-namespace/src/test/resources/META-INF/rdb/withNamespaceForMasterSlaveWithStrategyType.xml +++ b/sharding-jdbc-spring/sharding-jdbc-spring-namespace/src/test/resources/META-INF/rdb/withNamespaceForMasterSlaveWithStrategyType.xml @@ -22,8 +22,8 @@ - - + + diff --git a/sharding-jdbc-spring/sharding-jdbc-spring-namespace/src/test/resources/META-INF/rdb/withNamespaceGenerateKeyColumns.xml b/sharding-jdbc-spring/sharding-jdbc-spring-namespace/src/test/resources/META-INF/rdb/withNamespaceGenerateKeyColumns.xml index 6a86605370882ba16f371ca1dfc71bba41fc8134..84a82b1b8011614762db9d27f1a01dbbafdc251c 100644 --- a/sharding-jdbc-spring/sharding-jdbc-spring-namespace/src/test/resources/META-INF/rdb/withNamespaceGenerateKeyColumns.xml +++ b/sharding-jdbc-spring/sharding-jdbc-spring-namespace/src/test/resources/META-INF/rdb/withNamespaceGenerateKeyColumns.xml @@ -15,8 +15,8 @@ - - + +