MyBatis-Plus插件机制及通用Service新功能

1.高级(插件机制)

1.1自动填充

项目中经常会遇到一些数据，每次都使用相同的方式填充，例如记录的创建时间，更新时间等。

我们可以使用MyBatis Plus的自动填充功能，完成这些字段的赋值工作：

1.1.1 原理

实现元对象处理器接口：com.baomidou.mybatisplus.core.handlers.MetaObjectHandler，确定填充具体操作
注解填充字段：@TableField(fill = ...) 确定字段填充的时机
FieldFill.INSERT：插入填充字段
FieldFill.UPDATE：更新填充字段
FieldFill.INSERT_UPDATE：插入和更新填充字段

1.1.2 基本操作

步骤一：修改表添加字段

alter table tmp_customer add column create_time date;
alter table tmp_customer add column update_time date;

步骤二：修改JavaBean

package com.czxy.mp.domain;
 
import com.baomidou.mybatisplus.annotation.*;
import lombok.Data;
 
import java.util.Date;
 
/**
 * Created by liangtong.
 */
@Data
@TableName("tmp_customer")
public class Customer {
    @TableId(type = IdType.AUTO)
    private Integer cid;
    private String cname;
    private String password;
    private String telephone;
    private String money;
 
    @TableField(value="create_time",fill = FieldFill.INSERT)
    private Date createTime;
 
    @TableField(value="update_time",fill = FieldFill.UPDATE)
    private Date updateTime;
 
}

步骤三：编写处理类

MyBatis-Plus插件机制及通用Service新功能

package com.czxy.mp.handler;
 
import com.baomidou.mybatisplus.core.handlers.MetaObjectHandler;
import org.apache.ibatis.reflection.MetaObject;
import org.springframework.stereotype.Component;
 
import java.util.Date;
 
 
@Component
public class MyMetaObjectHandler implements MetaObjectHandler {
    /**
     * 插入填充
     * @param metaObject
     */
    @Override
    public void insertFill(MetaObject metaObject) {
        this.setFieldValByName("createTime", new Date(), metaObject);
    }
 
    /**
     * 更新填充
     * @param metaObject
     */
    @Override
    public void updateFill(MetaObject metaObject) {
        this.setFieldValByName("updateTime", new Date(), metaObject);
    }
}

步骤四：测试

 @Test
    public void testInsert() {
        Customer customer = new Customer();
        customer.setCname("测试888");
 
        customerMapper.insert(customer);
    }
 
    @Test
    public void testUpdate() {
        Customer customer = new Customer();
        customer.setCid(11);
        customer.setTelephone("999");
 
        customerMapper.updateById(customer);
    }

1.2乐观锁

基于数据库
乐观锁：数据不同步不会发生。读锁。
悲观锁：数据不同步肯定发生。写锁。

1.2.1 什么是乐观锁

目的：数据必须同步。当要更新一条记录的时候，希望这条记录没有被别人更新
乐观锁实现方式：

取出记录时，获取当前version

更新时，带上这个version

执行更新时， set version = newVersion where version = oldVersion

如果version不对，就更新失败

1.2.2. 实现

步骤：

步骤1：环境准备（表version字段、JavaBean versoin属性、必须提供默认值）
步骤2：使用乐观锁版本控制 @Version
步骤3：开启乐观锁插件配置
步骤一：修改表结构，添加version字段

MyBatis-Plus插件机制及通用Service新功能

步骤二：修改JavaBean，添加version属性

MyBatis-Plus插件机制及通用Service新功能

package com.czxy.mp.domain;
 
import com.baomidou.mybatisplus.annotation.*;
import lombok.Data;
 
/**
 * Created by liangtong.
 */
@Data
@TableName("tmp_customer")
public class Customer {
    @TableId(type = IdType.AUTO)
    private Integer cid;
    private String cname;
    private String password;
    private String telephone;
    private String money;
    @Version
    @TableField(fill = FieldFill.INSERT)
    private Integer version;
}

步骤三：元对象处理器接口添加version的insert默认值 (保证version有数据)

MyBatis-Plus插件机制及通用Service新功能

package com.czxy.mp.config;
 
import com.baomidou.mybatisplus.core.handlers.MetaObjectHandler;
import org.apache.ibatis.reflection.MetaObject;
import org.springframework.stereotype.Component;
 
import java.util.Date;
 
/**
 * Created by liangtong.
 */
@Component
public class MyMetaObjectHandler implements MetaObjectHandler {
    /**
     * 插入填充
     * @param metaObject
     */
    @Override
    public void insertFill(MetaObject metaObject) {
        this.setFieldValByName("createTime", new Date(), metaObject);
        this.setFieldValByName("version", 1, metaObject);
    }
 
