[rocketmq-eventbridge] branch main updated: Update api list connection name (#68)

[shenlin]

This is an automated email from the ASF dual-hosted git repository.

shenlin pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/rocketmq-eventbridge.git


The following commit(s) were added to refs/heads/main by this push:
     new 9e638ab  Update api list connection name (#68)
9e638ab is described below

commit 9e638ab44a95e62661450cba093c5957407d1980
Author: zhaohai <33314633+zhaohai...@users.noreply.github.com>
AuthorDate: Wed Mar 29 11:10:07 2023 +0800

    Update api list connection name (#68)
    
    Update api list connection name
---
 .../eventbridge/adapter/api/controller/ApiDestinationController.java  | 2 +-
 .../adapter/api/dto/apidestination/ListApiDestinationsRequest.java    | 4 ++--
 .../src/main/resources/mybatis/EventApiDestinationMapper.xml          | 2 +-
 3 files changed, 4 insertions(+), 4 deletions(-)

diff --git 
a/adapter/api/src/main/java/org/apache/rocketmq/eventbridge/adapter/api/controller/ApiDestinationController.java
 
b/adapter/api/src/main/java/org/apache/rocketmq/eventbridge/adapter/api/controller/ApiDestinationController.java
index d0164bd..0cac4fe 100644
--- 
a/adapter/api/src/main/java/org/apache/rocketmq/eventbridge/adapter/api/controller/ApiDestinationController.java
+++ 
b/adapter/api/src/main/java/org/apache/rocketmq/eventbridge/adapter/api/controller/ApiDestinationController.java
@@ -172,7 +172,7 @@ public class ApiDestinationController {
                 final PaginationResult<List<ApiDestinationDTO>> 
listPaginationResult
                     = 
apiDestinationService.listApiDestinations(accountAPI.getResourceOwnerAccountId(ctx),
                     listApiDestinationsRequest.getApiDestinationNamePrefix(),
-                        listApiDestinationsRequest.getConnectionNamePrefix(), 
listApiDestinationsRequest.getNextToken(),
+                        listApiDestinationsRequest.getConnectionName(), 
listApiDestinationsRequest.getNextToken(),
                     listApiDestinationsRequest.getMaxResults());
                 List<ApiDestinationsResponse> apiDestinationsResponses = 
Lists.newArrayList();
                 listPaginationResult.getData()
diff --git 
a/adapter/api/src/main/java/org/apache/rocketmq/eventbridge/adapter/api/dto/apidestination/ListApiDestinationsRequest.java
 
b/adapter/api/src/main/java/org/apache/rocketmq/eventbridge/adapter/api/dto/apidestination/ListApiDestinationsRequest.java
index a6b48de..cfb1555 100644
--- 
a/adapter/api/src/main/java/org/apache/rocketmq/eventbridge/adapter/api/dto/apidestination/ListApiDestinationsRequest.java
+++ 
b/adapter/api/src/main/java/org/apache/rocketmq/eventbridge/adapter/api/dto/apidestination/ListApiDestinationsRequest.java
@@ -33,8 +33,8 @@ public class ListApiDestinationsRequest extends BaseResponse {
     @SerializedName("ApiDestinationNamePrefix")
     private String apiDestinationNamePrefix;
 
-    @SerializedName("ConnectionNamePrefix")
-    private String connectionNamePrefix;
+    @SerializedName("ConnectionName")
+    private String connectionName;
 
 
     @Min(value = 0, message = "The limit size of page is invalid, which must 
greater than 0 and less than [{0}].")
diff --git 
a/adapter/persistence/src/main/resources/mybatis/EventApiDestinationMapper.xml 
b/adapter/persistence/src/main/resources/mybatis/EventApiDestinationMapper.xml
index e403654..fab1e9f 100644
--- 
a/adapter/persistence/src/main/resources/mybatis/EventApiDestinationMapper.xml
+++ 
b/adapter/persistence/src/main/resources/mybatis/EventApiDestinationMapper.xml
@@ -72,7 +72,7 @@
         <where>
             <if test="accountId != null and accountId != ''">account_id = 
#{accountId}</if>
             <if test="name != null and name != ''">and name like 
concat('%',#{name},'%')</if>
-            <if test="connectionName != null and connectionName != ''">and 
connection_name like concat('%',#{connectionName},'%')</if>
+            <if test="connectionName != null and connectionName != ''">and 
connection_name = #{connectionName}</if>
         </where>
         order by gmt_modify desc LIMIT #{nextToken} , #{maxResults}
     </select>