You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@shardingsphere.apache.org by du...@apache.org on 2023/06/14 12:34:11 UTC
[shardingsphere] branch master updated: Refactor refresh single table metadata (#26345)
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 <zh...@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)));
}
/**