This is an automated email from the ASF dual-hosted git repository.
panyuepeng 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 ecd3d7919 [Improve] Improve streampark-console system package module
mapper name base on [3.1 Naming Style] (#3292)
ecd3d7919 is described below
commit ecd3d79198eb8bfc0b1ec7296ac70d9d8cc4a043
Author: VampireAchao <[email protected]>
AuthorDate: Sat Oct 28 17:01:23 2023 +0800
[Improve] Improve streampark-console system package module mapper name base
on [3.1 Naming Style] (#3292)
---
.../streampark/console/system/mapper/AccessTokenMapper.java | 9 +++++----
.../apache/streampark/console/system/mapper/MemberMapper.java | 4 ++--
.../org/apache/streampark/console/system/mapper/MenuMapper.java | 6 +++---
.../org/apache/streampark/console/system/mapper/RoleMapper.java | 2 +-
.../org/apache/streampark/console/system/mapper/TeamMapper.java | 4 ++--
.../org/apache/streampark/console/system/mapper/UserMapper.java | 6 +++---
.../console/system/service/impl/AccessTokenServiceImpl.java | 8 ++++----
.../console/system/service/impl/MemberServiceImpl.java | 4 ++--
.../streampark/console/system/service/impl/MenuServiceImpl.java | 4 ++--
.../streampark/console/system/service/impl/RoleServiceImpl.java | 2 +-
.../streampark/console/system/service/impl/TeamServiceImpl.java | 4 ++--
.../streampark/console/system/service/impl/UserServiceImpl.java | 6 +++---
.../src/main/resources/mapper/system/AccessTokenMapper.xml | 8 ++++----
.../src/main/resources/mapper/system/MemberMapper.xml | 4 ++--
.../src/main/resources/mapper/system/MenuMapper.xml | 6 +++---
.../src/main/resources/mapper/system/RoleMapper.xml | 2 +-
.../src/main/resources/mapper/system/TeamMapper.xml | 4 ++--
.../src/main/resources/mapper/system/UserMapper.xml | 6 +++---
18 files changed, 45 insertions(+), 44 deletions(-)
diff --git
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/mapper/AccessTokenMapper.java
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/mapper/AccessTokenMapper.java
index d36edec4e..5def2c56f 100644
---
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/mapper/AccessTokenMapper.java
+++
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/mapper/AccessTokenMapper.java
@@ -27,12 +27,13 @@ import
com.baomidou.mybatisplus.extension.plugins.pagination.Page;
public interface AccessTokenMapper extends BaseMapper<AccessToken> {
- IPage<AccessToken> page(Page<AccessToken> page, @Param("accessToken")
AccessToken accessToken);
+ IPage<AccessToken> selectPage(
+ Page<AccessToken> page, @Param("accessToken") AccessToken accessToken);
- AccessToken getByUserToken(
+ AccessToken selectByUserToken(
@Param("userId") Long userId, @Param("accessToken") String accessToken);
- AccessToken getById(@Param("id") Long id);
+ AccessToken selectById(@Param("id") Long id);
- AccessToken getByUserId(@Param("userId") Long userId);
+ AccessToken selectByUserId(@Param("userId") Long userId);
}
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 34ceef610..efd765b62 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
@@ -46,7 +46,7 @@ public interface MemberMapper extends BaseMapper<Member> {
*/
Boolean deleteByRoleId(@Param("roleId") Long roleId);
- IPage<Member> findUsers(Page<Member> page, @Param("member") Member member);
+ IPage<Member> selectPage(Page<Member> page, @Param("member") Member member);
- List<User> findUsersNotInTeam(@Param("teamId") Long teamId);
+ List<User> selectUsersNotInTeam(@Param("teamId") Long teamId);
}
diff --git
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/mapper/MenuMapper.java
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/mapper/MenuMapper.java
index 554be19cd..c8fdfb5f1 100644
---
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/mapper/MenuMapper.java
+++
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/mapper/MenuMapper.java
@@ -27,9 +27,9 @@ import java.util.List;
public interface MenuMapper extends BaseMapper<Menu> {
- List<String> findUserPermissions(@Param("userId") Long userId,
@Param("teamId") Long teamId);
+ List<String> selectPermissions(@Param("userId") Long userId,
@Param("teamId") Long teamId);
- List<Menu> findUserMenus(@Param("userId") Long userId, @Param("teamId") Long
teamId);
+ List<Menu> selectMenus(@Param("userId") Long userId, @Param("teamId") Long
teamId);
/**
* Find the user ID associated with the current menu or button
@@ -37,5 +37,5 @@ public interface MenuMapper extends BaseMapper<Menu> {
* @param menuId menuId
* @return user id list
*/
- List<String> findUserIdsByMenuId(String menuId);
+ List<String> selectUserIdsByMenuId(String menuId);
}
diff --git
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/mapper/RoleMapper.java
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/mapper/RoleMapper.java
index 591da68e5..19da6df23 100644
---
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/mapper/RoleMapper.java
+++
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/mapper/RoleMapper.java
@@ -27,5 +27,5 @@ import
com.baomidou.mybatisplus.extension.plugins.pagination.Page;
public interface RoleMapper extends BaseMapper<Role> {
- IPage<Role> findRole(Page<Role> page, @Param("role") Role role);
+ IPage<Role> selectPage(Page<Role> page, @Param("role") Role role);
}
diff --git
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/mapper/TeamMapper.java
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/mapper/TeamMapper.java
index 1e2100b4f..a24c8d38e 100644
---
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/mapper/TeamMapper.java
+++
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/mapper/TeamMapper.java
@@ -29,7 +29,7 @@ import java.util.List;
public interface TeamMapper extends BaseMapper<Team> {
- IPage<Team> findTeam(Page<Team> page, @Param("team") Team team);
+ IPage<Team> selectPage(Page<Team> page, @Param("team") Team team);
- List<Team> findUserTeams(Long userId);
+ List<Team> selectTeamsByUserId(Long userId);
}
diff --git
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/mapper/UserMapper.java
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/mapper/UserMapper.java
index add41e4c0..7b8e8a644 100644
---
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/mapper/UserMapper.java
+++
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/mapper/UserMapper.java
@@ -29,11 +29,11 @@ import java.util.List;
public interface UserMapper extends BaseMapper<User> {
- IPage<User> findUserDetail(Page page, @Param("user") User user);
+ IPage<User> selectPage(Page page, @Param("user") User user);
- List<User> getNoTokenUser();
+ List<User> selectNoTokenUsers();
- List<User> findByAppOwner(@Param("teamId") Long teamId);
+ List<User> selectUsersByAppOwner(@Param("teamId") Long teamId);
void clearLastTeamByUserId(@Param("userId") Long userId);
diff --git
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/service/impl/AccessTokenServiceImpl.java
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/service/impl/AccessTokenServiceImpl.java
index 69c88b9c3..45f239c6d 100644
---
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/service/impl/AccessTokenServiceImpl.java
+++
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/service/impl/AccessTokenServiceImpl.java
@@ -89,7 +89,7 @@ public class AccessTokenServiceImpl extends
ServiceImpl<AccessTokenMapper, Acces
@Override
public IPage<AccessToken> findAccessTokens(AccessToken tokenParam,
RestRequest request) {
Page<AccessToken> page = new
MybatisPager<AccessToken>().getDefaultPage(request);
- this.baseMapper.page(page, tokenParam);
+ this.baseMapper.selectPage(page, tokenParam);
List<AccessToken> records = page.getRecords();
page.setRecords(records);
return page;
@@ -97,13 +97,13 @@ public class AccessTokenServiceImpl extends
ServiceImpl<AccessTokenMapper, Acces
@Override
public boolean checkTokenEffective(Long userId, String token) {
- AccessToken res = baseMapper.getByUserToken(userId, token);
+ AccessToken res = baseMapper.selectByUserToken(userId, token);
return res != null &&
AccessToken.STATUS_ENABLE.equals(res.getFinalStatus());
}
@Override
public RestResponse toggleToken(Long tokenId) {
- AccessToken tokenInfo = baseMapper.getById(tokenId);
+ AccessToken tokenInfo = baseMapper.selectById(tokenId);
if (Objects.isNull(tokenInfo)) {
return RestResponse.fail(ResponseCode.CODE_FAIL_ALERT, "accessToken
could not be found!");
}
@@ -127,6 +127,6 @@ public class AccessTokenServiceImpl extends
ServiceImpl<AccessTokenMapper, Acces
@Override
public AccessToken getByUserId(Long userId) {
- return baseMapper.getByUserId(userId);
+ return baseMapper.selectByUserId(userId);
}
}
diff --git
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/service/impl/MemberServiceImpl.java
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/service/impl/MemberServiceImpl.java
index 56a3b3e18..dba05949f 100644
---
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/service/impl/MemberServiceImpl.java
+++
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/service/impl/MemberServiceImpl.java
@@ -79,12 +79,12 @@ public class MemberServiceImpl extends
ServiceImpl<MemberMapper, Member> impleme
Page<Member> page = new Page<>();
page.setCurrent(request.getPageNum());
page.setSize(request.getPageSize());
- return baseMapper.findUsers(page, member);
+ return baseMapper.selectPage(page, member);
}
@Override
public List<User> findCandidateUsers(Long teamId) {
- return baseMapper.findUsersNotInTeam(teamId);
+ return baseMapper.selectUsersNotInTeam(teamId);
}
@Override
diff --git
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/service/impl/MenuServiceImpl.java
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/service/impl/MenuServiceImpl.java
index 0f01a38aa..197ed20b4 100644
---
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/service/impl/MenuServiceImpl.java
+++
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/service/impl/MenuServiceImpl.java
@@ -71,7 +71,7 @@ public class MenuServiceImpl extends ServiceImpl<MenuMapper,
Menu> implements Me
if (UserTypeEnum.ADMIN == user.getUserType()) {
return
this.list().stream().map(Menu::getPerms).collect(Collectors.toList());
}
- return this.baseMapper.findUserPermissions(userId, teamId);
+ return this.baseMapper.selectPermissions(userId, teamId);
}
@Override
@@ -88,7 +88,7 @@ public class MenuServiceImpl extends ServiceImpl<MenuMapper,
Menu> implements Me
new LambdaQueryWrapper<Menu>().eq(Menu::getType,
"0").orderByAsc(Menu::getOrderNum);
return this.list(queryWrapper);
}
- return this.baseMapper.findUserMenus(userId, teamId);
+ return this.baseMapper.selectMenus(userId, teamId);
}
@Override
diff --git
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/service/impl/RoleServiceImpl.java
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/service/impl/RoleServiceImpl.java
index 7a3f580b2..81ac22326 100644
---
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/service/impl/RoleServiceImpl.java
+++
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/service/impl/RoleServiceImpl.java
@@ -63,7 +63,7 @@ public class RoleServiceImpl extends ServiceImpl<RoleMapper,
Role> implements Ro
Page<Role> page = new Page<>();
page.setCurrent(request.getPageNum());
page.setSize(request.getPageSize());
- return this.baseMapper.findRole(page, role);
+ return this.baseMapper.selectPage(page, role);
}
@Override
diff --git
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/service/impl/TeamServiceImpl.java
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/service/impl/TeamServiceImpl.java
index 25e71b018..cf140f3d7 100644
---
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/service/impl/TeamServiceImpl.java
+++
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/service/impl/TeamServiceImpl.java
@@ -67,7 +67,7 @@ public class TeamServiceImpl extends ServiceImpl<TeamMapper,
Team> implements Te
Page<Team> page = new Page<>();
page.setCurrent(request.getPageNum());
page.setSize(request.getPageSize());
- return this.baseMapper.findTeam(page, team);
+ return this.baseMapper.selectPage(page, team);
}
@Override
@@ -144,6 +144,6 @@ public class TeamServiceImpl extends
ServiceImpl<TeamMapper, Team> implements Te
if (UserTypeEnum.ADMIN == user.getUserType()) {
return this.list();
}
- return baseMapper.findUserTeams(userId);
+ return baseMapper.selectTeamsByUserId(userId);
}
}
diff --git
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/service/impl/UserServiceImpl.java
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/service/impl/UserServiceImpl.java
index 7a007751f..f3253d05c 100644
---
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/service/impl/UserServiceImpl.java
+++
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/service/impl/UserServiceImpl.java
@@ -93,7 +93,7 @@ public class UserServiceImpl extends ServiceImpl<UserMapper,
User> implements Us
Page<User> page = new Page<>();
page.setCurrent(request.getPageNum());
page.setSize(request.getPageSize());
- IPage<User> resPage = this.baseMapper.findUserDetail(page, user);
+ IPage<User> resPage = this.baseMapper.selectPage(page, user);
Utils.notNull(resPage);
if (resPage.getTotal() == 0) {
@@ -187,7 +187,7 @@ public class UserServiceImpl extends
ServiceImpl<UserMapper, User> implements Us
@Override
public List<User> getNoTokenUser() {
- List<User> users = this.baseMapper.getNoTokenUser();
+ List<User> users = this.baseMapper.selectNoTokenUsers();
if (!users.isEmpty()) {
users.forEach(User::dataMasking);
}
@@ -236,7 +236,7 @@ public class UserServiceImpl extends
ServiceImpl<UserMapper, User> implements Us
@Override
public List<User> findByAppOwner(Long teamId) {
- return baseMapper.findByAppOwner(teamId);
+ return baseMapper.selectUsersByAppOwner(teamId);
}
/**
diff --git
a/streampark-console/streampark-console-service/src/main/resources/mapper/system/AccessTokenMapper.xml
b/streampark-console/streampark-console-service/src/main/resources/mapper/system/AccessTokenMapper.xml
index e36715720..1c4930029 100644
---
a/streampark-console/streampark-console-service/src/main/resources/mapper/system/AccessTokenMapper.xml
+++
b/streampark-console/streampark-console-service/src/main/resources/mapper/system/AccessTokenMapper.xml
@@ -37,7 +37,7 @@
as finalStatus
</sql>
- <select id="page"
resultType="org.apache.streampark.console.system.entity.AccessToken"
+ <select id="selectPage"
resultType="org.apache.streampark.console.system.entity.AccessToken"
parameterType="org.apache.streampark.console.system.entity.AccessToken">
select
<include refid="Base_Column_List"/>
@@ -49,7 +49,7 @@
</where>
</select>
- <select id="getByUserId"
resultType="org.apache.streampark.console.system.entity.AccessToken">
+ <select id="selectByUserId"
resultType="org.apache.streampark.console.system.entity.AccessToken">
select
<include refid="Base_Column_List"/>
from t_user t2
@@ -58,7 +58,7 @@
where t1.user_id = #{userId}
</select>
- <select id="getByUserToken"
resultType="org.apache.streampark.console.system.entity.AccessToken">
+ <select id="selectByUserToken"
resultType="org.apache.streampark.console.system.entity.AccessToken">
select
<include refid="Base_Column_List"/>
from t_user t2
@@ -67,7 +67,7 @@
and t1.token = #{accessToken,jdbcType=VARCHAR}
</select>
- <select id="getById"
resultType="org.apache.streampark.console.system.entity.AccessToken">
+ <select id="selectById"
resultType="org.apache.streampark.console.system.entity.AccessToken">
select
<include refid="Base_Column_List"/>
from t_access_token t1
diff --git
a/streampark-console/streampark-console-service/src/main/resources/mapper/system/MemberMapper.xml
b/streampark-console/streampark-console-service/src/main/resources/mapper/system/MemberMapper.xml
index 83d678812..2b1df7363 100644
---
a/streampark-console/streampark-console-service/src/main/resources/mapper/system/MemberMapper.xml
+++
b/streampark-console/streampark-console-service/src/main/resources/mapper/system/MemberMapper.xml
@@ -39,7 +39,7 @@
where role_id = #{roleId}
</delete>
- <select id="findUsers"
resultType="org.apache.streampark.console.system.entity.Member"
parameterType="org.apache.streampark.console.system.entity.Member">
+ <select id="selectPage"
resultType="org.apache.streampark.console.system.entity.Member"
parameterType="org.apache.streampark.console.system.entity.Member">
select tur.*,
u.username,
r.role_name
@@ -68,7 +68,7 @@
</if>
</select>
- <select id="findUsersNotInTeam"
resultType="org.apache.streampark.console.system.entity.User">
+ <select id="selectUsersNotInTeam"
resultType="org.apache.streampark.console.system.entity.User">
select tu.* from t_user tu
where tu.user_id
not in (
diff --git
a/streampark-console/streampark-console-service/src/main/resources/mapper/system/MenuMapper.xml
b/streampark-console/streampark-console-service/src/main/resources/mapper/system/MenuMapper.xml
index 9ed8abe91..da346613c 100644
---
a/streampark-console/streampark-console-service/src/main/resources/mapper/system/MenuMapper.xml
+++
b/streampark-console/streampark-console-service/src/main/resources/mapper/system/MenuMapper.xml
@@ -33,7 +33,7 @@
<result column="modify_time" jdbcType="TIMESTAMP"
property="modifyTime"/>
</resultMap>
- <select id="findUserPermissions" resultType="string">
+ <select id="selectPermissions" resultType="string">
select distinct m.perms
from t_role r
left join t_member ur on (r.role_id = ur.role_id)
@@ -45,7 +45,7 @@
and m.perms <> ''
</select>
- <select id="findUserMenus" resultMap="menu">
+ <select id="selectMenus" resultMap="menu">
select m.*
from t_menu m inner join t_role_menu rm
on m.menu_id = rm.menu_id
@@ -57,7 +57,7 @@
order by m.order_num
</select>
- <select id="findUserIdsByMenuId" parameterType="string"
resultType="string">
+ <select id="selectUserIdsByMenuId" parameterType="string"
resultType="string">
select user_id
from t_member
where role_id in
diff --git
a/streampark-console/streampark-console-service/src/main/resources/mapper/system/RoleMapper.xml
b/streampark-console/streampark-console-service/src/main/resources/mapper/system/RoleMapper.xml
index e49a07bdf..9b26172ae 100644
---
a/streampark-console/streampark-console-service/src/main/resources/mapper/system/RoleMapper.xml
+++
b/streampark-console/streampark-console-service/src/main/resources/mapper/system/RoleMapper.xml
@@ -25,7 +25,7 @@
<result column="description" jdbcType="VARCHAR"
property="description"/>
</resultMap>
- <select id="findRole"
resultType="org.apache.streampark.console.system.entity.Role"
parameterType="org.apache.streampark.console.system.entity.Role">
+ <select id="selectPage"
resultType="org.apache.streampark.console.system.entity.Role"
parameterType="org.apache.streampark.console.system.entity.Role">
select * from t_role
<where>
<if test="role.roleName != null and role.roleName != ''">
diff --git
a/streampark-console/streampark-console-service/src/main/resources/mapper/system/TeamMapper.xml
b/streampark-console/streampark-console-service/src/main/resources/mapper/system/TeamMapper.xml
index a366a9d3e..f2bba76db 100644
---
a/streampark-console/streampark-console-service/src/main/resources/mapper/system/TeamMapper.xml
+++
b/streampark-console/streampark-console-service/src/main/resources/mapper/system/TeamMapper.xml
@@ -25,7 +25,7 @@
<result column="modify_time" jdbcType="TIMESTAMP"
property="modifyTime"/>
</resultMap>
- <select id="findTeam"
resultType="org.apache.streampark.console.system.entity.Team"
parameterType="org.apache.streampark.console.system.entity.Team">
+ <select id="selectPage"
resultType="org.apache.streampark.console.system.entity.Team"
parameterType="org.apache.streampark.console.system.entity.Team">
select * from t_team
<where>
<if test="team.teamName != null and team.teamName != ''">
@@ -43,7 +43,7 @@
</if>
</select>
- <select id="findUserTeams"
resultType="org.apache.streampark.console.system.entity.Team"
parameterType="org.apache.streampark.console.system.entity.Team">
+ <select id="selectTeamsByUserId"
resultType="org.apache.streampark.console.system.entity.Team"
parameterType="org.apache.streampark.console.system.entity.Team">
select t.* from t_team t
join t_member m
on t.id = m.team_id
diff --git
a/streampark-console/streampark-console-service/src/main/resources/mapper/system/UserMapper.xml
b/streampark-console/streampark-console-service/src/main/resources/mapper/system/UserMapper.xml
index aeec2eb4f..cf06e3fab 100644
---
a/streampark-console/streampark-console-service/src/main/resources/mapper/system/UserMapper.xml
+++
b/streampark-console/streampark-console-service/src/main/resources/mapper/system/UserMapper.xml
@@ -34,7 +34,7 @@
<result column="login_type" jdbcType="INTEGER" property="loginType"/>
</resultMap>
- <select id="findUserDetail"
resultType="org.apache.streampark.console.system.entity.User"
parameterType="org.apache.streampark.console.system.entity.User">
+ <select id="selectPage"
resultType="org.apache.streampark.console.system.entity.User"
parameterType="org.apache.streampark.console.system.entity.User">
select * from t_user
<where>
<if test="user.username != null and user.username != ''">
@@ -58,13 +58,13 @@
</if>
</select>
- <select id="getNoTokenUser"
resultType="org.apache.streampark.console.system.entity.User"
parameterType="org.apache.streampark.console.system.entity.User">
+ <select id="selectNoTokenUsers"
resultType="org.apache.streampark.console.system.entity.User"
parameterType="org.apache.streampark.console.system.entity.User">
select u.* from t_user u left join t_access_token t
on u.user_id = t.user_id
where t.user_id is null
</select>
- <select id="findByAppOwner"
resultType="org.apache.streampark.console.system.entity.User"
parameterType="org.apache.streampark.console.system.entity.User">
+ <select id="selectUsersByAppOwner"
resultType="org.apache.streampark.console.system.entity.User"
parameterType="org.apache.streampark.console.system.entity.User">
select u.* from t_user u inner join (
select distinct(user_id) as user_id
from t_flink_app
