Mybatis左连接的实现方式

news2024/9/28 11:16:29

在使用 MyBatis Plus 进行数据库操作时，我们有时需要从多个表中获取数据。这篇文章将介绍如何在 MyBatis Plus 中实现左连接查询。我们将以两个表格为例，一个是部门领导表 (system_dept_leader)，另一个是用户表 (system_user)，并演示如何通过左连接来获取部门领导的详细信息，包括用户的昵称和工号。

数据表结构

假设我们有以下两个数据表：

部门领导表 (`system_dept_leader`)

字段名	类型	描述
id	Long	主键
dept_id	Long	部门ID
user_id	Long	用户ID
is_primary	Integer	是否主要

用户表 (`system_user`)

字段名	类型	描述
id	Long	主键
nickname	String	昵称
worker_code	String	工号

实现步骤

我们将通过以下步骤实现左连接查询：

定义查询结果类
编写 SQL 提供者
在 Mapper 接口中定义查询方法

1. 定义查询结果类

首先，我们需要定义一个查询结果类，用于存储查询结果。这里我们定义一个 DeptLeaderDORespVO 类，继承自基础类 DeptLeaderDOBaseVO，并包含用户的昵称和工号字段。

@Data
@EqualsAndHashCode(callSuper = true)
@ToString(callSuper = true)
public class DeptLeaderDORespVO extends DeptLeaderDOBaseVO {

    private Long id;

    @NotNull(message = "Department不能为空")
    private Long deptId;

    @NotNull(message = "User不能为空")
    private Long userId;

    @NotNull(message = "Is Primary不能为空")
    private Integer isPrimary;

    private String nickname;
    private String workerCode;
}

2. 编写 SQL 提供者

接下来，我们编写一个 SQL 提供者类，用于动态生成 SQL 查询。这里使用 SelectProvider 注解来指定自定义 SQL。

public class DeptLeaderSqlProvider {

    public String selectDeptLeaderWithUserDetails(Map<String, Object> params) {
        Long deptId = (Long) params.get("deptId");
        Long userId = (Long) params.get("userId");
        Integer isPrimary = (Integer) params.get("isPrimary");

        StringBuilder sql = new StringBuilder();
        sql.append("SELECT dl.*, su.nickname, su.worker_code AS workerCode ");
        sql.append("FROM system_dept_leader dl ");
        sql.append("LEFT JOIN system_user su ON dl.user_id = su.id ");
        sql.append("WHERE 1=1 ");
        if (deptId != null) {
            sql.append("AND dl.dept_id = #{deptId} ");
        }
        if (userId != null) {
            sql.append("AND dl.user_id = #{userId} ");
        }
        if (isPrimary != null) {
            sql.append("AND dl.is_primary = #{isPrimary} ");
        }
        sql.append("ORDER BY dl.id DESC");
        return sql.toString();
    }
}

3. 在 Mapper 接口中定义查询方法

最后，在 Mapper 接口中定义查询方法，并使用 SelectProvider 注解指定 SQL 提供者。

@Mapper
public interface DeptLeaderMapper extends BaseMapperX<DeptLeaderDO> {

    @SelectProvider(type = DeptLeaderSqlProvider.class, method = "selectDeptLeaderWithUserDetails")
    List<DeptLeaderDORespVO> selectDeptLeaderWithUserDetails(@Param("deptId") Long deptId,
                                                             @Param("userId") Long userId,
                                                             @Param("isPrimary") Integer isPrimary);
}

4. 调用服务层方法

在服务层中调用该查询方法，并将结果返回给前端或进行进一步处理。

@Service
public class DeptLeaderService {

    @Autowired
    private DeptLeaderMapper deptLeaderMapper;

    public List<DeptLeaderDORespVO> getDeptLeaders(Long deptId, Long userId, Integer isPrimary) {
        return deptLeaderMapper.selectDeptLeaderWithUserDetails(deptId, userId, isPrimary);
    }
}