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

benjobs pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-streampark.git


The following commit(s) were added to refs/heads/dev by this push:
     new 8f1cf35c5 [Improve] update mapper Boolean return type to primitive 
(#3337)
8f1cf35c5 is described below

commit 8f1cf35c5703a8b51bed1210b85de36614708feb
Author: VampireAchao <[email protected]>
AuthorDate: Wed Nov 15 22:08:00 2023 +0800

    [Improve] update mapper Boolean return type to primitive (#3337)
---
 .../org/apache/streampark/console/core/mapper/FlinkClusterMapper.java | 4 ++--
 .../java/org/apache/streampark/console/core/mapper/ProjectMapper.java | 2 +-
 .../org/apache/streampark/console/core/mapper/VariableMapper.java     | 2 +-
 .../org/apache/streampark/console/system/mapper/MemberMapper.java     | 4 ++--
 4 files changed, 6 insertions(+), 6 deletions(-)

diff --git 
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/mapper/FlinkClusterMapper.java
 
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/mapper/FlinkClusterMapper.java
index 1e59183da..3c54ceb17 100644
--- 
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/mapper/FlinkClusterMapper.java
+++ 
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/mapper/FlinkClusterMapper.java
@@ -25,7 +25,7 @@ import com.baomidou.mybatisplus.core.mapper.BaseMapper;
 
 public interface FlinkClusterMapper extends BaseMapper<FlinkCluster> {
 
-  Boolean existsByClusterId(@Param("clusterId") String clusterId, @Param("id") 
Long id);
+  boolean existsByClusterId(@Param("clusterId") String clusterId, @Param("id") 
Long id);
 
-  Boolean existsByClusterName(@Param("clusterName") String clusterName, 
@Param("id") Long id);
+  boolean existsByClusterName(@Param("clusterName") String clusterName, 
@Param("id") Long id);
 }
diff --git 
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/mapper/ProjectMapper.java
 
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/mapper/ProjectMapper.java
index 11f6a1ea6..d14f79e0b 100644
--- 
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/mapper/ProjectMapper.java
+++ 
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/mapper/ProjectMapper.java
@@ -35,7 +35,7 @@ public interface ProjectMapper extends BaseMapper<Project> {
 
   IPage<Project> selectPage(Page<Project> page, @Param("project") Project 
project);
 
-  Boolean existsByTeamId(@Param("teamId") Long teamId);
+  boolean existsByTeamId(@Param("teamId") Long teamId);
 
   List<Project> selectProjectsByTeamId(@Param("teamId") Long teamId);
 }
diff --git 
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/mapper/VariableMapper.java
 
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/mapper/VariableMapper.java
index f381265af..638bb652a 100644
--- 
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/mapper/VariableMapper.java
+++ 
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/mapper/VariableMapper.java
@@ -33,5 +33,5 @@ public interface VariableMapper extends BaseMapper<Variable> {
 
   List<Variable> selectVarsByTeamId(@Param("teamId") Long teamId, 
@Param("keyword") String keyword);
 
-  Boolean existsByTeamId(@Param("teamId") Long teamId);
+  boolean existsByTeamId(@Param("teamId") Long teamId);
 }
diff --git 
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/mapper/MemberMapper.java
 
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/mapper/MemberMapper.java
index efd765b62..7fb7c3d3c 100644
--- 
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/mapper/MemberMapper.java
+++ 
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/mapper/MemberMapper.java
@@ -36,7 +36,7 @@ public interface MemberMapper extends BaseMapper<Member> {
    * @param userId user id
    * @return boolean
    */
-  Boolean deleteByUserId(@Param("userId") Long userId);
+  boolean deleteByUserId(@Param("userId") Long userId);
 
   /**
    * delete user by role id
@@ -44,7 +44,7 @@ public interface MemberMapper extends BaseMapper<Member> {
    * @param roleId role id
    * @return boolean
    */
-  Boolean deleteByRoleId(@Param("roleId") Long roleId);
+  boolean deleteByRoleId(@Param("roleId") Long roleId);
 
   IPage<Member> selectPage(Page<Member> page, @Param("member") Member member);
 

Reply via email to