image.png数据库 MyBatis

ykkj-spring-boot-starter-mybatis技术组件,基于 MyBatis Plus 实现数据库的操作。

1. 实体类

framework/mybatis/core/dataobject/BaseDO.java是所有数据库实体的父类,代码如下:

  1. @Data
  2. public abstract class BaseDO implements Serializable {
  3. /**
  4. * 创建时间
  5. */
  6. @TableField(fill = FieldFill.INSERT)
  7. private Date createTime;
  8. /**
  9. * 最后更新时间
  10. */
  11. @TableField(fill = FieldFill.INSERT_UPDATE)
  12. private Date updateTime;
  13. /**
  14. * 创建者,目前使用 AdminUserDO / MemberUserDO 的 id 编号
  15. *
  16. * 使用 String 类型的原因是,未来可能会存在非数值的情况,留好拓展性。
  17. */
  18. @TableField(fill = FieldFill.INSERT)
  19. private String creator;
  20. /**
  21. * 更新者,目前使用 AdminUserDO / MemberUserDO 的 id 编号
  22. *
  23. * 使用 String 类型的原因是,未来可能会存在非数值的情况,留好拓展性。
  24. */
  25. @TableField(fill = FieldFill.INSERT_UPDATE)
  26. private String updater;
  27. /**
  28. * 是否删除
  29. */
  30. @TableLogic
  31. private Boolean deleted;
  32. }
  • createTime + creator 字段,创建人相关信息。
  • updater + updateTime 字段,创建人相关信息。
  • deleted 字段,逻辑删除。

对应的 SQL 字段如下:

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

1.1 主键编号

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

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

对应的 SQL 字段如下:
id bigint NOT NULL AUTO_INCREMENT COMMENT ‘编号’,

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

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

1.2 逻辑删除

所有表通过 deleted 字段来实现逻辑删除,值为 0 表示未删除,值为 1 表示已删除,可见 application.yaml 配置文件的 logic-delete-value 和 logic-not-delete-value 配置项。如下图所示:
image.png
① 所有 SELECT 查询,都会自动拼接 WHERE deleted = 0 查询条件,过滤已经删除的记录。如果被删除的记录,只能通过在 XML 或者 @SELECT 来手写 SQL 语句。例如说:
image.png
② 建立唯一索引时,需要额外增加 delete_time 字段,添加到唯一索引字段中,避免唯一索引冲突。例如说,system_users 使用 username 作为唯一索引:

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

    1.3 自动填充

    framework/mybatis/core/handler/DefaultDBFieldHandler.java基于 MyBatis 自动填充机制,实现 BaseDO 通用字段的自动设置。代码如下如:
    image.png

    1.4 “复杂”字段类型

    MyBatis Plus 提供 TypeHandler 字段类型处理器,用于 JavaType 与 JdbcType 之间的转换。示例如下:
    image.png
    常用的字段类型处理器有:

  • JacksonTypeHandler:通用的 Jackson 实现 JSON 字段类型处理器。

  • JsonLongSetTypeHandler:针对 Set 的 Jackson 实现 JSON 字段类型处理器。

另外,如果你后续要拓展自定义的 TypeHandler 实现,可以添加到 产com.ykkj.cdp.framework.mybatis.core.type包下。
注意事项:
使用 TypeHandler 时,需要设置实体的 @TableName 注解的 @autoResultMap = true。

2. 编码规范

① 数据库实体类放在 dal.dataobject 包下,以 DO 结尾;数据库访问类放在 dal.mysql 包下,以 Mapper 结尾。如下图所示:
image.png


② 数据库实体类的注释要完整,特别是哪些字段是关联(外键)、枚举、冗余等等。例如说:
image.png
③ 禁止在 Controller、Service 中,直接进行 MyBatis Plus 操作。原因是:大量 MyBatis 操作散落在 Service 中,会导致 Service 的代码越来乱,无法聚焦业务逻辑。

示例
错误 image.png
正确 image.png

并且,通过只允许将 MyBatis Plus 操作编写 Mapper 层,更好的实现 SELECT 查询的复用,而不是 Service 会存在很多相同且重复的 SELECT 查询的逻辑。
④ Mapper 的 SELECT 查询方法的命名,采用 Spring Data 的 “Query methods”策略,方法名使用 selectBy查询条件 规则。例如说:
image.png
⑤ 优先使用 LambdaQueryWrapper 条件构造器,使用方法获得字段名,避免手写 “字段” 可能写错的情况。例如说:
image.png
⑥ 简单的单表查询,优先在 Mapper 中通过 default 方法实现。例如说:
image.png

3. CRUD 接口

/framework/mybatis/core/mapper/BaseMapperX.java接口,继承 MyBatis Plus 的 BaseMapper 接口,提供更强的 CRUD 操作能力。

3.1 selectOne

selectOne(…)方法,使用指定条件,查询单条记录。示例如下:
image.png

3.2 selectCount

selectCount(…)方法,使用指定条件,查询记录的数量。示例如下:
image.png

3.3 selectList

selectList(…)方法,使用指定条件,查询多条记录。示例如下:
image.png

3.4 selectPage

针对 MyBatis Plus 分页查询的二次分装,在 BaseMapperX中实现,目的是使用项目自己的分页封装:

  • 【入参】查询前,将项目的分页参数 framework/common/pojo/PageParam.java,转换成 MyBatis Plus 的 IPage 对象。
  • 【出参】查询后,将 MyBatis Plus 的分页结果 IPage,转换成项目的分页结果 framework/common/pojo/PageResult.java。代码如下图:

image.png
具体的使用示例,可见 module/system/dal/mysql/tenant/TenantMapper.java类中,定义 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(…)方法,遍历数组,逐条插入数据库中,适合少量数据插入,或者对性能要求不高的场景。 示例如下:
image.png
为什么不使用 insertBatchSomeColumn 批量插入?

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

    4. 批量插入

    绝大多数场景下,推荐使用 MyBatis Plus 提供的 IService 的 #saveBatch()方法。示例 module/system/service/permission/PermissionServiceImpl.java如下:
    image.png

    5. 条件构造器

    继承 MyBatis Plus 的条件构造器,拓展了 framework/mybatis/core/query/LambdaQueryWrapperX.java和 /framework/mybatis/core/query/QueryWrapperX.java类,主要是增加 xxxIfPresent 方法,用于判断值不存在的时候,不要拼接到条件中。例如说:
    image.png
    具体的使用示例如下:
    image.png

    6. Mapper XML

    默认配置下,MyBatis Mapper XML 需要写在各 ykkj-module-xxx-biz 模块的 resources/mapper 目录下。示例 ykkj-module-infra-biz/src/main/resources/mapper/test/TestDemoMapper.xml如下:
    image.png
    尽量避免数据库的连表(多表)查询,而是采用多次查询,Java 内存拼接的方式替代。例如说:
    image.png