[type:feat]Selector module adapts to namespace transformation

db/init/mysql/schema.sql

@@ -2370,3 +2370,5 @@ INSERT INTO `shenyu`.`permission` (`id`, `object_id`, `resource_id`, `date_creat
 INSERT INTO `shenyu`.`permission` (`id`, `object_id`, `resource_id`, `date_created`, `date_updated`) VALUES ('1792779493541343265', '1346358560427216896', '1792749362445840484', '2024-06-25 20:00:00.000', '2024-06-25 20:00:00.000');
 INSERT INTO `shenyu`.`permission` (`id`, `object_id`, `resource_id`, `date_created`, `date_updated`) VALUES ('1792779493541343266', '1346358560427216896', '1792749362445840485', '2024-06-25 20:00:00.000', '2024-06-25 20:00:00.000');
 INSERT INTO `shenyu`.`permission` (`id`, `object_id`, `resource_id`, `date_created`, `date_updated`) VALUES ('1792779493541343267', '1346358560427216896', '1792749362445840486', '2024-06-25 20:00:00.000', '2024-06-25 20:00:00.000');
+
+ALTER TABLE `shenyu`.`selector` ADD COLUMN `namespace_id` varchar(50) NULL COMMENT 'namespaceId' AFTER `match_restful`;

db/init/og/create-table.sql

@@ -2673,3 +2673,7 @@ INSERT INTO "public"."permission" VALUES ('1792779493541343265', '13463585604272
 INSERT INTO "public"."permission" VALUES ('1792779493541343266', '1346358560427216896', '1792749362445840485', '2024-06-25 20:00:00.000', '2024-06-25 20:00:00.000');
 INSERT INTO "public"."permission" VALUES ('1792779493541343267', '1346358560427216896', '1792749362445840486', '2024-06-25 20:00:00.000', '2024-06-25 20:00:00.000');
 
+
+ALTER TABLE "public"."selector" ADD COLUMN namespace_id VARCHAR(50) NULL;
+COMMENT ON COLUMN "public"."selector"."namespace_id" IS 'namespaceId';
+

db/init/oracle/schema.sql

@@ -2857,3 +2857,7 @@ INSERT /*+ IGNORE_ROW_ON_DUPKEY_INDEX (permission(id)) */ INTO permission (id, o
 INSERT /*+ IGNORE_ROW_ON_DUPKEY_INDEX (permission(id)) */ INTO permission (id, object_id, resource_id) VALUES ('1792779493541343265', '1346358560427216896', '1792749362445840484');
 INSERT /*+ IGNORE_ROW_ON_DUPKEY_INDEX (permission(id)) */ INTO permission (id, object_id, resource_id) VALUES ('1792779493541343266', '1346358560427216896', '1792749362445840485');
 INSERT /*+ IGNORE_ROW_ON_DUPKEY_INDEX (permission(id)) */ INTO permission (id, object_id, resource_id) VALUES ('1792779493541343267', '1346358560427216896', '1792749362445840486');
+
+
+ALTER TABLE selector ADD namespace_id VARCHAR2(50) NULL;
+COMMENT ON COLUMN selector.namespace_id IS 'namespaceId';

db/init/pg/create-table.sql

@@ -2791,3 +2791,5 @@ INSERT INTO "public"."permission" VALUES ('1792779493541343265', '13463585604272
 INSERT INTO "public"."permission" VALUES ('1792779493541343266', '1346358560427216896', '1792749362445840485', '2024-06-25 20:00:00.000', '2024-06-25 20:00:00.000');
 INSERT INTO "public"."permission" VALUES ('1792779493541343267', '1346358560427216896', '1792749362445840486', '2024-06-25 20:00:00.000', '2024-06-25 20:00:00.000');
 
+ALTER TABLE "public"."selector" ADD COLUMN namespace_id VARCHAR(50) NULL;
+COMMENT ON COLUMN "public"."selector"."namespace_id" IS 'namespaceId';

db/upgrade/2.6.1-upgrade-2.7.0-mysql.sql

@@ -168,3 +168,10 @@ INSERT INTO `shenyu`.`permission` (`id`, `object_id`, `resource_id`, `date_creat
 
 /* add column into dashboard_user table */
 ALTER TABLE `shenyu`.`dashboard_user` ADD COLUMN `client_id` varchar(32) NULL DEFAULT NULL COMMENT 'client id';
+
+
+ALTER TABLE `shenyu`.`selector` ADD COLUMN `namespace_id` varchar(50) NULL COMMENT 'namespaceId' AFTER `match_restful`;
+
+UPDATE selector
+SET namespace_id = '649330b6-c2d7-4edc-be8e-8a54df9eb385'
+WHERE namespaceId IS NULL;

db/upgrade/2.6.1-upgrade-2.7.0-og.sql

@@ -192,3 +192,8 @@ INSERT INTO "public"."permission" VALUES ('1792779493541343267', '13463585604272
 /* add column into dashboard_user table */
 ALTER TABLE "public"."dashboard_user" ADD COLUMN client_id VARCHAR(32) NULL;
 COMMENT ON COLUMN "public"."dashboard_user".client_id IS 'client id';
+
+ALTER TABLE "public"."selector" ADD COLUMN namespace_id VARCHAR(50) NULL;
+COMMENT ON COLUMN "public"."selector"."namespace_id" IS 'namespaceId';
+
+UPDATE "public"."selector" SET namespace_id = '649330b6-c2d7-4edc-be8e-8a54df9eb385' WHERE namespace_id IS NULL;

db/upgrade/2.6.1-upgrade-2.7.0-oracle.sql

@@ -218,3 +218,8 @@ INSERT /*+ IGNORE_ROW_ON_DUPKEY_INDEX (permission(id)) */ INTO permission (id, o
 /* add column into dashboard_user table */
 ALTER TABLE dashboard_user ADD client_id VARCHAR(32) NULL;
 COMMENT ON COLUMN dashboard_user.client_id IS 'client id';
+
+ALTER TABLE selector ADD namespace_id VARCHAR2(50) NULL;
+COMMENT ON COLUMN selector.namespace_id IS 'namespaceId';
+
+UPDATE selector SET namespace_id = '649330b6-c2d7-4edc-be8e-8a54df9eb385' WHERE namespace_id IS NULL;

db/upgrade/2.6.1-upgrade-2.7.0-pg.sql

@@ -193,3 +193,8 @@ INSERT INTO "public"."permission" VALUES ('1792779493541343267', '13463585604272
 /* add column into dashboard_user table */
 ALTER TABLE "public"."dashboard_user" ADD COLUMN client_id VARCHAR(32) NULL;
 COMMENT ON COLUMN "public"."dashboard_user".client_id IS 'client id';
+
+ALTER TABLE "public"."selector" ADD COLUMN namespace_id VARCHAR(50) NULL;
+COMMENT ON COLUMN "public"."selector"."namespace_id" IS 'namespaceId';
+
+UPDATE "public"."selector" SET namespace_id = '649330b6-c2d7-4edc-be8e-8a54df9eb385' WHERE namespace_id IS NULL;

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

@@ -17,9 +17,13 @@
 
 package org.apache.shenyu.admin.controller;
 
+import jakarta.validation.Valid;
+import jakarta.validation.constraints.NotNull;
 import org.apache.shenyu.admin.aspect.annotation.RestApi;
+import org.apache.shenyu.admin.mapper.NamespaceMapper;
 import org.apache.shenyu.admin.mapper.SelectorMapper;
 import org.apache.shenyu.admin.model.dto.BatchCommonDTO;
+import org.apache.shenyu.admin.model.dto.BatchNamespaceCommonDTO;
 import org.apache.shenyu.admin.model.dto.SelectorDTO;
 import org.apache.shenyu.admin.model.page.CommonPager;
 import org.apache.shenyu.admin.model.page.PageCondition;
@@ -41,12 +45,6 @@
 import org.springframework.web.bind.annotation.RequestBody;
 import org.springframework.web.bind.annotation.RequestParam;
 
-import jakarta.validation.Valid;
-import jakarta.validation.constraints.NotBlank;
-import jakarta.validation.constraints.NotEmpty;
-import jakarta.validation.constraints.NotNull;
-import java.util.List;
-
 /**
  * this is selector controller.
  */
@@ -66,29 +64,37 @@ public SelectorController(final SelectorService selectorService) {
      * @param name        selector name.
      * @param currentPage current page.
      * @param pageSize    page size.
+     * @param namespaceId namespaceId.
      * @return {@linkplain ShenyuAdminResult}
      */
     @GetMapping("")
     public AdminResult<CommonPager<SelectorVO>> querySelectors(final String pluginId, final String name,
-                                                                @RequestParam @NotNull final Integer currentPage,
-                                                                @RequestParam @NotNull final Integer pageSize) {
+                                                               @RequestParam @NotNull final Integer currentPage,
+                                                               @RequestParam @NotNull final Integer pageSize,
+                                                               @Valid @Existed(message = "namespaceId is not existed",
+                                                                       provider = NamespaceMapper.class) final String namespaceId
+    ) {
         final SelectorQueryCondition condition = new SelectorQueryCondition();
         condition.setUserId(SessionUtil.visitor().getUserId());
         condition.setPlugin(ListUtil.of(pluginId));
         condition.setKeyword(name);
+        condition.setNamespaceId(namespaceId);
         return searchAdaptor(new PageCondition<>(currentPage, pageSize, condition));
     }
 
     /**
      * detail selector.
      *
      * @param id selector id.
+     * @param namespaceId namespaceId.
      * @return {@linkplain ShenyuAdminResult}
      */
-    @GetMapping("/{id}")
+    @GetMapping("/{id}/{namespaceId}")
     public ShenyuAdminResult detailSelector(@PathVariable("id") @Valid
-                                            @Existed(provider = SelectorMapper.class, message = "selector is not existed") final String id) {
-        SelectorVO selectorVO = selectorService.findById(id);
+                                            @Existed(provider = SelectorMapper.class, message = "selector is not existed") final String id,
+                                            @PathVariable("namespaceId") @Valid
+                                            @Existed(provider = NamespaceMapper.class, message = "namespaceId is not existed") final String namespaceId) {
+        SelectorVO selectorVO = selectorService.findByIdAndNamespaceId(id, namespaceId);
         return ShenyuAdminResult.success(ShenyuResultMessage.DETAIL_SUCCESS, selectorVO);
     }
 
@@ -113,8 +119,7 @@ public ShenyuAdminResult createSelector(@Valid @RequestBody final SelectorDTO se
      */
     @PutMapping("/{id}")
     public ShenyuAdminResult updateSelector(@PathVariable("id") @Valid
-                                            @Existed(provider = SelectorMapper.class,
-                                                    message = "selector is not existed") final String id,
+                                            @Existed(provider = SelectorMapper.class, message = "selector is not existed") final String id,
                                             @Valid @RequestBody final SelectorDTO selectorDTO) {
         selectorDTO.setId(id);
         Integer updateCount = selectorService.createOrUpdate(selectorDTO);
@@ -129,7 +134,7 @@ public ShenyuAdminResult updateSelector(@PathVariable("id") @Valid
      */
     @PostMapping("/batchEnabled")
     public ShenyuAdminResult batchEnabled(@Valid @RequestBody final BatchCommonDTO batchCommonDTO) {
-        if (!selectorService.enabled(batchCommonDTO.getIds(), batchCommonDTO.getEnabled())) {
+        if (!selectorService.enabledByIdsAndNamespaceId(batchCommonDTO.getIds(), batchCommonDTO.getEnabled(), batchCommonDTO.getNamespaceId())) {
             return ShenyuAdminResult.error(ShenyuResultMessage.NOT_FOUND_EXCEPTION);
         }
         return ShenyuAdminResult.success(ShenyuResultMessage.ENABLE_SUCCESS);
@@ -138,12 +143,12 @@ public ShenyuAdminResult batchEnabled(@Valid @RequestBody final BatchCommonDTO b
     /**
      * delete Selectors.
      *
-     * @param ids primary key.
+     * @param batchNamespaceCommonDTO batchNamespaceCommonDTO.
      * @return {@linkplain ShenyuAdminResult}
      */
     @DeleteMapping("/batch")
-    public ShenyuAdminResult deleteSelector(@RequestBody @NotEmpty final List<@NotBlank String> ids) {
-        Integer deleteCount = selectorService.delete(ids);
+    public ShenyuAdminResult deleteSelector(@Valid @RequestBody final BatchNamespaceCommonDTO batchNamespaceCommonDTO) {
+        Integer deleteCount = selectorService.deleteByNamespaceId(batchNamespaceCommonDTO.getIds(), batchNamespaceCommonDTO.getNamespaceId());
         return ShenyuAdminResult.success(ShenyuResultMessage.DELETE_SUCCESS, deleteCount);
     }
 

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

@@ -49,7 +49,7 @@ public interface DiscoveryMapper extends ExistProvider {
     DiscoveryDO selectById(String id);
 
     /**
-     * selectAll.
+     * selectAllByNamespaceId.
      *
      * @return discoveryDOList
      */

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

@@ -38,15 +38,15 @@ public interface DiscoveryUpstreamMapper extends ExistProvider {
     Boolean existed(@Param("id") Serializable key);
 
     /**
-     * selectByIds.
+     * selectByIdsAndNamespaceId.
      *
      * @param ids id list
      * @return discoveryUpstreamDO list
      */
     List<DiscoveryUpstreamDO> selectByIds(@Param("ids") List<String> ids);
 
     /**
-     * selectAll.
+     * selectAllByNamespaceId.
      *
      * @return discoveryUpstreamDO list
      */
@@ -102,7 +102,7 @@ public interface DiscoveryUpstreamMapper extends ExistProvider {
     int updateSelective(DiscoveryUpstreamDO discoveryUpstreamDO);
 
     /**
-     * deleteByIds.
+     * deleteByIdsAndNamespaceId.
      *
      * @param ids id list
      * @return rows int

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

@@ -59,7 +59,7 @@ public interface NamespaceMapper extends ExistProvider {
 
 
     /**
-     * selectAll.
+     * selectAllByNamespaceId.
      *
      * @param name name.
      * @return namespaceDOList

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

@@ -65,20 +65,19 @@ public interface NamespacePluginRelMapper extends ExistProvider {
     /**
      * select plugin by namespacePluginId.
      *
-     * @param id    primary key.
+     * @param pluginId    primary key.
      * @param namespaceId namespace id.
      * @return {@linkplain PluginVO}
      */
-    NamespacePluginVO selectById(String id, String namespaceId);
+    NamespacePluginVO selectByPluginIdAndNamespaceId(String pluginId, String namespaceId);
 
     /**
      * select plugin by pluginId.
      *
      * @param pluginId    primary key.
-     * @param namespaceId namespace id.
      * @return {@linkplain PluginVO}
      */
-    NamespacePluginVO selectByPluginId(String pluginId, String namespaceId);
+    NamespacePluginVO selectByPluginId(String pluginId);
 
     /**
      * search by condition.
@@ -114,7 +113,7 @@ public interface NamespacePluginRelMapper extends ExistProvider {
      * @param namespaceId namespace id.
      * @return {@linkplain NamespacePluginRelDO}
      */
-    List<NamespacePluginVO> selectByIds(List<String> ids, String namespaceId);
+    List<NamespacePluginVO> selectByIdsAndNamespaceId(List<String> ids, String namespaceId);
 
 
     /**
@@ -124,22 +123,22 @@ public interface NamespacePluginRelMapper extends ExistProvider {
      * @param namespaceId namespace id.
      * @return rows int
      */
-    int deleteByIds(List<String> ids, String namespaceId);
+    int deleteByIdsAndNamespaceId(List<String> ids, String namespaceId);
 
     /**
      * select all.
      *
      * @param namespaceId namespace id.
      * @return {@linkplain List}
      */
-    List<NamespacePluginVO> selectAll(String namespaceId);
+    List<NamespacePluginVO> selectAllByNamespaceId(String namespaceId);
 
     /**
      * select all.
      *
      * @return {@linkplain List}
      */
-    List<NamespacePluginVO> selectAll();
+    List<NamespacePluginVO> selectAllByNamespaceId();
 
     /**
      * enable data by a list of ids.

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

@@ -71,23 +71,23 @@ public interface ProxySelectorMapper extends ExistProvider {
     int update(ProxySelectorDO proxySelectorDO);
 
     /**
-     * selectById.
+     * selectByIdAndNamespaceId.
      *
      * @param id id
      * @return ProxySelectorDO
      */
     ProxySelectorDO selectById(@Param("id") String id);
 
     /**
-     * selectByIds.
+     * selectByIdsAndNamespaceId.
      *
      * @param ids id list
      * @return proxySelectorDO list
      */
     List<ProxySelectorDO> selectByIds(@Param("ids") List<String> ids);
 
     /**
-     * deleteByIds.
+     * deleteByIdsAndNamespaceId.
      *
      * @param ids id list
      * @return rows int
@@ -113,7 +113,7 @@ public interface ProxySelectorMapper extends ExistProvider {
     List<ProxySelectorDO> selectByDiscoveryId(@Param("discoveryId") String discoveryId);
 
     /**
-     * selectAll.
+     * selectAllByNamespaceId.
      *
      * @return ProxySelectorDOList
      */

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

@@ -44,6 +44,15 @@ public interface SelectorMapper extends ExistProvider {
     @Override
     Boolean existed(@Param("id") Serializable id);
 
+    /**
+     * select selector by id.
+     *
+     * @param id          primary key.
+     * @param namespaceId namespaceId.
+     * @return {@linkplain SelectorDO}
+     */
+    SelectorDO selectByIdAndNamespaceId(String id, String namespaceId);
+
     /**
      * select selector by id.
      *
@@ -71,35 +80,41 @@ public interface SelectorMapper extends ExistProvider {
     /**
      * Find by plugin id list.
      *
-     * @param pluginId the plugin id
+     * @param pluginId    the plugin id
+     * @param namespaceId namespaceId.
      * @return the list
      */
-    List<SelectorDO> findByPluginId(String pluginId);
+    List<SelectorDO> findByPluginIdAndNamespaceId(String pluginId, String namespaceId);
 
     /**
-     * Find by plugin id list.
+     * Find by plugin id and namespace id list.
      *
-     * @param pluginIds the plugin ids
+     * @param pluginIds   the plugin ids
+     * @param namespaceId namespaceId.
      * @return the list
      */
-    List<SelectorDO> findByPluginIds(List<String> pluginIds);
+    List<SelectorDO> findByPluginIdsAndNamespaceId(@Param("list") List<String> pluginIds, String namespaceId);
 
     /**
      * select select by name.
      *
-     * @param name the name
+     * @param name        the name
+     * @param namespaceId namespaceId.
      * @return selector do list
      */
-    List<SelectorDO> selectByName(String name);
+    List<SelectorDO> selectByNameAndNamespaceId(String name, String namespaceId);
 
     /**
      * Find by name and plugin id selector do.
      *
-     * @param name     the name
-     * @param pluginId the plugin id
+     * @param name        the name
+     * @param pluginId    the plugin id
+     * @param namespaceId namespaceId.
      * @return the selector do
      */
-    SelectorDO findByNameAndPluginId(@Param("name") String name, @Param("pluginId") String pluginId);
+    SelectorDO findByNameAndPluginIdAndNamespaceId(@Param("name") String name,
+                                                   @Param("pluginId") String pluginId,
+                                                   @Param("namespaceId") String namespaceId);
 
     /**
      * count selector by query.
@@ -199,7 +214,7 @@ public interface SelectorMapper extends ExistProvider {
     /**
      * update status.
      *
-     * @param id id
+     * @param id      id
      * @param enabled enabled
      * @return result
      */