diff --git a/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/manager/resource/StorageUnitManager.java b/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/manager/resource/StorageUnitManager.java index 1619076cf1451..259e60a1a9801 100644 --- a/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/manager/resource/StorageUnitManager.java +++ b/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/manager/resource/StorageUnitManager.java @@ -56,13 +56,13 @@ public final class StorageUnitManager { * @param databaseName database name * @param propsMap data source pool properties map */ - public synchronized void registerStorageUnit(final String databaseName, final Map propsMap) { + public synchronized void register(final String databaseName, final Map propsMap) { try { closeStaleRules(databaseName); SwitchingResource switchingResource = resourceSwitchManager.switchByRegisterStorageUnit(metaDataContexts.getMetaData().getDatabase(databaseName).getResourceMetaData(), propsMap); buildNewMetaDataContext(databaseName, switchingResource); } catch (final SQLException ex) { - log.error("Alter database: {} register storage unit failed", databaseName, ex); + log.error("Alter database: {} register storage unit failed.", databaseName, ex); } } @@ -72,13 +72,13 @@ public synchronized void registerStorageUnit(final String databaseName, final Ma * @param databaseName database name * @param propsMap data source pool properties map */ - public synchronized void alterStorageUnit(final String databaseName, final Map propsMap) { + public synchronized void alter(final String databaseName, final Map propsMap) { try { closeStaleRules(databaseName); SwitchingResource switchingResource = resourceSwitchManager.switchByAlterStorageUnit(metaDataContexts.getMetaData().getDatabase(databaseName).getResourceMetaData(), propsMap); buildNewMetaDataContext(databaseName, switchingResource); } catch (final SQLException ex) { - log.error("Alter database: {} register storage unit failed", databaseName, ex); + log.error("Alter database: {} alter storage unit failed.", databaseName, ex); } } @@ -88,14 +88,14 @@ public synchronized void alterStorageUnit(final String databaseName, final Map