    /**
     * 更新填充
     * @param metaObject
     */
    @Override
    public void updateFill(MetaObject metaObject) {
        this.setFieldValByName("updateTime", new Date(), metaObject);
    }
}

步骤四：修改 MybatisPlusConfig 开启乐观锁

package com.czxy.mp.config;
 
import com.baomidou.mybatisplus.annotation.DbType;
import com.baomidou.mybatisplus.extension.plugins.MybatisPlusInterceptor;
import com.baomidou.mybatisplus.extension.plugins.OptimisticLockerInterceptor;
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;
 
/**
 * Created by liangtong.
 */
@Configuration
public class MybatisPlusConfig {
     */
    /**
     * 配置插件
     * @return
     */
    @Bean
    public MybatisPlusInterceptor mybatisPlusInterceptor(){
 
        MybatisPlusInterceptor mybatisPlusInterceptor = new MybatisPlusInterceptor();
        // 分页插件
        mybatisPlusInterceptor.addInnerInterceptor(new PaginationInnerInterceptor(DbType.MYSQL));
        // 乐观锁
        mybatisPlusInterceptor.addInnerInterceptor(new OptimisticLockerInnerInterceptor());
 
        return mybatisPlusInterceptor;
    }
}

步骤五：测试
- 先添加一条，保证version有数据
- 在更新该条

 @Test
    public void testUpdate() {
        Customer customer = new Customer();
        customer.setCid(14);
        customer.setCname("测试999");
        // 与数据库中数据一致，将更新成功，否则返回失败。
        customer.setVersion(1);
 
        int i = customerMapper.updateById(customer);
        System.out.println(i);
    }

1.2.3 注意事项

支持的数据类型只有:int,Integer,long,Long,Date,Timestamp,LocalDateTime

整数类型下 newVersion = oldVersion + 1

newVersion 会回写到 entity 中

仅支持 updateById(id) 与 update(entity, wrapper) 方法

在 update(entity, wrapper) 方法下, wrapper 不能复用!!!

数据库表的version字段，必须有默认值（SQL语句默认值、或MyBatisPlus自动填充）

在进行更新操作时，必须设置version值，否则无效。

1.3逻辑删除

1.3.1 什么是逻辑删除

逻辑删除，也称为假删除。就是在表中提供一个字段用于记录是否删除，实际该数据没有被删除。

1.3.2 实现

步骤：

步骤一：环境（表提供字段deleted、JavaBean属性 deleted、填充默认值0）

步骤二：修改JavaBean，添加注解 @TableLogic

步骤一：修改表结构添加deleted字段

MyBatis-Plus插件机制及通用Service新功能

步骤二：修改JavaBean，给deleted字段添加@TableLogic

MyBatis-Plus插件机制及通用Service新功能

package com.czxy.mp.domain;
 
import com.baomidou.mybatisplus.annotation.*;
import lombok.Data;
 
/**
 * Created by liangtong.
 */
@Data
@TableName("tmp_customer")
public class Customer {
    @TableId(type = IdType.AUTO)
    private Integer cid;
    private String cname;
    private String password;
    private String telephone;
    private String money;
    @Version
    @TableField(fill = FieldFill.INSERT)
    private Integer version;
 
    @TableLogic
    @TableField(fill = FieldFill.INSERT)
    private Integer deleted;
}

步骤三：添加数据时，设置默认“逻辑未删除值”

MyBatis-Plus插件机制及通用Service新功能

package com.czxy.mp.config;
 
import com.baomidou.mybatisplus.core.handlers.MetaObjectHandler;
import org.apache.ibatis.reflection.MetaObject;
import org.springframework.stereotype.Component;
 
import java.util.Date;
 
/**
 * Created by liangtong.
 */
@Component
public class MyMetaObjectHandler implements MetaObjectHandler {
    /**
     * 插入填充
     * @param metaObject
     */
    @Override
    public void insertFill(MetaObject metaObject) {
        this.setFieldValByName("createTime", new Date(), metaObject);
        this.setFieldValByName("version", 1, metaObject);
        this.setFieldValByName("deleted", 0, metaObject);
    }
 
    /**
     * 更新填充
     * @param metaObject
     */
    @Override
    public void updateFill(MetaObject metaObject) {
        this.setFieldValByName("updateTime", new Date(), metaObject);
    }
}

步骤四：测试

  @Test
    public void testDelete() {
        // 删除时，必须保证deleted数据为“逻辑未删除值”
        int i = customerMapper.deleteById(12);
        System.out.println(i);
    }

