Add mysql index of init schema in admin module

shenyu-admin/src/main/java/org/apache/shenyu/admin/controller/PluginController.java

@@ -59,9 +59,15 @@
 @RestController
 @RequestMapping("/plugin")
 public class PluginController implements PagedController<PluginQueryCondition, PluginVO> {
-
+
+    /**
+     * 插件服务
+     */
     private final PluginService pluginService;
-
+
+    /**
+     * 同步数据服务
+     */
     private final SyncDataService syncDataService;
 
     public PluginController(final PluginService pluginService, final SyncDataService syncDataService) {
@@ -208,6 +214,7 @@ public ShenyuAdminResult syncPluginAll() {
 
     /**
      * Sync plugin data.
+     * 同步插件数据
      *
      * @param id the id
      * @return the mono
@@ -216,7 +223,8 @@ public ShenyuAdminResult syncPluginAll() {
     public ShenyuAdminResult syncPluginData(@PathVariable("id")
                                             @Existed(message = "plugin is not existed",
                                                     provider = PluginMapper.class) final String id) {
-        return ShenyuAdminResult.success(syncDataService.syncPluginData(id) ? ShenyuResultMessage.SYNC_SUCCESS : ShenyuResultMessage.SYNC_FAIL);
+        boolean syncResult = syncDataService.syncPluginData(id);
+        return ShenyuAdminResult.success(syncResult ? ShenyuResultMessage.SYNC_SUCCESS : ShenyuResultMessage.SYNC_FAIL);
     }
 
     /**

shenyu-admin/src/main/java/org/apache/shenyu/admin/controller/SelectorController.java

@@ -77,7 +77,7 @@ public AdminResult<CommonPager<SelectorVO>> querySelectors(final String pluginId
                                                                 @RequestParam @NotNull final Integer pageSize) {
         final SelectorQueryCondition condition = new SelectorQueryCondition();
         condition.setUserId(SessionUtil.visitor().getUserId());
-        condition.setPlugin(ListUtil.of(pluginId));
+        condition.setPluginIds(ListUtil.of(pluginId));
         condition.setKeyword(name);
         return searchAdaptor(new PageCondition<>(currentPage, pageSize, condition));
     }

shenyu-admin/src/main/java/org/apache/shenyu/admin/listener/AbstractPathDataChangedListener.java

@@ -36,13 +36,20 @@
 
 /**
  * AbstractPathDataChangedListener.
+ * 路径数据变更的监听器的抽象框架实现
  */
 public abstract class AbstractPathDataChangedListener implements DataChangedListener {
 
     private static final Logger LOG = LoggerFactory.getLogger(AbstractPathDataChangedListener.class);
 
+    /**
+     * 规则同步对象锁
+     */
     private final Object ruleSyncObject = new Object();
 
+    /**
+     * 选择器同步对象锁
+     */
     private final Object selectorSyncObject = new Object();
 
     @Override
@@ -116,28 +123,37 @@ public void onDiscoveryUpstreamChanged(final List<DiscoverySyncData> changed, fi
 
     @Override
     public void onSelectorChanged(final List<SelectorData> changed, final DataEventTypeEnum eventType) {
+        // 选择器数据的刷新事件
         if (eventType == DataEventTypeEnum.REFRESH && !changed.isEmpty()) {
+            // 构建选择器的父路径("/shenyu/selector/${pluginName}")
             String selectorParentPath = DefaultPathConstants.buildSelectorParentPath(changed.get(0).getPluginName());
+            // 递归地删除节点路径
             deletePathRecursive(selectorParentPath);
         }
+        // 变更的选择器数据遍历
         for (SelectorData data : changed) {
+            // 选择器的真实路径("/shenyu/selector/${pluginName}/${selectorId}")
             String selectorRealPath = DefaultPathConstants.buildSelectorRealPath(data.getPluginName(), data.getId());
+            // delete
             if (eventType == DataEventTypeEnum.DELETE) {
                 deleteNode(selectorRealPath);
                 LOG.debug("[DataChangedListener] delete appKey {}", selectorRealPath);
                 continue;
             }
-            //create or update
+            // create or update
             synchronized (selectorSyncObject) {
                 createOrUpdate(selectorRealPath, data);
             }
+            // 操作日志
             LOG.debug("[DataChangedListener] change path {} with data {}", selectorRealPath, data);
         }
     }
 
     @Override
     public void onPluginChanged(final List<PluginData> changed, final DataEventTypeEnum eventType) {
+        // 变更的插件数据遍历
         for (PluginData data : changed) {
+            // 构建插件路径("/shenyu/plugin/${pluginName}")
             String pluginPath = DefaultPathConstants.buildPluginPath(data.getName());
             // delete
             if (eventType == DataEventTypeEnum.DELETE) {
@@ -149,28 +165,36 @@ public void onPluginChanged(final List<PluginData> changed, final DataEventTypeE
                 LOG.debug("[DataChangedListener] delete pluginPath {}", pluginPath);
                 continue;
             }
-            //create or update
+            // create or update
             createOrUpdate(pluginPath, data);
+            // 操作日志
             LOG.debug("[DataChangedListener] change path {} with data {}", pluginPath, data);
         }
     }
 
     @Override
     public void onRuleChanged(final List<RuleData> changed, final DataEventTypeEnum eventType) {
+        // 规则数据的刷新事件
         if (eventType == DataEventTypeEnum.REFRESH && !changed.isEmpty()) {
-            String selectorParentPath = DefaultPathConstants.buildRuleParentPath(changed.get(0).getPluginName());
-            deletePathRecursive(selectorParentPath);
+            // 构建规则的父路径("/shenyu/rule/${pluginName}")
+            String ruleParentPath = DefaultPathConstants.buildRuleParentPath(changed.get(0).getPluginName());
+            // 递归地删除节点路径
+            deletePathRecursive(ruleParentPath);
         }
+        // 变更的规则数据遍历
         for (RuleData data : changed) {
+            // 规则的真实路径("/shenyu/rule/${pluginName}/${selectorId-ruleId}")
             String ruleRealPath = DefaultPathConstants.buildRulePath(data.getPluginName(), data.getSelectorId(), data.getId());
+            // delete
             if (eventType == DataEventTypeEnum.DELETE) {
                 deleteNode(ruleRealPath);
                 continue;
             }
-            //create or update
+            // create or update
             synchronized (ruleSyncObject) {
                 createOrUpdate(ruleRealPath, data);
             }
+            // 操作日志
             LOG.debug("[DataChangedListener] change path {} with data {}", ruleRealPath, data);
         }
     }

shenyu-admin/src/main/java/org/apache/shenyu/admin/listener/DataChangedEvent.java

@@ -27,6 +27,7 @@
 
 /**
  * Data change event.
+ * 数据变更事件
  *
  * @see DataChangedEventDispatcher
  * @since 2.0.0
@@ -35,8 +36,14 @@ public class DataChangedEvent extends ApplicationEvent {
 
     private static final long serialVersionUID = 8397163004365988739L;
 
+    /**
+     * 数据事件类型
+     */
     private final DataEventTypeEnum eventType;
 
+    /**
+     * 配置分组
+     */
     private final ConfigGroupEnum groupKey;
 
     /**

shenyu-admin/src/main/java/org/apache/shenyu/admin/listener/DataChangedEventDispatcher.java

@@ -37,12 +37,19 @@
 
 /**
  * Event forwarders, which forward the changed events to each ConfigEventListener.
+ * 数据变更事件的分发器
  */
 @Component
 public class DataChangedEventDispatcher implements ApplicationListener<DataChangedEvent>, InitializingBean {
 
+    /**
+     * 应用上下文
+     */
     private final ApplicationContext applicationContext;
 
+    /**
+     * 数据变更事件的监听器列表
+     */
     private List<DataChangedListener> listeners;
 
     public DataChangedEventDispatcher(final ApplicationContext applicationContext) {
@@ -52,22 +59,28 @@ public DataChangedEventDispatcher(final ApplicationContext applicationContext) {
     @Override
     @SuppressWarnings("unchecked")
     public void onApplicationEvent(final DataChangedEvent event) {
+        // 数据变更事件的监听器
         for (DataChangedListener listener : listeners) {
             switch (event.getGroupKey()) {
                 case APP_AUTH:
+                    // 应用认证数据
                     listener.onAppAuthChanged((List<AppAuthData>) event.getSource(), event.getEventType());
                     break;
                 case PLUGIN:
+                    // 插件数据变更
                     listener.onPluginChanged((List<PluginData>) event.getSource(), event.getEventType());
                     break;
                 case RULE:
+                    // 规则数据变更
                     listener.onRuleChanged((List<RuleData>) event.getSource(), event.getEventType());
                     break;
                 case SELECTOR:
+                    // 选择器数据变更
                     listener.onSelectorChanged((List<SelectorData>) event.getSource(), event.getEventType());
                     applicationContext.getBean(LoadServiceDocEntry.class).loadDocOnSelectorChanged((List<SelectorData>) event.getSource(), event.getEventType());
                     break;
                 case META_DATA:
+                    // 元数据变更
                     listener.onMetaDataChanged((List<MetaData>) event.getSource(), event.getEventType());
                     break;
                 case PROXY_SELECTOR:
@@ -84,6 +97,7 @@ public void onApplicationEvent(final DataChangedEvent event) {
 
     @Override
     public void afterPropertiesSet() {
+        // 数据变更事件的监听器列表
         Collection<DataChangedListener> listenerBeans = applicationContext.getBeansOfType(DataChangedListener.class).values();
         this.listeners = Collections.unmodifiableList(new ArrayList<>(listenerBeans));
     }

shenyu-admin/src/main/java/org/apache/shenyu/admin/listener/DataChangedListener.java

@@ -31,11 +31,13 @@
 /**
  * Event listener, used to send notification of event changes,
  * used to support HTTP, websocket, zookeeper and other event notifications.
+ * 数据变更事件的监听器
  */
 public interface DataChangedListener {
 
     /**
      * invoke this method when AppAuth was received.
+     * 应用认证数据变更
      *
      * @param changed   the changed
      * @param eventType the event type
@@ -45,6 +47,7 @@ default void onAppAuthChanged(List<AppAuthData> changed, DataEventTypeEnum event
 
     /**
      * invoke this method when Plugin was received.
+     * 插件数据变更
      *
      * @param changed   the changed
      * @param eventType the event type
@@ -54,6 +57,7 @@ default void onPluginChanged(List<PluginData> changed, DataEventTypeEnum eventTy
 
     /**
      * invoke this method when Selector was received.
+     * 选择器数据变更
      *
      * @param changed   the changed
      * @param eventType the event type
@@ -63,6 +67,7 @@ default void onSelectorChanged(List<SelectorData> changed, DataEventTypeEnum eve
 
     /**
      * On meta data changed.
+     * 元数据变更
      *
      * @param changed   the changed
      * @param eventType the event type
@@ -73,6 +78,7 @@ default void onMetaDataChanged(List<MetaData> changed, DataEventTypeEnum eventTy
 
     /**
      * invoke this method when Rule was received.
+     * 规则数据变更
      *
      * @param changed   the changed
      * @param eventType the event type

shenyu-admin/src/main/java/org/apache/shenyu/admin/listener/RecordLogDataChangedAdapterListener.java

@@ -25,10 +25,14 @@
 
 /**
  * RecordLogDataChangedAdapterListener.
+ * 操作记录日志数据变更的适配监听器
  */
 @Component
 public class RecordLogDataChangedAdapterListener implements DataChangedListener, ApplicationListener<AdminDataModelChangedEvent> {
-
+
+    /**
+     * 操作日志记录的数据访问对象
+     */
     private final OperationRecordLogMapper logMapper;
 
     public RecordLogDataChangedAdapterListener(final OperationRecordLogMapper logMapper) {

shenyu-admin/src/main/java/org/apache/shenyu/admin/listener/etcd/EtcdClient.java

@@ -75,7 +75,9 @@ public Boolean exists(final String key) {
      */
     public void put(final String key, final String value) {
         try {
-            client.getKVClient().put(ByteSequence.from(key, StandardCharsets.UTF_8), ByteSequence.from(value, StandardCharsets.UTF_8)).get();
+            client.getKVClient()
+                    .put(ByteSequence.from(key, StandardCharsets.UTF_8), ByteSequence.from(value, StandardCharsets.UTF_8))
+                    .get();
         } catch (Exception e) {
             LOG.error("update value of node error.", e);
             throw new ShenyuException(e.getMessage());
@@ -87,7 +89,8 @@ public void put(final String key, final String value) {
      * @param key node name
      */
     public void delete(final String key) {
-        client.getKVClient().delete(ByteSequence.from(key, StandardCharsets.UTF_8));
+        client.getKVClient()
+                .delete(ByteSequence.from(key, StandardCharsets.UTF_8));
     }
 
     /**

shenyu-admin/src/main/java/org/apache/shenyu/admin/listener/etcd/EtcdDataDataChangedListener.java

@@ -22,9 +22,13 @@
 
 /**
  * EtcdDataDataChangedListener.
+ * 使用etcd注册中心发布数据变更
  */
 public class EtcdDataDataChangedListener extends AbstractPathDataChangedListener {
 
+    /**
+     * etcd客户端
+     */
     private final EtcdClient etcdClient;
 
     public EtcdDataDataChangedListener(final EtcdClient client) {

shenyu-admin/src/main/java/org/apache/shenyu/admin/listener/nacos/NacosDataChangedListener.java

@@ -29,11 +29,15 @@
 
 /**
  * Use nacos to push data changes.
+ * 使用nacos注册中心发布数据变更
  */
 public class NacosDataChangedListener extends AbstractNodeDataChangedListener {
 
     private static final Logger LOG = LoggerFactory.getLogger(NacosDataChangedListener.class);
 
+    /**
+     * 配置服务
+     */
     private final ConfigService configService;
 
     public NacosDataChangedListener(final ConfigService configService) {

shenyu-admin/src/main/java/org/apache/shenyu/admin/listener/zookeeper/ZookeeperDataChangedListener.java

@@ -23,9 +23,13 @@
 
 /**
  * Use zookeeper to push data changes.
+ * 使用ZooKeeper注册中心发布数据变更
  */
 public class ZookeeperDataChangedListener extends AbstractPathDataChangedListener {
 
+    /**
+     * ZooKeeper客户端
+     */
     private final ZookeeperClient zkClient;
 
     public ZookeeperDataChangedListener(final ZookeeperClient zkClient) {
@@ -34,19 +38,22 @@ public ZookeeperDataChangedListener(final ZookeeperClient zkClient) {
 
     @Override
     public void createOrUpdate(final String path, final Object data) {
+        // 创建持久化路径节点
         zkClient.createOrUpdate(path, data, CreateMode.PERSISTENT);
     }
 
     @Override
     public void deleteNode(final String path) {
         if (zkClient.isExist(path)) {
+            // 删除路径节点
             zkClient.delete(path);
         }
     }
 
     @Override
     public void deletePathRecursive(final String path) {
         if (zkClient.isExist(path)) {
+            // 删除路径节点
             zkClient.delete(path);
         }
     }

shenyu-admin/src/main/java/org/apache/shenyu/admin/mapper/DiscoveryHandlerMapper.java

@@ -94,7 +94,9 @@ public interface DiscoveryHandlerMapper extends ExistProvider {
      * @param proxySelectorId proxySelectorId
      * @return DiscoveryHandlerDO
      */
-    DiscoveryHandlerDO selectByProxySelectorId(@Param("proxySelectorId") String proxySelectorId);
+    DiscoveryHandlerDO selectByProxySelectorId(
+            @Param("proxySelectorId") String proxySelectorId
+    );
 
     /**
      * DiscoveryHandlerDOList.
@@ -109,6 +111,8 @@ public interface DiscoveryHandlerMapper extends ExistProvider {
      * @param discoveryId discoveryId
      * @return DiscoveryHandlerDO list
      */
-    List<DiscoveryHandlerDO> selectByDiscoveryId(@Param("discoveryId")String discoveryId);
+    List<DiscoveryHandlerDO> selectByDiscoveryId(
+            @Param("discoveryId")String discoveryId
+    );
 
 }