1. Mybaits-plus实战(二)
1.1. mybatis-plus插件
1.1.1. 用法
- 先举个例子介绍用法,如下:直接作为Bean注入,一般来讲插件太多印象性能,所以大部分插件都只在测试,开发环境使用,一般不上生产环境,下面我介绍的插件都以xml格式配置为例,因为那样参数展示会多一些,使用时直接pom使用或作为如下Bean注入
@Bean
public PerformanceInterceptor performanceInterceptor() {
PerformanceInterceptor performanceInterceptor = new PerformanceInterceptor();
/*<!-- SQL 执行性能分析,开发环境使用,线上不推荐。 maxTime 指的是 sql 最大执行时长 -->*/
performanceInterceptor.setMaxTime(1000);
/*<!--SQL是否格式化 默认false-->*/
performanceInterceptor.setFormat(false);
return performanceInterceptor;
}
1.1.2. 分页插件
<plugins>
<!--
| 分页插件配置
| 插件提供二种方言选择:1、默认方言 2、自定义方言实现类,两者均未配置则抛出异常!
| overflowCurrent 溢出总页数,设置第一页 默认false
| optimizeType Count优化方式 ( 版本 2.0.9 改为使用 jsqlparser 不需要配置 )
| -->
<!-- 注意!! 如果要支持二级缓存分页使用类 CachePaginationInterceptor 默认、建议如下!! -->
<plugin interceptor="com.baomidou.mybatisplus.plugins.PaginationInterceptor">
<property name="sqlParser" ref="自定义解析类、可以没有" />
<property name="localPage" value="默认 false 改为 true 开启了 pageHeper 支持、可以没有" />
<property name="dialectClazz" value="自定义方言类、可以没有" />
</plugin>
</plugins>
1.1.2.1. json序列化移除transient
- 看到有个jackson的json序列化溢出transient功能,即controller层请求返回对象中属性若有transient修饰,则去掉该属性不传回去
- 但我不习惯用jackson,所以改了fastjson的方式
@Configuration
public class WebConfig implements WebMvcConfigurer {
@Override
public void configureMessageConverters(List<HttpMessageConverter<?>> converters) {
FastJsonHttpMessageConverter fastJsonHttpMessageConverter = new FastJsonHttpMessageConverter();
FastJsonConfig fj = new FastJsonConfig();
fj.setSerializerFeatures(SerializerFeature.SkipTransientField);
fastJsonHttpMessageConverter.setFastJsonConfig(fj);
converters.add(fastJsonHttpMessageConverter);
}
}
1.1.3. 执行分析插件
- 用作拦截全表的delete和update操作,防止瞎写的sql语句
<plugins>
<!-- SQL 执行分析拦截器 stopProceed 发现全表执行 delete update 是否停止运行 -->
<plugin interceptor="com.baomidou.mybatisplus.plugins.SqlExplainInterceptor">
<property name="stopProceed" value="false" />
</plugin>
</plugins>
1.1.4. 性能分析插件
- 用于输出每条 SQL 语句及其执行时间
<plugins>
....
<!-- SQL 执行性能分析,开发环境使用,线上不推荐。 maxTime 指的是 sql 最大执行时长 -->
<plugin interceptor="com.baomidou.mybatisplus.plugins.PerformanceInterceptor">
<property name="maxTime" value="100" />
<!--SQL是否格式化 默认false-->
<property name="format" value="true" />
</plugin>
</plugins>
1.1.5. 乐观锁插件
- 实体字段需要加上
@version
注解
<bean class="com.baomidou.mybatisplus.plugins.OptimisticLockerInterceptor"/>
public class User {
@Version
private Integer version;
...
}
1.1.6. 注入自定义SQL
- 自定义注入全表删除方法 deteleAll
1.1.6.1. java
- 配置注入方法
public class MySqlInjector extends AutoSqlInjector {
@Override
public void inject(Configuration configuration, MapperBuilderAssistant builderAssistant, Class<?> mapperClass,
Class<?> modelClass, TableInfo table) {
/* 添加一个自定义方法 */
deleteAllUser(mapperClass, modelClass, table);
}
public void deleteAllUser(Class<?> mapperClass, Class<?> modelClass, TableInfo table) {
/* 执行 SQL ,动态 SQL 参考类 SqlMethod */
String sql = "delete from " + table.getTableName();
/* mapper 接口方法名一致 */
String method = "deleteAll";
SqlSource sqlSource = languageDriver.createSqlSource(configuration, sql, modelClass);
this.addMappedStatement(mapperClass, method, sqlSource, SqlCommandType.DELETE, Integer.class);
}
}
1.1.6.2. Mapper
- 声明方法
public interface UserMapper extends BaseMapper<User> {
/**
* 自定义注入方法
*/
int deleteAll();
}
1.1.6.3. xml
- 启用
<!-- 定义 MP 全局策略,安装集成文档部分结合 -->
<bean id="globalConfig" class="com.baomidou.mybatisplus.entity.GlobalConfiguration">
.....
<!-- 自定义注入 deleteAll 方法 -->
<property name="sqlInjector" ref="mySqlInjector" />
</bean>
<!-- 自定义注入器 -->
<bean id="mySqlInjector" class="com.baomidou.test.MySqlInjector" />
1.1.7. 公共字段自动填充
MyMetaObjectHandler
的用法,前一篇文章有用到
1.1.8. 逻辑删除
LogicSqlInjector
的用法,前一篇有用到
1.1.9. 读写分离与多数据源
- 集成pom
<dependency>
<groupId>com.baomidou</groupId>
<artifactId>dynamic-datasource-spring-boot-starter</artifactId>
<version>2.x.x</version>
</dependency>
- 配置主从数据源
spring:
datasource:
dynamic:
primary: master #设置默认的数据源或者数据源组,默认值即为master,如果你主从默认下主库的名称就是master可不定义此项。
datasource:
master:
username: root
password: 123456
driver-class-name: com.mysql.jdbc.Driver
url: jdbc:mysql://47.100.20.186:3306/dynamic?characterEncoding=utf8&useSSL=false
slave_1:
username: root
password: 123456
driver-class-name: com.mysql.jdbc.Driver
url: jdbc:mysql://47.100.20.186:3307/dynamic?characterEncoding=utf8&useSSL=false
slave_2:
username: root
password: 123456
driver-class-name: com.mysql.jdbc.Driver
url: jdbc:mysql://47.100.20.186:3308/dynamic?characterEncoding=utf8&useSSL=false
#......省略
#以上会配置一个默认库master,一个组slave下有两个子库slave_1,slave_2
- 切换数据源
使用 @DS 注解切换数据源。
1.1.9.1. 读写分离
1.1.9.1.1. 配置
sharding:
jdbc:
datasource:
names: ds_master,ds_slave_0,ds_slave_1
ds_master:
...
ds_slave_0:
...
ds_slave_1:
...
config:
masterslave:
load-balance-algorithm-type: round_robin
name: ds_ms
master-data-source-name: ds_master
slave-data-source-names: ds_slave_0,ds_slave_1
1.1.10. Sequence主键
- 它提供了id_worker,id_worker_str,uuid三种自定义主键生成器,对oracle可以用
OracleKeyGenerator
配置主键自增 - id_worker就是雪花算法
1.1.11. 其他功能
- 多租户 SQL 解析器
- 通用枚举扫描并自动关联注入
1.2. 条件构造器
- 开始接触mybatis-plus肯定会常常看到
AbstractWrapper
这个条件包装类,通常使用两个实现QueryWrapper
和UpdateWrapper
- 我列一些觉得常用的
-
allEq
,常用allEq(Map<R, V> params)
和allEq(Map<R, V> params, boolean null2IsNull)
,分别表示key对应的值为null,需不需要判断isnull;allEq(BiPredicate<R, V> filter, Map<R, V> params)
应该比较少用- 例子:值的范围大于2000的条件才被入选
Map<String, Object> map = new HashMap<>();
map.put("daily_price_id", 1117L);
QueryWrapper<DailyPrice> queryWrapper = new QueryWrapper<DailyPrice>().allEq((k, v) -> ((Long) v) > 2000L, map);
List<DailyPrice> dailyPrices = dailyPriceService.getBaseMapper().selectList(queryWrapper); eq
,很明显,=ne
不等于大于小于
gt
,lt
,范围between
,like
,常用的关键字都有last
直接拼接sql到最后,如:last("limit 1")
-
- 至于联合查询什么的,或者条件比较复杂的and,or啥的,我觉的还是直接在mapper.xml里直接写sql比较好,那样更简洁明了,它的语法查些简单的语句还是不错的
1.3. 附加知识点
- 在逐步研究mybatis-plus的过程中,遇到的一些实用知识点整理下
1.3.1. 跳过transient属性的值
- 我们从数据库所取的字段很多时候是有冗余的,加了
transient
字段,在controller层返回的时候,json会过滤掉它 - 还需要配置内容如下,主要是
SerializerFeature.SkipTransientField
@Configuration
public class WebConfig implements WebMvcConfigurer {
@Override
public void configureMessageConverters(List<HttpMessageConverter<?>> converters) {
FastJsonHttpMessageConverter fastJsonHttpMessageConverter = new FastJsonHttpMessageConverter();
FastJsonConfig fj = new FastJsonConfig();
// 跳过transient属性的值,浏览器兼容,日期自动格式化
fj.setSerializerFeatures(SerializerFeature.SkipTransientField,SerializerFeature.BrowserCompatible,SerializerFeature.WriteDateUseDateFormat);
fastJsonHttpMessageConverter.setFastJsonConfig(fj);
converters.add(fastJsonHttpMessageConverter);
}
}
1.3.2. 日期自动格式化
- 对日期字段,返回前端需要的是格式化后的,所以也如上配置
SerializerFeature.WriteDateUseDateFormat
即可
官网gitee:https://baomidou.gitee.io/mybatis-plus-doc/#/page-plugin
官网:https://mp.baomidou.com/guide/wrapper.html#abstractwrapper