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 2024/04/16 08:10:10 UTC
(shardingsphere) branch master updated: Fix table meta data not update when use refresh table metadata (#30913)
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 418a347c77a Fix table meta data not update when use refresh table metadata (#30913)
418a347c77a is described below
commit 418a347c77a7acbbc9b7241a74301bfe0d50cf3f
Author: zhaojinchao <zh...@apache.org>
AuthorDate: Tue Apr 16 16:10:02 2024 +0800
Fix table meta data not update when use refresh table metadata (#30913)
---
.../apache/shardingsphere/mode/manager/ContextManager.java | 11 +++++++----
1 file changed, 7 insertions(+), 4 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 ba07398303c..699054e8be5 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
@@ -137,11 +137,13 @@ public final class ContextManager implements AutoCloseable {
MetaDataBasedPersistService persistService = metaDataContexts.get().getPersistService();
if (force) {
metaDataContexts.set(reloadedMetaDataContexts);
- database.getSchemas().forEach((schemaName, schema) -> persistService.getDatabaseMetaDataService().persistByAlterConfiguration(database.getName(), schemaName, schema));
+ metaDataContexts.get().getMetaData().getDatabase(database.getName()).getSchemas()
+ .forEach((schemaName, schema) -> persistService.getDatabaseMetaDataService().persistByAlterConfiguration(database.getName(), schemaName, schema));
} else {
deletedSchemaNames(database.getName(), reloadedMetaDataContexts.getMetaData().getDatabase(database.getName()), database);
metaDataContexts.set(reloadedMetaDataContexts);
- database.getSchemas().forEach((schemaName, schema) -> persistService.getDatabaseMetaDataService().compareAndPersist(database.getName(), schemaName, schema));
+ metaDataContexts.get().getMetaData().getDatabase(database.getName()).getSchemas()
+ .forEach((schemaName, schema) -> persistService.getDatabaseMetaDataService().compareAndPersist(database.getName(), schemaName, schema));
}
} catch (final SQLException ex) {
log.error("Refresh database meta data: {} failed", database.getName(), ex);
@@ -156,9 +158,10 @@ public final class ContextManager implements AutoCloseable {
public void refreshTableMetaData(final ShardingSphereDatabase database) {
try {
MetaDataContexts reloadedMetaDataContexts = createMetaDataContexts(database);
- deletedSchemaNames(database.getName(), database, database);
+ deletedSchemaNames(database.getName(), reloadedMetaDataContexts.getMetaData().getDatabase(database.getName()), database);
metaDataContexts.set(reloadedMetaDataContexts);
- database.getSchemas().forEach((schemaName, schema) -> metaDataContexts.get().getPersistService().getDatabaseMetaDataService().compareAndPersist(database.getName(), schemaName, schema));
+ metaDataContexts.get().getMetaData().getDatabase(database.getName()).getSchemas()
+ .forEach((schemaName, schema) -> metaDataContexts.get().getPersistService().getDatabaseMetaDataService().compareAndPersist(database.getName(), schemaName, schema));
} catch (final SQLException ex) {
log.error("Refresh table meta data: {} failed", database.getName(), ex);
}