共计 7103 个字符,预计需要花费 18 分钟才能阅读完成。
看这篇内容之前倡议先看一下 MyBatisPlus 学习整顿(一)
不多 bibi,间接建表
DROP TABLE IF EXISTS `user`;
CREATE TABLE `user` (`id` bigint(20) NULL DEFAULT NULL COMMENT '主键',
`name` varchar(32) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL COMMENT '姓名',
`age` int(11) NULL DEFAULT NULL COMMENT '年龄',
`email` varchar(64) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL COMMENT '邮箱',
`manager_id` bigint(20) NULL DEFAULT NULL COMMENT '直属下级 id',
`create_time` datetime(0) NULL DEFAULT NULL COMMENT '创立工夫',
`update_time` datetime(0) NULL DEFAULT NULL COMMENT '批改工夫',
`version` int(11) NULL DEFAULT 1 COMMENT '版本',
`deleted` int(1) NULL DEFAULT 0 COMMENT '逻辑删除标识(0,未删除;1,已删除)'
) ENGINE = InnoDB CHARACTER SET = utf8 COLLATE = utf8_general_ci ROW_FORMAT = Dynamic;
INSERT INTO `user` VALUES (1234, '大 boss', 40, 'boss@163.com', NULL, '2019-10-02 10:08:02', '2019-10-02 10:08:05', 1, 0);
INSERT INTO `user` VALUES (2345, '王天风', 25, 'wtf@163.com', 1234, '2019-10-02 10:09:07', '2019-10-02 10:09:10', 1, 0);
INSERT INTO `user` VALUES (2346, '李艺伟', 28, 'lyw@163.com', 2345, '2019-10-02 10:10:09', '2019-10-02 10:10:12', 1, 0);
INSERT INTO `user` VALUES (3456, '张雨绮', 31, 'zyq@163.com', 2345, '2019-10-02 10:10:54', '2019-10-02 10:10:58', 1, 0);
INSERT INTO `user` VALUES (4566, '刘雨红', 32, 'lyh@163.com', 2345, '2019-10-02 10:11:51', '2019-10-02 10:11:55', 1, 0);
SET FOREIGN_KEY_CHECKS = 1;
我的项目延用 MyBatisPlus 学习整顿(一)https://github.com/xiao-ren-wu/notebook/tree/master/mybatis-plus-demo
逻辑删除
- 设定逻辑删除规定
在配置文件中配置逻辑删除和逻辑未删除的值
mybatis-plus:
global-config:
logic-not-delete-value: 0
logic-delete-value: 1
- 在 pojo 类中在逻辑删除的字段加注解
@TableLogic
@Data
@EqualsAndHashCode(callSuper = false)
public class User extends Model<User> {@TableId(type = IdType.AUTO)
private Long id;
@TableField(condition = SqlCondition.LIKE)
private String name;
private Integer age;
private String email;
private Long managerId;
private LocalDateTime createTime;
private LocalDateTime updateTime;
private Integer version;
@TableLogic
private Integer deleted;
}
- 通过 id 逻辑删除
@Test
public void deleteById(){userMapper.deleteById(4566L);
}
- 查问中排除删除标识字段及注意事项
逻辑删除字段只是为了标识数据是否被逻辑删除,在查问的时候,并不想也将该字段查问进去。
咱们只须要在 delete 字段上减少@TableField(select = false)
mybatisplus 在查问的时候就会主动疏忽该字段。
@Test
public void selectIgnoreDeleteTest(){userMapper.selectById(3456L);
}
自定义 sql,MybatisPlus 不会疏忽 deleted 属性,须要咱们手动疏忽
主动填充
MybaitsPlus 在咱们插入数据或者更新数据的时候,为咱们提供了主动填充性能。相似 MySQL 提供的默认值一样。
如果咱们须要应用主动填充性能,咱们须要在实体类的相应属性上加 @TableField
注解,并指定什么时候进行主动填充。mybatisPlus 为咱们提供了三种填充机会,在 FieldFill
枚举中
public enum FieldFill {
/**
* 默认不解决
*/
DEFAULT,
/**
* 插入时填充字段
*/
INSERT,
/**
* 更新时填充字段
*/
UPDATE,
/**
* 插入和更新时填充字段
*/
INSERT_UPDATE
}
设置好之后,咱们还须要编写具体的填充规定,具体是编写一个填充类并交给 Spring 治理,而后实现 MetaObjectHandler
接口中的 insertFill
和updateFill
办法。
eg:
- 插入 User 对象的时候主动填充插入工夫,更新 User 对象的时候主动填充更新工夫。
- 指定实体类中须要主动填充的字段,并设置填充机会
@Data
@EqualsAndHashCode(callSuper = false)
public class User extends Model<User> {
...
@TableField(fill = INSERT)
private LocalDateTime createTime;
@TableField(fill = UPDATE)
private LocalDateTime updateTime;
...
}
- 编写填充规定
@Component
public class MyMetaObjHandler implements MetaObjectHandler {
@Override
public void insertFill(MetaObject metaObject) {if(metaObject.hasSetter("createTime")){setInsertFieldValByName("createTime", LocalDateTime.now(),metaObject);
}
}
@Override
public void updateFill(MetaObject metaObject) {if(metaObject.hasSetter("updateTime")){setUpdateFieldValByName("updateTime",LocalDateTime.now(),metaObject);
}
}
}
解释一下为什么要用 if 判断是否有对应的属性
mybatisPlus 在执行插入或者更新操作的时候,每次都会执行该办法,有些表中是没有设置主动填充字段的,而且有些主动填充字段的值的获取比拟耗费零碎性能,所以为了不必要的耗费,进行 if 判断,决定是否须要填充。
有些时候咱们曾经设置了属性的值。不想让 mybatisPlus 再主动填充,也就是说咱们没有设置属性的值,mybatisPlus 进行填充,如果设置了那么就用咱们设置的值。这种状况咱们只须要在填充类中提前获取默认值,而后应用该默认值就能够了。
@Override
public void updateFill(MetaObject metaObject) {if(metaObject.hasSetter("updateTime")){Object updateTime = getFieldValByName("updateTime", metaObject);
if(Objects.nonNull(updateTime)){setUpdateFieldValByName("updateTime",updateTime,metaObject);
}else{setUpdateFieldValByName("updateTime",LocalDateTime.now(),metaObject);
}
}
}
乐观锁
乐观锁实用于读多写少的状况,更新数据的时候不应用“锁“而是应用版本号来判断是否能够更新数据。通过不加锁来减小数据更新工夫和零碎的性能耗费,进而进步数据库的吞吐量。CAS 机制就是一种典型的乐观锁的模式。
乐观锁是逻辑存在的一种概念,咱们如果应用乐观锁须要手动在表的加上 version 字段。
- mysql 应用乐观锁伪代码示例:
update user
set balabala....
where balabala... and version = xxx
乐观锁
1. 配置类中注入乐观锁插件
@Bean
public OptimisticLockerInterceptor optimisticLockerInterceptor(){return new OptimisticLockerInterceptor();
}
- 实体类中的版本字段减少
@version
注解
@Data
@EqualsAndHashCode(callSuper = false)
public class User extends Model<User> {
...
@Version
private Integer version;
...
}
- test
更新王天风的年龄
@Test
public void testLock(){
int version = 1;
User user = new User();
user.setEmail("wtf@163.com");
user.setAge(34);
user.setId(2345L);
user.setManagerId(1234L);
user.setVersion(1);
userMapper.updateById(user);
}
数据库中的 version 曾经变成 2
注意事项:
- 反对的类型只有:int,Integer,long,Long,Date,Timestamp,LocalDateTime
- 整数类型下 newVerison = oldVersion+1
- newVersion 会写到 entity 中
- 仅反对 updateById(id)与 update(entity,wrapper)办法
- 在 update(entiry,wrapper)办法下,wrapper 不能复用
性能剖析
- 配置类中注入性能剖析插件
@Bean
// @Profile({"dev,test"})
public PerformanceInterceptor performanceInterceptor() {PerformanceInterceptor performanceInterceptor = new PerformanceInterceptor();
// 格式化 sql 输入
performanceInterceptor.setFormat(true);
// 设置 sql 执行最大工夫,单位(ms)performanceInterceptor.setMaxTime(5L);
return performanceInterceptor;
}
执行 sql 就能够打印 sql 执行的信息了
依附第三方插件丑化 sql 输入
https://mp.baomidou.com/guide/p6spy.html
- 第三方依赖
<dependency>
<groupId>p6spy</groupId>
<artifactId>p6spy</artifactId>
<version>3.8.5</version>
</dependency>
- 更改配置文件中的 dirver 和 url
spring:
datasource:
# driver-class-name: com.mysql.cj.jdbc.Driver
username: root
password: root
# url: jdbc:mysql://localhost:3306/test?serverTimezone=CTT&useUnicode=true&characterEncoding=utf-8&allowMultiQueries=true
driver-class-name: com.p6spy.engine.spy.P6SpyDriver
url: jdbc:p6spy:mysql://localhost:3306/test?serverTimezone=CTT&useUnicode=true&characterEncoding=utf-8&allowMultiQueries=true
- 减少 spy.properties 配置文件
module.log=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,batch,resultset
# 日期格局
dateformat=yyyy-MM-dd HH:mm:ss
# 理论驱动可多个
#driverlist=org.h2.Driver
# 是否开启慢 SQL 记录
outagedetection=true
# 慢 SQL 记录规范 2 秒
outagedetectioninterval=2
- test
留神
开启性能剖析会耗费零碎的性能,所以性能剖析插件要配合 @Profile
注解执行应用的环境。
SQL 注入器 ->_-> 封装自定义通用 SQL
实现步骤:
- 创立定义方法的类
- 创立注入器
- 在 mapper 中退出自定义办法
eg: 编写一个删除表所有数据的办法
- 创立定义方法的类
public class DeleteAllMethod extends AbstractMethod {
@Override
public MappedStatement injectMappedStatement(Class<?> mapperClass, Class<?> modelClass, TableInfo tableInfo) {
// 执行的 sql
String sql = "delete from" + tableInfo.getTableName();
// mapper 接口办法名
String method = "deleteAll";
SqlSource sqlSource = languageDriver.createSqlSource(configuration, sql, mapperClass);
return addDeleteMappedStatement(mapperClass, method, sqlSource);
}
}
- 创立注入器。增加本人的办法
@Component
public class MySqlInject extends DefaultSqlInjector {
@Override
public List<AbstractMethod> getMethodList(Class<?> mapperClass) {List<AbstractMethod> methodList = super.getMethodList(mapperClass);
methodList.add(new DeleteAllMethod());
return methodList;
}
}
- 在 mapper 中退出自定义办法
public interface UserMapper extends BaseMapper<User> {
/**
* 删除所有表数据
*
* @return 影响行数
*/
int deleteAll();}
- test
@Test
public void deleteAll(){userMapper.deleteAll();
}
- 附录
- 参考源码 https://github.com/xiao-ren-wu/notebook/blob/master/mybatis-plus-demo-2.zip