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 <[email protected]>
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());