Mybatis |
您所在的位置：网站首页 › mybatis扩展插件 › Mybatis |
Mybatis
| Mybatis-Plus插件扩展一、简介1.1 MybatisPlusInterceptor1.2 InnerInterceptor二、插件扩展2.1 分页插件2.2 SQL分析打印2.2.1 引入依赖：2.2.2 application.yml配置2.2.3 spy.properties配置2.3 防止全表更新与删除2.4 乐观锁OptimisticLockerInnerInterceptor2.4.1 配置插件2.4.2 测试一、简介1.1 MybatisPlusInterceptor MybatisPlusInterceptor是核心插件，目前代理了Executor#query 和 Executor#update 和 StatementHandler#prepare 方法 属性 代码语言：javascript复制private List interceptors = new ArrayList();1.2 InnerInterceptor目前提供您的插件都将基于此接口来实现功能。 目前已有的功能： 自动分页: PaginationInnerInterceptor多租户: TenantLineInnerInterceptor动态表名: DynamicTableNameInnerInterceptor乐观锁: OptimisticLockerInnerInterceptorsql性能规范: IllegalSQLInnerInterceptor防止全表更新与删除: BlockAttackInnerInterceptor注意: 使用多个功能需要注意顺序关系,建议使用如下顺序 多租户,动态表名分页,乐观锁sql性能规范,防止全表更新与删除总结: 对sql进行单次改造的优先放入,不对sql进行改造的最后放入 二、插件扩展2.1 分页插件配置文件中： 这里本应该多加一个@MapperScan注解，但是我将该注解写在SpringBoot的启动类上面了，所以你看情况要不要加。 代码语言：javascript复制package com.baomidou.mybatisplus.config; import com.baomidou.mybatisplus.annotation.DbType; import com.baomidou.mybatisplus.extension.plugins.MybatisPlusInterceptor; import com.baomidou.mybatisplus.extension.plugins.inner.BlockAttackInnerInterceptor; import com.baomidou.mybatisplus.extension.plugins.inner.OptimisticLockerInnerInterceptor; import com.baomidou.mybatisplus.extension.plugins.inner.PaginationInnerInterceptor; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; @Configuration public class MybatisPlusConfig { //注册分页插件 @Bean public MybatisPlusInterceptor mybatisPlusInterceptor(){ MybatisPlusInterceptor interceptor=new MybatisPlusInterceptor(); interceptor.addInnerInterceptor(new PaginationInnerInterceptor(DbType.MYSQL)); return interceptor; } }实体类Employee.java 代码语言：javascript复制package com.baomidou.mybatisplus.beans; import com.baomidou.mybatisplus.annotation.TableName; import com.baomidou.mybatisplus.annotation.IdType; import com.baomidou.mybatisplus.annotation.Version; import com.baomidou.mybatisplus.extension.activerecord.Model; import com.baomidou.mybatisplus.annotation.TableId; import lombok.Data; import java.io.Serializable; /** ** * * * @author xiongtete * @since 2021-06-22 */ @Data @TableName("tbl_employee") public class Employee extends Model { private static final long serialVersionUID = 1L; @TableId(value = "id", type = IdType.AUTO) private Integer id; private String lastName; private String email; private String gender; private Integer age; @Version private Integer version; }数据库初始数据  在这里插入图片描述测试分页插件： 代码语言：javascript复制 @Test public void testPage(){ Page employeePage = employeeMapper.selectPage(new Page(1, 2), null); List records = employeePage.getRecords(); records.forEach(System.out::println); System.out.println("========分页相关的信息======="); System.out.println("总条数:"+employeePage.getTotal()); System.out.println("当前页码:"+employeePage.getCurrent()); System.out.println("总页码:"+employeePage.getPages()); System.out.println("每页显示的条数:"+employeePage.getSize()); System.out.println("是否有上一页:"+employeePage.hasPrevious()); System.out.println("是否有下一页:"+employeePage.hasNext()); } 在这里插入图片描述上图的红色部分不用管，那个是我加入了性能分析插件输出的信息 2.2 SQL分析打印该功能依赖 p6spy 组件，完美的输出打印 SQL 及执行时长 3.1.0 以上版本 2.2.1 引入依赖：代码语言：javascript复制 p6spy p6spy 3.9.1 2.2.2 application.yml配置代码语言：javascript复制# DataSource Config spring: datasource: url: jdbc:p6spy:mysql://localhost:3306/mp?&useSSL=false&serverTimezone=UTC&allowPublicKeyRetrieval=true username: root password: 123456 driver-class-name: com.p6spy.engine.spy.P6SpyDriver type: com.alibaba.druid.pool.DruidDataSource # mybatis-plus配置控制台打印sql语句: mybatis-plus: configuration: log-impl: org.apache.ibatis.logging.stdout.StdOutImpl # driver-class-name 为 p6spy 提供的驱动类 # url 前缀为 jdbc:p6spy 跟着冒号为对应数据库连接地址 # 打印出sql为null,在excludecategories增加commit # 批量操作不打印sql,去除excludecategories中的batch # 批量操作打印重复的问题请使用MybatisPlusLogFactory (3.2.1新增） # 该插件有性能损耗，不建议生产环境使用。2.2.3 spy.properties配置代码语言：javascript复制#3.2.1以上使用 modulelist=com.baomidou.mybatisplus.extension.p6spy.MybatisPlusLogFactory,com.p6spy.engine.outage.P6OutageFactory #3.2.1以下使用或者不配置 #modulelist=com.p6spy.engine.logging.P6LogFactory,com.p6spy.engine.outage.P6OutageFactory # 自定义日志打印 logMessageFormat=com.baomidou.mybatisplus.extension.p6spy.P6SpyLogger #日志输出到控制台 appender=com.baomidou.mybatisplus.extension.p6spy.StdoutLogger # 使用日志系统记录 sql #appender=com.p6spy.engine.spy.appender.Slf4JLogger # 设置 p6spy driver 代理 deregisterdrivers=true # 取消JDBC URL前缀 useprefix=true # 配置记录 Log 例外,可去掉的结果集有error,info,batch,debug,statement,commit,rollback,result,resultset. excludecategories=info,debug,result,commit,resultset # 日期格式 dateformat=yyyy-MM-dd HH:mm:ss # 实际驱动可多个 #driverlist=org.h2.Driver # 是否开启慢SQL记录 outagedetection=true # 慢SQL记录标准 2 秒 outagedetectioninterval=2然后测试 代码语言：javascript复制 @Test public void test1(){ Employee employee=new Employee(); employee.setLastName("王老师"); employee.setEmail("[email protected]"); employee.setGender("1"); employee.setAge(22); int result = employeeMapper.insert(employee); System.out.println(result); } 在这里插入图片描述2.3 防止全表更新与删除配置文件： 代码语言：javascript复制 //注册防止全表更新与删除插件 @Bean public MybatisPlusInterceptor mybatisPlusInterceptor1(){ BlockAttackInnerInterceptor blockAttackInnerInterceptor=new BlockAttackInnerInterceptor(); MybatisPlusInterceptor interceptor=new MybatisPlusInterceptor(); interceptor.addInnerInterceptor(blockAttackInnerInterceptor); return interceptor; }然后我们测试个删除全表的方法 代码语言：javascript复制 /** * 测试sql执行分析插件 */ @Test public void testSQLExplain(){ Integer delete = employeeMapper.delete(null);//全表删除 } 在这里插入图片描述由上图可看出，全表删除直接抛异常了，这种插件建议只在开发环境中使用，生产环境不要用了。 2.4 乐观锁OptimisticLockerInnerInterceptor当要更新一条记录的时候，希望这条记录没有被别人更新 乐观锁实现方式： 取出记录时，获取当前version更新时，带上这个version执行更新时， set version = newVersion where version = oldVersion如果version不对，就更新失败2.4.1 配置插件SpringBoot注解方式： 代码语言：javascript复制@Bean public MybatisPlusInterceptor mybatisPlusInterceptor() { MybatisPlusInterceptor interceptor = new MybatisPlusInterceptor(); interceptor.addInnerInterceptor(new OptimisticLockerInnerInterceptor()); return interceptor; }在实体类的字段上加上@Version注解 代码语言：javascript复制@Version private Integer version; 在这里插入图片描述说明: 支持的数据类型只有:int,Integer,long,Long,Date,Timestamp,LocalDateTime整数类型下 newVersion = oldVersion + 1newVersion 会回写到 entity 中仅支持 updateById(id) 与 update(entity, wrapper) 方法在 update(entity, wrapper) 方法下, wrapper 不能复用!!!2.4.2 测试 在这里插入图片描述假设我们更新id为19的这条数据，现在的version为3，我们先将age改为33 代码语言：javascript复制@Test public void testOptimisticLocker(){ //更新操作 Employee employee=new Employee(); employee.setId(19); employee.setLastName("tom"); employee.setEmail("[email protected]"); employee.setGender("1"); employee.setAge(33); employee.setVersion(3); int i = employeeMapper.updateById(employee); } 在这里插入图片描述 在这里插入图片描述执行成功,version+1变为4 假如我们此时将代码中的version改为3再测试(也就是说两个人都想改同一条数据，但是其中一个人先该，另一个人后改，后改的这个人的version已经和数据库中的不一致了) 代码语言：javascript复制 @Test public void testOptimisticLocker(){ //更新操作 Employee employee=new Employee(); employee.setId(19); employee.setLastName("tom"); employee.setEmail("[email protected]"); employee.setGender("1"); employee.setAge(33); employee.setVersion(3); int i = employeeMapper.updateById(employee); } 在这里插入图片描述 在这里插入图片描述通过控制台输出可以确定更新并没有执行成功，因为返回的受影响行数是0. |
【本文地址】
公司简介
联系我们
今日新闻 |
点击排行 |
|
推荐新闻 |
图片新闻 |
|
专题文章 |