C#入坑JAVA MyBatis入门 CURD 批量联表分页查询

本文，分享 MyBatis 各种常用操作，不限于链表查询、分页查询等等。

1. 分页查询

在下文的的「3.4 selectPage」小节，我们使用 MyBatis Plus 实现了分页查询。除了这种方式，我们也可以使用 XML 实现分页查询。

这里，以查询 system_users 表为例，讲解如何使用 XML 实现分页查询。

#1.1 方案一：MyBatis XML

这个是 MyBatis 内置的使用方式，步骤如下：

分页案例 01

① 创建 AdminUserMapper.xml 文件，编写两个 SQL 查询语句：

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="cn.iocoder.yudao.module.system.dal.mysql.user.AdminUserMapper">

    <select id="selectPage01List"
            resultType="cn.iocoder.yudao.module.system.dal.dataobject.user.AdminUserDO" >
        SELECT * FROM system_users
        <where>
            <if test="reqVO.username != null and reqVO.username !=''">
                AND username LIKE CONCAT('%',#{reqVO.username},'%')
            </if>
            <if test="reqVO.createTime != null">
                AND create_time BETWEEN #{reqVO.createTime[0]}, #{reqVO.createTime[1]},
            </if>
            <if test="reqVO.status != null">
                AND status = #{reqVO.status}
            </if>
        </where>
        ORDER BY id DESC
        LIMIT #{reqVO.pageNo}, #{reqVO.pageSize}
    </select>

    <select id="selectPage01Count" resultType="Long" >
        SELECT COUNT(1) FROM system_users
        <where>
            <if test="reqVO.username != null and reqVO.username !=''">
                AND username LIKE CONCAT('%',#{reqVO.username},'%')
            </if>
            <if test="reqVO.createTime != null">
                AND create_time BETWEEN #{reqVO.createTime[0]}, #{reqVO.createTime[1]},
            </if>
            <if test="reqVO.status != null">
                AND status = #{reqVO.status}
            </if>
        </where>
    </select>

</mapper>

② 在 AdminUserMapper 创建这两 SQL 对应的方法：

@Mapper
public interface AdminUserMapper extends BaseMapperX<AdminUserDO> {

    /**
     * 查询分页的列表
     */
    List<AdminUserDO> selectPage01List(@Param("reqVO") UserPageReqVO reqVO);

    /**
     * 查询分页的条数
     */
    Long selectPage01Count(@Param("reqVO") UserPageReqVO reqVO);

}

其中 UserPageReqVO.java (opens new window)是分页查询的请求 VO。

③ 在 AdminUserServiceImplService 层，调用这两个方法，实现分页查询：

@Service
@Slf4j
public class AdminUserServiceImpl implements AdminUserService {

    @Override
    public PageResult<AdminUserDO> getUserPage(UserPageReqVO reqVO) {
        return new PageResult<>(
                userMapper.selectPage01List(reqVO),
                userMapper.selectPage01Count(reqVO)
        );
    }
}

④ 简单调用下，可以在 IDEA 控制台看到 2 条 SQL：

分页案例 01 的效果

#1.2 方案二：MyBatis Plus XML

这个是 MyBatis Plus 拓展的使用方式，可以简化只需要写一条 SQL，步骤如下：

分页案例 02

① 创建 AdminUserMapper.xml 文件，只编写一个 SQL 查询语句：

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="cn.iocoder.yudao.module.system.dal.mysql.user.AdminUserMapper">

    <select id="selectPage02"
            resultType="cn.iocoder.yudao.module.system.dal.dataobject.user.AdminUserDO" >
        SELECT * FROM system_users
        <where>
            <if test="reqVO.username != null and reqVO.username !=''">
                AND username LIKE CONCAT('%',#{reqVO.username},'%')
            </if>
            <if test="reqVO.createTime != null">
                AND create_time BETWEEN #{reqVO.createTime[0]}, #{reqVO.createTime[1]},
            </if>
            <if test="reqVO.status != null">
                AND status = #{reqVO.status}
            </if>
        </where>
        ORDER BY id DESC
    </select>

</mapper>

注意，不需要写 LIMIT 分页语句噢。

② 在 AdminUserMapper 创建这一 SQL 对应的方法：

@Mapper
public interface AdminUserMapper extends BaseMapperX<AdminUserDO> {

    IPage<AdminUserDO> selectPage02(IPage<AdminUserDO> page, @Param("reqVO") UserPageReqVO reqVO);

}

第一个参数、返回结果必须都是 IPage 类型，第二个参数可以放查询条件。

③ 在 AdminUserServiceImplService 层，调用这一个方法，实现分页查询：

@Service
@Slf4j
public class AdminUserServiceImpl implements AdminUserService {

    @Override
    public PageResult<AdminUserDO> getUserPage(UserPageReqVO reqVO) {
        // 必须使用 MyBatis Plus 的分页对象
        IPage<AdminUserDO> page = new Page<>(reqVO.getPageNo(), reqVO.getPageSize());
        userMapper.selectPage02(page, reqVO);
        return new PageResult<>(page.getRecords(), page.getTotal());
    }
}

因为项目使用 PageParam 和 PageResult 作为分页对象，所以需要和 IPage 做下转换。

④ 简单调用下，可以在 IDEA 控制台看到 2 条 SQL：

分页案例 02 的效果

本质上，MyBatis Plus 是基于我们在 XML 编写的这条 SQL，计算出获得分页数量的 SQL。

一般情况下，建议采用方案二：MyBatis Plus XML，因为它开发效率更高，并且在分页数量为 0 时，就不多余查询分页的列表，一定程度上可以提升性能。

#2. 联表查询

对于需要链表查询的场景，建议也是写 MyBatis XML，使用方法比较简单，可以看下《MyBatis学习总结（三）—— 多表关联查询与动态 SQL》 (opens new window)文章。

除了 XML 这种方式外，项目也集成了 MyBatis Plus Join (opens new window)框架，通过 Java 代码实现联表查询。

这里，以查询 system_users 和 system_dept 联表，查询部门名为音娱乐行、用户状态为开启的用户列表。

#2.1 案例一：字段平铺

① 创建 AdminUserDetailDO 类，继承 AdminUserDO 类，并添加 deptName 平铺。代码如下：

@Data
public class AdminUserDetailDO extends AdminUserDO {

    private String deptName;

}

② 在 AdminUserMapper 创建 selectListByStatusAndDeptName 方法，代码如下：

@Mapper
public interface AdminUserMapper extends BaseMapperX<AdminUserDO> {

    default List<AdminUserDetailDO> selectList2ByStatusAndDeptName(Integer status, String deptName) {
        return selectJoinList(AdminUserDetailDO.class, new MPJLambdaWrapper<AdminUserDO>() // 查询 List
                .selectAll(AdminUserDO.class) // 查询 system_users 表的 all 所有字段
                .selectAs(DeptDO::getName, AdminUserDetailDO::getDeptName) // 查询 system_dept 表的 name 字段，使用 deptName 字段“部分”返回
                .eq(AdminUserDO::getStatus, status) // WHERE system_users.status = ? 【部门名为 `芋道源码`】
                .leftJoin(DeptDO.class, DeptDO::getId, AdminUserDO::getDeptId) // 联表 WHERE system_users.dept_id = system_dept.id 
                .eq(DeptDO::getName, deptName) // WHERE system_dept.name = ? 【用户状态为开启】
        );
    }
    
}

#2.2 案例二：字段内嵌

① 创建 AdminUserDetailDO 类，继承 AdminUserDO 类，并添加 dept 部门。代码如下：

@Data
public class AdminUserDetail2DO extends AdminUserDO {

    private DeptDO dept;

}

② 在 AdminUserMapper 创建 selectListByStatusAndDeptName 方法，代码如下：

@Mapper
public interface AdminUserMapper extends BaseMapperX<AdminUserDO> {

    default List<AdminUserDetail2DO> selectListByStatusAndDeptName(Integer status, String deptName) {
        return selectJoinList(AdminUserDetail2DO.class, new MPJLambdaWrapper<AdminUserDO>()
                .selectAll(AdminUserDO.class)
                .selectAssociation(DeptDO.class, AdminUserDetail2DO::getDept) // 重点差异点：查询 system_dept 表的 name 字段，使用 dept 字段“整个”返回
                .eq(AdminUserDO::getStatus, status)
                .leftJoin(DeptDO.class, DeptDO::getId, AdminUserDO::getDeptId)
                .eq(DeptDO::getName, deptName)
        );
    }

}

#2.3 总结

MyBatis Plus Join 相比 MyBatis XML 来说，一开始肯定是需要多看看它的文档 (opens new window)。

但是熟悉后，我还是更喜欢使用 MyBatis Plus Join 哈~

《MyBatis 数据库》MyBatis 是最容易读懂的 Java 框架之一

1. 实体类

BaseDO (opens new window) 是所有数据库实体的父类，代码如下：

@Data
public abstract class BaseDO implements Serializable {

    /**
     * 创建时间
     */
    @TableField(fill = FieldFill.INSERT)
    private Date createTime;
    /**
     * 最后更新时间
     */
    @TableField(fill = FieldFill.INSERT_UPDATE)
    private Date updateTime;
    /**
     * 创建者，目前使用 AdminUserDO / MemberUserDO 的 id 编号
     *
     * 使用 String 类型的原因是，未来可能会存在非数值的情况，留好拓展性。
     */
    @TableField(fill = FieldFill.INSERT)
    private String creator;
    /**
     * 更新者，目前使用 AdminUserDO / MemberUserDO 的 id 编号
     *
     * 使用 String 类型的原因是，未来可能会存在非数值的情况，留好拓展性。
     */
    @TableField(fill = FieldFill.INSERT_UPDATE)
    private String updater;
    /**
     * 是否删除
     */
    @TableLogic
    private Boolean deleted;

}

createTime + creator 字段，创建人相关信息。
updater + updateTime 字段，创建人相关信息。
deleted 字段，逻辑删除。

对应的 SQL 字段如下：

`creator` varchar(64) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci DEFAULT '' COMMENT '创建者',
`create_time` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
`updater` varchar(64) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci DEFAULT '' COMMENT '更新者',
`update_time` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '更新时间',
`deleted` bit(1) NOT NULL DEFAULT b'0' COMMENT '是否删除',

#1.1 主键编号

id 主键编号，推荐使用 Long 型自增，原因是：

自增，保证数据库是按顺序写入，性能更加优秀。
Long 型，避免未来业务增长，超过 Int 范围。

对应的 SQL 字段如下：

`id` bigint NOT NULL AUTO_INCREMENT COMMENT '编号',

项目的 id 默认采用数据库自增的策略，如果希望使用 Snowflake 雪花算法，可以修改 application.yaml 配置文件，将配置项 mybatis-plus.global-config.db-config.id-type 修改为 ASSIGN_ID。如下图所示：

配置 Snowflake 雪花算法

#1.2 逻辑删除

所有表通过 deleted 字段来实现逻辑删除，值为 0 表示未删除，值为 1 表示已删除，可见 application.yaml 配置文件的 logic-delete-value 和 logic-not-delete-value 配置项。如下图所示：

逻辑删除的配置

① 所有 SELECT 查询，都会自动拼接 WHERE deleted = 0 查询条件，过滤已经删除的记录。如果被删除的记录，只能通过在 XML 或者 @SELECT 来手写 SQL 语句。例如说：

不自动过滤逻辑删除

② 建立唯一索引时，需要额外增加 delete_time 字段，添加到唯一索引字段中，避免唯一索引冲突。例如说，system_users 使用 username 作为唯一索引：

未添加前：先逻辑删除了一条 username = yudao 的记录，然后又插入了一条 username = yudao 的记录时，会报索引冲突的异常。
已添加后：先逻辑删除了一条 username = yudao 的记录并更新 delete_time 为当前时间，然后又插入一条 username = yudao 并且 delete_time 为 0 的记录，不会导致唯一索引冲突。

#1.3 自动填充

DefaultDBFieldHandler (opens new window) 基于 MyBatis 自动填充机制，实现 BaseDO 通用字段的自动设置。代码如下如：

DefaultDBFieldHandler 自动填充

#1.4 “复杂”字段类型

MyBatis Plus 提供 TypeHandler 字段类型处理器，用于 JavaType 与 JdbcType 之间的转换。示例如下：

字段处理器的示例

常用的字段类型处理器有：

JacksonTypeHandler (opens new window)：通用的 Jackson 实现 JSON 字段类型处理器。
JsonLongSetTypeHandler (opens new window)：针对 Set<Long> 的 Jackson 实现 JSON 字段类型处理器。

另外，如果你后续要拓展自定义的 TypeHandler 实现，可以添加到 cn.iocoder.yudao.framework.mybatis.core.type (opens new window)包下。

注意事项：

使用 TypeHandler 时，需要设置实体的 @TableName 注解的 @autoResultMap = true。

#2. 编码规范

① 数据库实体类放在 dal.dataobject 包下，以 DO 结尾；数据库访问类放在 dal.mysql 包下，以 Mapper 结尾。如下图所示：

包规范

② 数据库实体类的注释要完整，特别是哪些字段是关联（外键）、枚举、冗余等等。例如说：

包规范

③ 禁止在 Controller、Service 中，直接进行 MyBatis Plus 操作。原因是：大量 MyBatis 操作散落在 Service 中，会导致 Service 的代码越来乱，无法聚焦业务逻辑。

	示例
错误
正确

并且，通过只允许将 MyBatis Plus 操作编写 Mapper 层，更好的实现 SELECT 查询的复用，而不是 Service 会存在很多相同且重复的 SELECT 查询的逻辑。

④ Mapper 的 SELECT 查询方法的命名，采用 Spring Data 的 "Query methods" (opens new window)策略，方法名使用 selectBy查询条件 规则。例如说：

SELECT 命名示例

⑤ 优先使用 LambdaQueryWrapper 条件构造器，使用方法获得字段名，避免手写 "字段" 可能写错的情况。例如说：

LambdaQueryWrapper 条件构造器

⑥ 简单的单表查询，优先在 Mapper 中通过 default 方法实现。例如说：

单表查询

#3. CRUD 接口

BaseMapperX (opens new window)接口，继承 MyBatis Plus 的 BaseMapper 接口，提供更强的 CRUD 操作能力。

#3.1 selectOne

#selectOne(...) (opens new window)方法，使用指定条件，查询单条记录。示例如下：

selectOne 示例

#3.2 selectCount

#selectCount(...) (opens new window)方法，使用指定条件，查询记录的数量。示例如下：

selectCount 示例

#3.3 selectList

#selectList(...) (opens new window)方法，使用指定条件，查询多条记录。示例如下：

selectList 示例

#3.4 selectPage

针对 MyBatis Plus 分页查询的二次分装，在 BaseMapperX (opens new window)中实现，目的是使用项目自己的分页封装：

【入参】查询前，将项目的分页参数 PageParam (opens new window)，转换成 MyBatis Plus 的 IPage 对象。
【出参】查询后，将 MyBatis Plus 的分页结果 IPage，转换成项目的分页结果 PageResult (opens new window)。代码如下图：

BaseMapperX 实现

具体的使用示例，可见 TenantMapper (opens new window)类中，定义 selectPage 查询方法。代码如下：

@Mapper
public interface TenantMapper extends BaseMapperX<TenantDO> {

    default PageResult<TenantDO> selectPage(TenantPageReqVO reqVO) {
        return selectPage(reqVO, new LambdaQueryWrapperX<TenantDO>()
                .likeIfPresent(TenantDO::getName, reqVO.getName()) // 如果 name 不为空，则进行 like 查询
                .likeIfPresent(TenantDO::getContactName, reqVO.getContactName())
                .likeIfPresent(TenantDO::getContactMobile, reqVO.getContactMobile())
                .eqIfPresent(TenantDO::getStatus, reqVO.getStatus()) // 如果 status 不为空，则进行 = 查询
                .betweenIfPresent(TenantDO::getCreateTime, reqVO.getBeginCreateTime(), reqVO.getEndCreateTime()) // 如果 create 不为空，则进行 between 查询
                .orderByDesc(TenantDO::getId)); // 按照 id 倒序
    }
    
}

完整实战，可见《开发指南 —— 分页实现》文档。

#3.5 insertBatch

#insertBatch(...) (opens new window)方法，遍历数组，逐条插入数据库中，适合少量数据插入，或者对性能要求不高的场景。示例如下：

insertBatch 示例

为什么不使用 insertBatchSomeColumn 批量插入？

只支持 MySQL 数据库。其它 Oracle 等数据库使用会报错，可见 InsertBatchSomeColumn (opens new window)说明。
未支持多租户。插入数据库时，多租户字段不会进行自动赋值。

#4. 批量插入

绝大多数场景下，推荐使用 MyBatis Plus 提供的 IService 的 #saveBatch() (opens new window)方法。示例 PermissionServiceImpl (opens new window)如下：

saveBatch 示例

#5. 条件构造器

继承 MyBatis Plus 的条件构造器，拓展了 LambdaQueryWrapperX (opens new window)和 QueryWrapperX (opens new window)类，主要是增加 xxxIfPresent 方法，用于判断值不存在的时候，不要拼接到条件中。例如说：

xxxIfPresent 方法

具体的使用示例如下：

LambdaQueryWrapperX 使用示例

#6. Mapper XML

默认配置下，MyBatis Mapper XML 需要写在各 yudao-module-xxx-biz 模块的 resources/mapper 目录下。示例 TestDemoMapper.xml (opens new window)如下：

TestDemoMapper.xml 示例

尽量避免数据库的连表（多表）查询，而是采用多次查询，Java 内存拼接的方式替代。例如说：

UserController 示例

#7. 字段加密

EncryptTypeHandler (opens new window)，基于 Hutool AES (opens new window)实现字段的解密与解密。

例如说，数据源配置 (opens new window)的 password 密码需要实现加密存储，则只需要在该字段上添加 EncryptTypeHandler 处理器。示例代码如下：

@TableName(value = "infra_data_source_config", autoResultMap = true) // ① 添加 autoResultMap = true
public class DataSourceConfigDO extends BaseDO {

    // ... 省略其它字段
    /**
     * 密码
     */
    @TableField(typeHandler = EncryptTypeHandler.class) // ② 添加 EncryptTypeHandler 处理器
    private String password;

}

另外，在 application.yaml 配置文件中，可使用 mybatis-plus.encryptor.password 设置加密密钥。

字段加密后，只允许使用精准匹配，无法使用模糊匹配。示例代码如下：

@Test // 测试使用 password 查询，可以查询到数据
public void testSelectPassword() {
    // mock 数据
    DataSourceConfigDO dbDataSourceConfig = randomPojo(DataSourceConfigDO.class);
    dataSourceConfigMapper.insert(dbDataSourceConfig);// @Sql: 先插入出一条存在的数据

    // 调用
    DataSourceConfigDO result = dataSourceConfigMapper.selectOne(DataSourceConfigDO::getPassword,
            EncryptTypeHandler.encrypt(dbDataSourceConfig.getPassword())); // 重点：需要使用 EncryptTypeHandler 去加密查询字段！！！
}