This is an automated email from the ASF dual-hosted git repository. zhangliang pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/shardingsphere.git
The following commit(s) were added to refs/heads/master by this push: new 9b6a684ca94 Refactor YamlDatabaseConfigurationImportExecutor (#34496) 9b6a684ca94 is described below commit 9b6a684ca940a40a0be9920b56dee7948ebb71bc Author: Liang Zhang <zhangli...@apache.org> AuthorDate: Sat Jan 25 20:55:39 2025 +0800 Refactor YamlDatabaseConfigurationImportExecutor (#34496) --- .../proxy/backend/util/YamlDatabaseConfigurationImportExecutor.java | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/util/YamlDatabaseConfigurationImportExecutor.java b/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/util/YamlDatabaseConfigurationImportExecutor.java index 2e99c22e0f9..6c2da2dbe62 100644 --- a/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/util/YamlDatabaseConfigurationImportExecutor.java +++ b/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/util/YamlDatabaseConfigurationImportExecutor.java @@ -75,9 +75,8 @@ public final class YamlDatabaseConfigurationImportExecutor { * Import proxy database from yaml configuration. * * @param yamlConfig yaml proxy database configuration - * @throws SQLException SQL exception */ - public void importDatabaseConfiguration(final YamlProxyDatabaseConfiguration yamlConfig) throws SQLException { + public void importDatabaseConfiguration(final YamlProxyDatabaseConfiguration yamlConfig) { String databaseName = yamlConfig.getDatabaseName(); checkDatabase(databaseName); checkDataSources(databaseName, yamlConfig.getDataSources()); @@ -100,7 +99,7 @@ public final class YamlDatabaseConfigurationImportExecutor { ShardingSpherePreconditions.checkState(!contextManager.getMetaDataContexts().getMetaData().containsDatabase(databaseName), () -> new DatabaseCreateExistsException(databaseName)); } - private void addDatabase(final String databaseName) throws SQLException { + private void addDatabase(final String databaseName) { contextManager.getPersistServiceFacade().getMetaDataManagerPersistService().createDatabase(databaseName); DatabaseType protocolType = DatabaseTypeEngine.getProtocolType(Collections.emptyMap(), contextManager.getMetaDataContexts().getMetaData().getProps()); contextManager.getMetaDataContexts().getMetaData().addDatabase(databaseName, protocolType, contextManager.getMetaDataContexts().getMetaData().getProps());