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