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 efcf0ecaf58 Refactor 
StandaloneMetaDataManagerPersistService.createTable() (#34517)
efcf0ecaf58 is described below

commit efcf0ecaf58f53e4717524b4ccf1bd7ecaf0b851
Author: Liang Zhang <zhangli...@apache.org>
AuthorDate: Sun Jan 26 21:44:43 2025 +0800

    Refactor StandaloneMetaDataManagerPersistService.createTable() (#34517)
---
 .../persist/service/StandaloneMetaDataManagerPersistService.java  | 8 +-------
 1 file changed, 1 insertion(+), 7 deletions(-)

diff --git 
a/mode/type/standalone/core/src/main/java/org/apache/shardingsphere/mode/manager/standalone/persist/service/StandaloneMetaDataManagerPersistService.java
 
b/mode/type/standalone/core/src/main/java/org/apache/shardingsphere/mode/manager/standalone/persist/service/StandaloneMetaDataManagerPersistService.java
index bab8b79d215..0cc1a04fddc 100644
--- 
a/mode/type/standalone/core/src/main/java/org/apache/shardingsphere/mode/manager/standalone/persist/service/StandaloneMetaDataManagerPersistService.java
+++ 
b/mode/type/standalone/core/src/main/java/org/apache/shardingsphere/mode/manager/standalone/persist/service/StandaloneMetaDataManagerPersistService.java
@@ -217,13 +217,7 @@ public final class StandaloneMetaDataManagerPersistService 
implements MetaDataMa
     @Override
     public void createTable(final String databaseName, final String 
schemaName, final ShardingSphereTable table) {
         
metaDataPersistService.getDatabaseMetaDataFacade().getTable().persist(databaseName,
 schemaName, Collections.singleton(table));
-        ShardingSphereMetaData metaData = 
metaDataContextManager.getMetaDataContexts().getMetaData();
-        ShardingSphereDatabase database = metaData.getDatabase(databaseName);
-        if (TableRefreshUtils.isSingleTable(table.getName(), database)) {
-            database.reloadRules();
-        }
-        database.getSchema(schemaName).putTable(table);
-        metaData.getGlobalRuleMetaData().getRules().forEach(each -> 
((GlobalRule) each).refresh(metaData.getAllDatabases(), 
GlobalRuleChangedType.SCHEMA_CHANGED));
+        
metaDataContextManager.getDatabaseMetaDataManager().alterTable(databaseName, 
schemaName, table);
     }
     
     @Override

Reply via email to