diff --git a/sharding-core/src/main/java/io/shardingsphere/core/metadata/table/ShardingTableMetaData.java b/sharding-core/src/main/java/io/shardingsphere/core/metadata/table/ShardingTableMetaData.java index 03164541afec3..89a42e8ca6b8b 100644 --- a/sharding-core/src/main/java/io/shardingsphere/core/metadata/table/ShardingTableMetaData.java +++ b/sharding-core/src/main/java/io/shardingsphere/core/metadata/table/ShardingTableMetaData.java @@ -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 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 connectionMap) { diff --git a/sharding-jdbc/src/main/java/io/shardingsphere/core/jdbc/core/connection/ShardingConnection.java b/sharding-jdbc/src/main/java/io/shardingsphere/core/jdbc/core/connection/ShardingConnection.java index 7dbd92a422276..712c0826ac131 100644 --- a/sharding-jdbc/src/main/java/io/shardingsphere/core/jdbc/core/connection/ShardingConnection.java +++ b/sharding-jdbc/src/main/java/io/shardingsphere/core/jdbc/core/connection/ShardingConnection.java @@ -71,7 +71,7 @@ public void release(final Connection connection) { */ public Map getConnections(final String logicTableName) throws SQLException { Map 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)); }