Refactor RuleItemManager

apache · Dec 15, 2024 · bf580ac · bf580ac
1 parent 79e413d
commit bf580ac
Showing 1 changed file with 7 additions and 7 deletions.
diff --git a/...sphere/mode/manager/cluster/event/dispatch/subscriber/type/MetaDataChangedSubscriber.java b/...sphere/mode/manager/cluster/event/dispatch/subscriber/type/MetaDataChangedSubscriber.java
@@ -57,7 +57,7 @@ public MetaDataChangedSubscriber(final ContextManager contextManager) {
     @Subscribe
     public synchronized void renew(final SchemaAddedEvent event) {
         contextManager.getMetaDataContextManager().getSchemaMetaDataManager().addSchema(event.getDatabaseName(), event.getSchemaName());
-        refreshShardingSphereStatisticsData();
+        refreshStatisticsData();
     }
 
     /**
@@ -68,7 +68,7 @@ public synchronized void renew(final SchemaAddedEvent event) {
     @Subscribe
     public synchronized void renew(final SchemaDeletedEvent event) {
         contextManager.getMetaDataContextManager().getSchemaMetaDataManager().dropSchema(event.getDatabaseName(), event.getSchemaName());
-        refreshShardingSphereStatisticsData();
+        refreshStatisticsData();
     }
 
     /**
@@ -84,7 +84,7 @@ public synchronized void renew(final TableCreatedOrAlteredEvent event) {
         ShardingSphereTable table = contextManager.getPersistServiceFacade().getMetaDataPersistService().getDatabaseMetaDataFacade().getTable()
                 .load(event.getDatabaseName(), event.getSchemaName(), event.getTableName());
         contextManager.getMetaDataContextManager().getSchemaMetaDataManager().alterSchema(event.getDatabaseName(), event.getSchemaName(), table, null);
-        refreshShardingSphereStatisticsData();
+        refreshStatisticsData();
     }
 
     /**
@@ -95,7 +95,7 @@ public synchronized void renew(final TableCreatedOrAlteredEvent event) {
     @Subscribe
     public synchronized void renew(final TableDroppedEvent event) {
         contextManager.getMetaDataContextManager().getSchemaMetaDataManager().alterSchema(event.getDatabaseName(), event.getSchemaName(), event.getTableName(), null);
-        refreshShardingSphereStatisticsData();
+        refreshStatisticsData();
     }
 
     /**
@@ -111,7 +111,7 @@ public synchronized void renew(final ViewCreatedOrAlteredEvent event) {
         ShardingSphereView view = contextManager.getPersistServiceFacade().getMetaDataPersistService().getDatabaseMetaDataFacade().getView()
                 .load(event.getDatabaseName(), event.getSchemaName(), event.getViewName());
         contextManager.getMetaDataContextManager().getSchemaMetaDataManager().alterSchema(event.getDatabaseName(), event.getSchemaName(), null, view);
-        refreshShardingSphereStatisticsData();
+        refreshStatisticsData();
     }
 
     /**
@@ -122,10 +122,10 @@ public synchronized void renew(final ViewCreatedOrAlteredEvent event) {
     @Subscribe
     public synchronized void renew(final ViewDroppedEvent event) {
         contextManager.getMetaDataContextManager().getSchemaMetaDataManager().alterSchema(event.getDatabaseName(), event.getSchemaName(), null, event.getViewName());
-        refreshShardingSphereStatisticsData();
+        refreshStatisticsData();
     }
 
-    private void refreshShardingSphereStatisticsData() {
+    private void refreshStatisticsData() {
         if (contextManager.getComputeNodeInstanceContext().getModeConfiguration().isCluster()
                 && InstanceType.PROXY == contextManager.getComputeNodeInstanceContext().getInstance().getMetaData().getType()) {
             new ShardingSphereStatisticsRefreshEngine(contextManager, new GlobalLockContext(new GlobalLockPersistService(repository))).asyncRefresh();