1.3.3 注意

如果使用逻辑删除，将delete语句，修改成了update，条件 where deleted=0
同时，查询语句自动追加一个查询条件 WHERE deleted=0。如果查询没有数据，检查deleted字段的值。

1.3.4 全局配置

如果使用了全局配置，可以不使用注解@TableLogic

mybatis-plus:
  global-config:
    db-config:
      logic-delete-field: deleted  # 局逻辑删除的实体字段名
      logic-delete-value: 1  # 逻辑已删除值(默认为 1)
      logic-not-delete-value: 0 # 逻辑未删除值(默认为 0)

1.3.5 恢复

问题：进行逻辑删除后的数据，如何恢复（recovery）？
方案1：使用sql具有，更新deleted=0即可

UPDATE `tmp_customer` SET `deleted`='0' WHERE `cid`='13';

方案2：直接使用update语句，==不能==解决问题。

 @Test
    public void testUpdate() {
        Customer customer = new Customer();
        customer.setCid(13);
        customer.setDeleted(0);
        //更新
        customerMapper.updateById(customer);
    }

方案3：修改Mapper，添加 recoveryById 方法，进行数据恢复。

@Mapper
public interface CustomerMapper extends BaseMapper<Customer> {
 
    @Update("update tmp_customer set deleted = 0 where cid = #{cid}")
    public void recoveryById(@Param("cid") Integer cid);
}

2.通用Service

2.1分析通用Service分析

MyBatis-Plus插件机制及通用Service新功能

2.2基本使用标准service：接口 + 实现

MyBatis-Plus插件机制及通用Service新功能

service接口

package com.czxy.service;
  import com.baomidou.mybatisplus.extension.service.IService;
  import com.czxy.domain.Customer;
  public interface CustomerService extends IService<Customer> {
  }

service实现类

package com.czxy.service.impl;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.czxy.domain.Customer;
import com.czxy.mapper.CustomerMapper;
import com.czxy.service.CustomerService;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
@Service
@Transactional
public class CustomerServiceImpl extends ServiceImpl<CustomerMapper,Customer> implements CustomerService {
 
}

2.3常见方法

查询所有
添加
修改
删除

package com.czxy.test;
 
import com.czxy.mp.Day62MybatisPlusApplication;
import com.czxy.mp.domain.Customer;
import com.czxy.mp.service.CustomerService;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.junit4.SpringRunner;
 
import javax.annotation.Resource;
import java.util.List;
 
 
@RunWith(SpringRunner.class)
@SpringBootTest(classes = Day62MybatisPlusApplication.class)
public class TestDay62CustomerService {
 
    @Resource
    private CustomerService customerService;
 
    @Test
    public void testSelectList() {
        List<Customer> list = customerService.list();
        list.forEach(System.out::println);
    }
 
    @Test
    public void testInsert() {
        Customer customer = new Customer();
        customer.setCname("张三");
        customer.setPassword("9999");
        // 添加
        customerService.save(customer);
    }
 
    @Test
    public void testUpdate() {
        Customer customer = new Customer();
        customer.setCid(14);
        customer.setCname("777");
        customer.setPassword("777");
 
        customerService.updateById(customer);
    }
 
    @Test
    public void testSaveOrUpdate() {
        Customer customer = new Customer();
        customer.setCid(15);
        customer.setCname("999");
        customer.setPassword("99");
 
        customerService.saveOrUpdate(customer);
    }
 
    @Test
    public void testDelete() {
        customerService.removeById(15);
    }
}

3.新功能

3.1执行SQL分析打印

该功能依赖 p6spy 组件，完美的输出打印 SQL 及执行时长

p6spy 依赖引入

<dependency>
    <groupId>p6spy</groupId>
    <artifactId>p6spy</artifactId>
    <version>3.9.1</version>
</dependency>

核心yml配置

spring:
  datasource:
  	# p6spy 提供的驱动代理类，
    driver-class-name: com.p6spy.engine.spy.P6SpyDriver
    # url 固定前缀为 jdbc:p6spy，跟着冒号为对应数据库连接地址
    url: jdbc:p6spy:mysql://127.0.0.1:3306...

MyBatis-Plus插件机制及通用Service新功能

spy.properties 配置

#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

3.2数据库安全保护

为了保护数据库配置及数据安全，在一定的程度上控制开发人员流动导致敏感信息泄露

步骤：
步骤1：使用 AES 工具类，生成秘钥。
步骤2：使用 AES工具类，根据步骤1生成的秘钥对敏感信息进行加密
步骤3：设置加密后的配置信息
步骤4：启动服务时，使用秘钥

