mybatis plus 插件,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.通用服务2.1分析通用服务分析2.2基本使用标准服务：接口实现2.3常见方法3.新功能3.1执行结构化查询语言分析打印3.2数据库安全保护

1.高级(插件机制)

1.1自动填充

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

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

1.1.1 原理

实现元对象处理器接口：com。窦米宝。mybatisplus。核心。经手人。元对象处理程序确定填充具体操作注解填充字段：@TableField(fill=.)确定字段填充的时机字段填充。插入：插入填充字段字段填充。更新：更新填充字段字段填充。插入_更新：插入和更新填充字段

1.1.2 基本操作

步骤一：修改表添加字段

　　更改表tmp _客户添加列create _ time日期变更表tmp_customer添加列更新时间日期步骤二：修改JavaBean

　　包com。czxy。议员。域；导入com。窦米宝。mybatisplus。注释。*;进口龙目岛。数据；导入Java。util。日期；/** *两通创作. */@ Data @ TableName( tmp _ Customer )公共类客户{ @TableId(type=IdType .自动)私有整数国际开发委员会私有字符串别名解析私有字符串密码；私人有线电话；私串钱；@TableField(value=create_time ，fill=FieldFill .插入)私人日期创建时间；@TableField(value=update_time ，fill=FieldFill .更新)私人日期更新时间；}步骤三：编写处理类

　　包com。czxy。议员。处理者；导入com。窦米宝。mybatisplus。核心。经手人。metaobjecthandler导入org。阿帕奇。伊巴提斯。反思。元对象；导入org。spring框架。刻板印象。组件；导入Java。util。日期；@Componentpublic类MyMetaObjectHandler实现MetaObjectHandler { /** *插入填充* @param元对象*/@覆盖公共空插入填充(元对象元对象){这个。setfieldvalbyname(创建时间，新日期()，元对象);} /** * 更新填充* @param元对象*/@覆盖公共void更新填充(元对象元对象){这个。setfieldvalbyname(更新时间，新日期()，元对象);}}步骤四：测试

　　 @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字段

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

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有数据)

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. */@Componentpublic 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. */@Configurationpublic 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字段

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

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;}

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

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. */@Componentpublic 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 方法，进行数据恢复。

@Mapperpublic 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分析

2.2基本使用 标准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@Transactionalpublic 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...

　　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：配置加密信息

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

　　到此这篇关于MyBatis-Plus插件机制以及通用Service、新功能的文章就介绍到这了,更多相关MyBatis-Plus插件通用Service内容请搜索盛行IT以前的文章或继续浏览下面的相关文章希望大家以后多多支持盛行IT！

郑重声明：本文由网友发布，不代表盛行IT的观点，版权归原作者所有，仅为传播更多信息之目的，如有侵权请联系，我们将第一时间修改或删除，多谢。