Skip to content

Commit

Permalink
change function names.
Browse files Browse the repository at this point in the history
  • Loading branch information
tristaZero committed Aug 1, 2018
1 parent 563c942 commit c83ef92
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -115,7 +115,7 @@ public void refresh(final String logicTableName, final ShardingRule shardingRule
* @param connectionMap connection map passing from sharding connection
*/
public void refresh(final String logicTableName, final ShardingRule shardingRule, final Map<String, Connection> connectionMap) {
tableMetaDataMap.put(logicTableName, loadTableMetaData(shardingRule.getTableRule(logicTableName), shardingRule.getShardingDataSourceNames(), connectionMap));
tableMetaDataMap.put(logicTableName, loadTableMetaData(shardingRule.getTableRuleByLogicTableName(logicTableName), shardingRule.getShardingDataSourceNames(), connectionMap));
}

private TableMetaData loadTableMetaData(final TableRule tableRule, final ShardingDataSourceNames shardingDataSourceNames, final Map<String, Connection> connectionMap) {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -71,7 +71,7 @@ public void release(final Connection connection) {
*/
public Map<String, Connection> getConnections(final String logicTableName) throws SQLException {
Map<String, Connection> result = new HashMap<>();
for (DataNode each : shardingContext.getShardingRule().getTableRule(logicTableName).getActualDataNodes()) {
for (DataNode each : shardingContext.getShardingRule().getTableRuleByLogicTableName(logicTableName).getActualDataNodes()) {
String dataSourceName = shardingContext.getShardingRule().getShardingDataSourceNames().getRawMasterDataSourceName(each.getDataSourceName());
result.put(dataSourceName, getConnection(dataSourceName));
}
Expand Down

0 comments on commit c83ef92

Please sign in to comment.