步骤1-2：使用工具类生成秘钥以及对敏感信息进行加密

package com.czxy;
import com.baomidou.mybatisplus.core.toolkit.AES;
import org.junit.Test;
public class TestAES {
    @Test
    public void testAes() {
        String randomKey = AES.generateRandomKey();
 
        String url =  "jdbc:p6spy:mysql://127.0.0.1:3306/zx_edu_teacher?useUnicode=true&characterEncoding=utf8";
        String username = "root";
        String password = "1234";
 
        String urlAES = AES.encrypt(url, randomKey);
        String usernameAES = AES.encrypt(username, randomKey);
        String passwordAES = AES.encrypt(password, randomKey);
 
        System.out.println("--mpw.key=" + randomKey);
        System.out.println("mpw:" + urlAES);
        System.out.println("mpw:" + usernameAES);
        System.out.println("mpw:" + passwordAES);
    }
}
// Jar 启动参数（ idea 设置 Program arguments , 服务器可以设置为启动环境变量 ）
//--mpw.key=fddd2b7a67460e16
//mpw:7kSEISvq3QWfnSh6vQZc2xgE+XF/sJ0WS/sgGkYpCOTQRjO1poLi3gfmGZNOwKzfqZUec0odiwAdmxcS7lfueENGIx8OmIe//d9imrGFpnkrf8jNSHdzfNPCUi3MbmUb
//mpw:qGbCMksqA90jjiGXXRr7lA==
//mpw:xKG9GABlywqar6CGPOSJKQ==

步骤3：配置加密信息

MyBatis-Plus插件机制及通用Service新功能

步骤4：使用秘钥启动服务

MyBatis-Plus插件机制及通用Service新功能

声明：本站所有文章，如无特殊说明或标注，均为本站原创发布。任何个人或组织，在未征得本站同意时，禁止复制、盗用、采集、发布本站内容到任何网站、书籍等各类媒体平台。如若本站内容侵犯了原著者的合法权益，可联系我们进行处理。

MyBatis-Plus插件机制及通用Service新功能

目录

1.高级(插件机制)

1.1自动填充

1.1.1 原理

1.1.2 基本操作

1.2乐观锁

1.2.1 什么是乐观锁

1.2.2. 实现

1.2.3 注意事项

1.3逻辑删除

1.3.1 什么是逻辑删除

1.3.2 实现

1.3.3 注意

1.3.4 全局配置

1.3.5 恢复

2.通用Service

2.1分析通用Service分析

2.2基本使用标准service：接口 + 实现

2.3常见方法

3.新功能

3.1执行SQL分析打印

3.2数据库安全保护

评论(0)

提示：请文明发言取消回复

作者信息

本站推荐

2025自媒体实战营，Deepseek、即梦 AI、Midjourney系统教程及案例实操

视频号短视频带货新玩法，用这个方法，一天佣金4407（附详细教程）

2025电商爆款课程，内销外销等方法，从0到爆单助力商家快速起量

2025小店运营全套系列课从小店基础入门到进阶精通

主播起号0-1快速成长从基础入门到进阶线上课

Ai五阶体系课入门通识理论+实操带你快速入门

热门资源

苹果cms海螺影视模板/大橙子模板/仿B站模板/v7模板/带手机移动端+详细安装使用说明

【已测】修复版H5骰子微信竞猜游戏骰宝免公众号版修复登录ID相同完美全套源码对接免签支付

网页游戏卧龙吟一键服务端加远程工具带架设教程

邪风曲单机版 2D回合制网络游戏源码一键安装即玩服务端公益服+GM工具

完整可用版本去水印小程序源码带教程源码

仙侠H5【苍穹剑诀】一键即玩端+授权后台+外网教程

MyBatis-Plus插件机制及通用Service新功能

目录

1.高级(插件机制)

1.1自动填充

1.1.1 原理

1.1.2 基本操作

1.2乐观锁

1.2.1 什么是乐观锁

1.2.2. 实现

1.2.3 注意事项

1.3逻辑删除

1.3.1 什么是逻辑删除

1.3.2 实现

1.3.3 注意

1.3.4 全局配置

1.3.5 恢复

2.通用Service

2.1分析 通用Service分析

2.2基本使用 标准service：接口 + 实现

2.3常见方法

3.新功能

3.1执行SQL分析打印

3.2数据库安全保护

评论(0)

提示：请文明发言 取消回复

相关文章

作者信息

本站推荐

热门资源

2.1分析通用Service分析

2.2基本使用标准service：接口 + 实现

提示：请文明发言取消回复