Use MetaDataChangedHandler to instead of MetaDataChangedSubscriber

apache · Jan 1, 2025 · cfc716a · cfc716a
1 parent c4aa845
commit cfc716a
Show file tree

Hide file tree

Showing 4 changed files with 10 additions and 10 deletions.
diff --git a/...dingsphere/mode/manager/cluster/event/dispatch/handler/database/SchemaChangedHandler.java b/...dingsphere/mode/manager/cluster/event/dispatch/handler/database/SchemaChangedHandler.java
@@ -36,7 +36,7 @@ public SchemaChangedHandler(final ContextManager contextManager) {
 
     /**
      * Handle schema created.
-     * 
+     *
      * @param databaseName database name
      * @param schemaName schema name
      */
@@ -47,7 +47,7 @@ public void handleCreated(final String databaseName, final String schemaName) {
 
     /**
      * Handle schema dropped.
-     * 
+     *
      * @param databaseName database name
      * @param schemaName schema name
      */

diff --git a/...phere/mode/manager/cluster/event/dispatch/handler/database/StorageUnitChangedHandler.java b/...phere/mode/manager/cluster/event/dispatch/handler/database/StorageUnitChangedHandler.java
@@ -42,7 +42,7 @@ public final class StorageUnitChangedHandler {
      */
     public void handleRegistered(final String databaseName, final String dataSourceUnitName, final DataChangedEvent event) {
         Preconditions.checkArgument(event.getValue().equals(
-                        contextManager.getPersistServiceFacade().getMetaDataPersistService().getMetaDataVersionPersistService().getActiveVersionByFullPath(event.getKey())),
+                contextManager.getPersistServiceFacade().getMetaDataPersistService().getMetaDataVersionPersistService().getActiveVersionByFullPath(event.getKey())),
                 "Invalid active version: %s of key: %s", event.getValue(), event.getKey());
         DataSourcePoolProperties dataSourcePoolProps = contextManager.getPersistServiceFacade().getMetaDataPersistService().getDataSourceUnitService().load(databaseName, dataSourceUnitName);
         contextManager.getMetaDataContextManager().getStorageUnitManager().registerStorageUnit(databaseName, Collections.singletonMap(dataSourceUnitName, dataSourcePoolProps));
@@ -57,7 +57,7 @@ public void handleRegistered(final String databaseName, final String dataSourceU
      */
     public void handleAltered(final String databaseName, final String dataSourceUnitName, final DataChangedEvent event) {
         Preconditions.checkArgument(event.getValue().equals(
-                        contextManager.getPersistServiceFacade().getMetaDataPersistService().getMetaDataVersionPersistService().getActiveVersionByFullPath(event.getKey())),
+                contextManager.getPersistServiceFacade().getMetaDataPersistService().getMetaDataVersionPersistService().getActiveVersionByFullPath(event.getKey())),
                 "Invalid active version: %s of key: %s", event.getValue(), event.getKey());
         DataSourcePoolProperties dataSourcePoolProps = contextManager.getPersistServiceFacade().getMetaDataPersistService().getDataSourceUnitService().load(databaseName, dataSourceUnitName);
         contextManager.getMetaDataContextManager().getStorageUnitManager().alterStorageUnit(databaseName, Collections.singletonMap(dataSourceUnitName, dataSourcePoolProps));

diff --git a/...rdingsphere/mode/manager/cluster/event/dispatch/handler/database/TableChangedHandler.java b/...rdingsphere/mode/manager/cluster/event/dispatch/handler/database/TableChangedHandler.java
@@ -40,15 +40,15 @@ public TableChangedHandler(final ContextManager contextManager) {
 
     /**
      * Handle table created or altered.
-     * 
+     *
      * @param databaseName database name
      * @param schemaName schema name
      * @param event data changed event
      */
     public void handleCreatedOrAltered(final String databaseName, final String schemaName, final DataChangedEvent event) {
         String tableName = TableMetaDataNode.getTableNameByActiveVersionNode(event.getKey()).orElseThrow(() -> new IllegalStateException("Table name not found."));
         Preconditions.checkArgument(event.getValue().equals(
-                        contextManager.getPersistServiceFacade().getMetaDataPersistService().getMetaDataVersionPersistService().getActiveVersionByFullPath(event.getKey())),
+                contextManager.getPersistServiceFacade().getMetaDataPersistService().getMetaDataVersionPersistService().getActiveVersionByFullPath(event.getKey())),
                 "Invalid active version: %s of key: %s", event.getValue(), event.getKey());
         ShardingSphereTable table = contextManager.getPersistServiceFacade().getMetaDataPersistService().getDatabaseMetaDataFacade().getTable().load(databaseName, schemaName, tableName);
         contextManager.getMetaDataContextManager().getSchemaMetaDataManager().alterSchema(databaseName, schemaName, table, null);
@@ -57,7 +57,7 @@ public void handleCreatedOrAltered(final String databaseName, final String schem
 
     /**
      * Handle table altered.
-     * 
+     *
      * @param databaseName database name
      * @param schemaName schema name
      * @param event data changed event

diff --git a/...ardingsphere/mode/manager/cluster/event/dispatch/handler/database/ViewChangedHandler.java b/...ardingsphere/mode/manager/cluster/event/dispatch/handler/database/ViewChangedHandler.java
@@ -40,15 +40,15 @@ public ViewChangedHandler(final ContextManager contextManager) {
 
     /**
      * Handle view created or altered.
-     * 
+     *
      * @param databaseName database name
      * @param schemaName schema name
      * @param event data changed event
      */
     public void handleCreatedOrAltered(final String databaseName, final String schemaName, final DataChangedEvent event) {
         String viewName = ViewMetaDataNode.getViewNameByActiveVersionNode(event.getKey()).orElseThrow(() -> new IllegalStateException("View name not found."));
         Preconditions.checkArgument(event.getValue().equals(
-                        contextManager.getPersistServiceFacade().getMetaDataPersistService().getMetaDataVersionPersistService().getActiveVersionByFullPath(event.getKey())),
+                contextManager.getPersistServiceFacade().getMetaDataPersistService().getMetaDataVersionPersistService().getActiveVersionByFullPath(event.getKey())),
                 "Invalid active version: %s of key: %s", event.getValue(), event.getKey());
         ShardingSphereView view = contextManager.getPersistServiceFacade().getMetaDataPersistService().getDatabaseMetaDataFacade().getView().load(databaseName, schemaName, viewName);
         contextManager.getMetaDataContextManager().getSchemaMetaDataManager().alterSchema(databaseName, schemaName, null, view);
@@ -57,7 +57,7 @@ public void handleCreatedOrAltered(final String databaseName, final String schem
 
     /**
      * Handle view dropped.
-     * 
+     *
      * @param databaseName database name
      * @param schemaName schema name
      * @param event data changed event