[shardingsphere] branch master updated: Refactor refresh single table metadata (#26345)

[duanzhengqiang]

This is an automated email from the ASF dual-hosted git repository.

duanzhengqiang 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 79dea9b6ae4 Refactor refresh single table metadata (#26345)
79dea9b6ae4 is described below

commit 79dea9b6ae49d2db0c2542e6b7946711d4cffabb
Author: zhaojinchao <zhaojinc...@apache.org>
AuthorDate: Wed Jun 14 20:34:04 2023 +0800

    Refactor refresh single table metadata (#26345)
---
 .../org/apache/shardingsphere/mode/manager/ContextManager.java    | 8 ++------
 1 file changed, 2 insertions(+), 6 deletions(-)

diff --git 
a/mode/core/src/main/java/org/apache/shardingsphere/mode/manager/ContextManager.java
 
b/mode/core/src/main/java/org/apache/shardingsphere/mode/manager/ContextManager.java
index da099f8c779..d43a661788a 100644
--- 
a/mode/core/src/main/java/org/apache/shardingsphere/mode/manager/ContextManager.java
+++ 
b/mode/core/src/main/java/org/apache/shardingsphere/mode/manager/ContextManager.java
@@ -562,12 +562,8 @@ public final class ContextManager implements AutoCloseable 
{
         GenericSchemaBuilderMaterial material = new 
GenericSchemaBuilderMaterial(database.getProtocolType(),
                 database.getResourceMetaData().getStorageTypes(), 
dataSourceMap, database.getRuleMetaData().getRules(), 
metaDataContexts.get().getMetaData().getProps(), schemaName);
         ShardingSphereSchema schema = 
GenericSchemaBuilder.build(Collections.singletonList(tableName), 
material).getOrDefault(schemaName, new ShardingSphereSchema());
-        if (schema.containsTable(tableName)) {
-            alterTable(databaseName, schemaName, schema.getTable(tableName));
-        } else {
-            dropTable(databaseName, schemaName, tableName);
-        }
-        
metaDataContexts.get().getPersistService().getDatabaseMetaDataService().compareAndPersist(database.getName(),
 schemaName, database.getSchema(schemaName));
+        
metaDataContexts.get().getPersistService().getDatabaseMetaDataService().getTableMetaDataPersistService()
+                .persist(database.getName(), schemaName, 
Collections.singletonMap(tableName, schema.getTable(tableName)));
     }
     
     /**