标签:tooltip row record .net pad generator prope 搭建 error
此Demo 主要应用SpringBoot 来展示Mybatis-Plus 特性, 以及在开发过程中可能应用到的插件的演示。
源码:https://github.com/wunian7yulian/MybatisPlusDemo
本文:https://wunian7yulian.github.io/MybatisPlusDemo/
相同于 MyBatis官方指南 中有了详细介绍
不同于 实践演示
目的:
主要借此做为突破口, 一是将自我学习成文记录下来, 二是将Demo 慢慢做成一个自己或者面向大众的后端脚手架工具。
规划:
分享-实践-填坑-总结-脚手架-分享-实践......
Mybatis-Plus 我来填坑~简介: 目录一、简单介绍官方说明 :成绩:最新版本:开发层面MyBatis-Plus特色Mybatis-Plus中的Plus二、MP的特性三、MP框架结构四、简单的入门Demo(Mysql)Demo代码地址:Demo 环境: 初始化:数据库:MySqlDDL:DML:工程:第一步、创建工程第二步、引入依赖坐标第三步、配置数据源第四步、添加mybatis扫描位置第五步、pojo及mapper第六步、测试五、核心功能核心一-简便之-代码生成器(AutoGenerator)Demo代码地址:Demo 环境: 工程:第一步、创建模块第二步、引入依赖坐标第三步、编写代码生成器第四步、运行测试发现问题: 如果是多模块项目 生成的文件会直接到了父项目目录下解决方法:核心二 - 清晰之-CRUD接口Demo代码地址:工程:第一步、创建模块第二步、引入依赖坐标第三步、生成代码第四步、其他配置需要第五步、对MP探个究竟!发现问题: 我虽然看到了方法 但是并没有一条SQL 那么它是怎样做到查询的呢?探索:第六步、使用它Mapper - 简单的CRUD:发现问题: 虽然MP替我生成了 uuid 作为主键,但是还是想用数据库自增形式主键怎么办?解决:Mapper - 批量的CRUD接口:Mapper - 选装组件:Service - CRUD:核心三 - 强大之 -Wrapper条件构造器Demo代码地址:工程: 第一 -->第四步 同上一工程步骤 第五步、探索WrapperWrapper含义: 版本不同:3.x Wrapper主要继承结构: AbstractWrapper接口:AbstractWrapper接口:UpdateWrapper接口:第六步、使用接口##打印SQL日志配置一> 编写AbstractWrapper测试类:发现问题: boolean condition
、 R column
和 Function<This, This> func
三个参数相关问题说明及使用:1.关于入参: boolean condition
2.关于入参: R column
3.关于入参: Function<This, This> func
二> 编写QueryWrapper与UpdateWrapper测试类:注意坑 在借用 lambda()
使用 lambda特性时!六、插件及扩展 Demo代码地址:工程:第一 -->第四步、同上第五步、插件使用分页插件:1、创建一个MP插件的配置类:2、配置分页插件3、编写测试逻辑删除插件:1、yaml添加逻辑值制定配置:2、配置逻辑插件:3、标识逻辑字段:4、编写测试乐观锁:主要适用场景七 、总结参考文档:
Mybatis-Plus(简称MP)是一个Mybatis的增强工具,在 Mybatis 的基础上只做增强不做改变,为简化开发而生!
MyBatis-Plus 荣获【2018年度开源中国最受欢迎的中国软件】 TOP5 ?
<dependency>
<groupId>com.baomidou</groupId>
<artifactId>mybatis-plus</artifactId>
<version>3.0.7.1</version>
</dependency>
官方简介说明 MP 和Mybatis 就像是 游戏中的p1 和p2 一样 兄弟搭配 干活不累 、
我在使用中明显感觉到 其实他更像是 马里奥和蘑菇 吃了蘑菇 我们跳的高度更高了一些。
内含分布式唯一 ID 生成器 - Sequence
),可自由配置,完美解决主键问题
https://github.com/wunian7yulian/MybatisPlusDemo/tree/master/simpledemo
windows 7
jdk 1.8.0.40
idea Ultimate
maven 3.3.9
创建数据库mp_demo_db
设置字符集 utf-8
-- 创建简单表格
DROP TABLE IF EXISTS user;
?
CREATE TABLE `user` (
`id` bigint(20) PRIMARY KEY AUTO_INCREMENT COMMENT ‘主键ID‘,
`name` varchar(30) DEFAULT NULL COMMENT ‘姓名‘,
`age` int(11) DEFAULT NULL COMMENT ‘年龄‘,
`email` varchar(50) DEFAULT NULL COMMENT ‘邮箱‘
) ENGINE=InnoDB DEFAULT CHARSET=utf8;
?
?
xxxxxxxxxx
-- 初始化数据
DELETE FROM user;
?
INSERT INTO user (id, name, age, email) VALUES
(1, ‘Jone‘, 18, ‘test1@baomidou.com‘),
(2, ‘Jack‘, 20, ‘test2@baomidou.com‘),
(3, ‘Tom‘, 28, ‘test3@baomidou.com‘),
(4, ‘Sandy‘, 21, ‘test4@baomidou.com‘),
(5, ‘Billie‘, 24, ‘test5@baomidou.com‘);
为了方便快捷 选用 SpringBoot 工程作为Demo支撑
输入项目包名 并添加mysql模块 创建完毕。
xxxxxxxxxx
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
<scope>runtime</scope>
</dependency>
?
<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
<optional>true</optional>
</dependency>
<dependency>
<groupId>com.baomidou</groupId>
<artifactId>mybatis-plus-boot-starter</artifactId>
<version>3.0.7.1</version>
</dependency>
<!--手动添加模板引擎-->
<dependency>
<groupId>org.freemarker</groupId>
<artifactId>freemarker</artifactId>
<version>2.3.20</version>
</dependency>
<dependency>
<groupId>com.baomidou</groupId>
<artifactId>mybatis-plus-generator</artifactId>
<version>3.0.6</version>
</dependency>
<dependency>
<groupId>com.baomidou</groupId>
<artifactId>mybatis-plus-core</artifactId>
<version>3.0.7.1</version>
</dependency>
在 application.yml
配置文件中添加相关配置:
xxxxxxxxxx
# DataSource Config
spring
datasource
# 这里如果有错误是因为 maven mysql包 选择了 runtime 形式的 scope 可以不用管它 继续下一步就好
driver-class-name com.mysql.jdbc.Driver
url jdbc mysql //127.0.0.1 3306/mp_demo_db?characterEncoding=utf8
username root
password123456
xxxxxxxxxx
?
"com.lynwood.mp.simpledemo.mapper") (
public class SimpledemoApplication {
?
public static void main(String[] args) {
SpringApplication.run(SimpledemoApplication.class, args);
}
?
}
pojo:
xxxxxxxxxx
import lombok.Data;
?
public class User {
private Long id;
private String name;
private Integer age;
private String email;
}
mapper:
xxxxxxxxxx
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.lynwood.mp.simpledemo.model.User;
?
public interface UserMapper extends BaseMapper<User> {
?
}
xxxxxxxxxx
SpringRunner.class) (
public class SampleTest {
?
private UserMapper userMapper;
?
public void testSelect() {
List<User> userList = userMapper.selectList(null);
Assert.assertEquals(5, userList.size());
userList.forEach(System.out::println);
}
?
}
运行结果:
xxxxxxxxxx
User{id=1, name=‘Jone‘, age=18, email=‘test1@baomidou.com‘}
User{id=2, name=‘Jack‘, age=20, email=‘test2@baomidou.com‘}
User{id=3, name=‘Tom‘, age=28, email=‘test3@baomidou.com‘}
User{id=4, name=‘Sandy‘, age=21,email=‘test4@baomidou.com‘}
User{id=5, name=‘Bill‘, age=24,email=‘test5@baomidou.com‘}
AutoGenerator 是 MyBatis-Plus 的代码生成器,通过 AutoGenerator 可以快速生成 Entity、Mapper、Mapper XML、Service、Controller 等各个模块的代码,极大的提升了开发效率。
https://github.com/wunian7yulian/MybatisPlusDemo/tree/master/simpledemo
同上
创建了autogenerator_demo模块(记得添加mysql模块 )作为演示代码生成器功能配置。
xxxxxxxxxx
<dependency>
<groupId>com.baomidou</groupId>
<artifactId>mybatis-plus-boot-starter</artifactId>
<version>3.0.7.1</version>
</dependency>
<!--手动添加模板引擎-->
<dependency>
<groupId>org.freemarker</groupId>
<artifactId>freemarker</artifactId>
<version>2.3.20</version>
</dependency>
<dependency>
<groupId>com.baomidou</groupId>
<artifactId>mybatis-plus-generator</artifactId>
<version>3.0.6</version>
</dependency>
注意:MP 3.0.3
之后移除了自动模板引擎依赖,需要手动添加对应模板引擎
直接复制就行啦!
xxxxxxxxxx
package com.lynwood.mp.autogenerator_demo;
?
import com.baomidou.mybatisplus.core.exceptions.MybatisPlusException;
import com.baomidou.mybatisplus.core.toolkit.StringPool;
import com.baomidou.mybatisplus.core.toolkit.StringUtils;
import com.baomidou.mybatisplus.generator.AutoGenerator;
import com.baomidou.mybatisplus.generator.InjectionConfig;
import com.baomidou.mybatisplus.generator.config.*;
import com.baomidou.mybatisplus.generator.config.po.TableInfo;
import com.baomidou.mybatisplus.generator.config.rules.NamingStrategy;
import com.baomidou.mybatisplus.generator.engine.FreemarkerTemplateEngine;
?
import java.util.ArrayList;
import java.util.List;
import java.util.Scanner;
?
//注意引入GlobalConfig 使用 import com.baomidou.mybatisplus.generator.config.*;
?
public class GeneratorCode {
/**
* 读取控制台内容
*/
public static String scanner(String tip) {
Scanner scanner = new Scanner(System.in);
StringBuilder help = new StringBuilder();
help.append("请输入" + tip + ":");
System.out.println(help.toString());
if (scanner.hasNext()) {
String ipt = scanner.next();
if (StringUtils.isNotEmpty(ipt)) {
return ipt;
}
}
throw new MybatisPlusException("请输入正确的" + tip + "!");
}
?
public static void main(String[] args) {
// 代码生成器
AutoGenerator mpg = new AutoGenerator();
?
// 全局配置
GlobalConfig gc = new GlobalConfig();
String projectPath = System.getProperty("user.dir");
gc.setOutputDir(projectPath + "/src/main/java");
gc.setAuthor("Lynwood");
gc.setOpen(false);
mpg.setGlobalConfig(gc);
?
// 数据源配置
DataSourceConfig dsc = new DataSourceConfig();
dsc.setUrl("jdbc:mysql://127.0.0.1:3306/mp_demo_db?useUnicode=true&useSSL=false&characterEncoding=utf8");
// dsc.setSchemaName("public");
dsc.setDriverName("com.mysql.jdbc.Driver");
dsc.setUsername("root");
dsc.setPassword("123456");
mpg.setDataSource(dsc);
?
// 包配置
PackageConfig pc = new PackageConfig();
pc.setModuleName(scanner("模块名"));
pc.setParent("com.lynwood.mp.autogenerator_demo");
mpg.setPackageInfo(pc);
?
// 自定义配置
InjectionConfig cfg = new InjectionConfig() {
public void initMap() {
// to do nothing
}
};
?
// 如果模板引擎是 freemarker
String templatePath = "/templates/mapper.xml.ftl";
// 如果模板引擎是 velocity
// String templatePath = "/templates/mapper.xml.vm";
?
// 自定义输出配置
List<FileOutConfig> focList = new ArrayList<>();
// 自定义配置会被优先输出
focList.add(new FileOutConfig(templatePath) {
public String outputFile(TableInfo tableInfo) {
// 自定义输出文件名
return projectPath + "/src/main/resources/mapper/" + pc.getModuleName()
+ "/" + tableInfo.getEntityName() + "Mapper" + StringPool.DOT_XML;
}
});
?
cfg.setFileOutConfigList(focList);
mpg.setCfg(cfg);
?
// 配置模板
TemplateConfig templateConfig = new TemplateConfig();
?
// 配置自定义输出模板
// templateConfig.setEntity();
// templateConfig.setService();
// templateConfig.setController();
?
templateConfig.setXml(null);
mpg.setTemplate(templateConfig);
?
// 策略配置
StrategyConfig strategy = new StrategyConfig();
strategy.setNaming(NamingStrategy.underline_to_camel);
strategy.setColumnNaming(NamingStrategy.underline_to_camel);
strategy.setSuperEntityClass(null);
strategy.setEntityLombokModel(true);
strategy.setRestControllerStyle(true);
strategy.setSuperControllerClass(null);
strategy.setInclude(scanner("表名"));
strategy.setSuperEntityColumns(null);
strategy.setControllerMappingHyphenStyle(true);
strategy.setTablePrefix(pc.getModuleName() + "_");
mpg.setStrategy(strategy);
mpg.setTemplateEngine(new FreemarkerTemplateEngine());
mpg.execute();
}
?
}
?
在控制台输入:
就可以生成代码啦!
都包含 :
原因是:在代码的全局配置中 String projectPath = System.getProperty("user.dir");
获取Working Directory时 返回的是项目路径,并非模块路径!
我们可以设定运行参数选项
将 Working Directory 调整为 当前模块目录 再次运行就ok了!
https://github.com/wunian7yulian/MybatisPlusDemo/tree/master/mp_crud_demo
Mybatis-Plus 为我们提供了丰富的 增删改查接口
我们可以分为三类 Mapper的CRUD接口、Service的CRUD接口和mapper层选装件接口:
确实比较丰富 , 下面会以具有代表性的例子来使用 演示 作为Demo主要内容
创建mp_crud_demo模块 选择mysql
因为需要生成表对应Pojo 还需要代码生成器
然后我们将上面的直接拷贝一下
xxxxxxxxxx
<dependency>
<groupId>com.baomidou</groupId>
<artifactId>mybatis-plus-boot-starter</artifactId>
<version>3.0.7.1</version>
</dependency>
<!--手动添加模板引擎-->
<dependency>
<groupId>org.freemarker</groupId>
<artifactId>freemarker</artifactId>
<version>2.3.20</version>
</dependency>
<dependency>
<groupId>com.baomidou</groupId>
<artifactId>mybatis-plus-generator</artifactId>
<version>3.0.6</version>
</dependency>
再添加 lombok 依赖(因:生成代码中的实体默认是使用@Data 等注解的)
xxxxxxxxxx
<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
<optional>true</optional>
</dependency>
pc.setParent("com.lynwood.mp.mp_crud_demo");
设定mybatis扫描位置
在MpCrudDemoApplication
上添加注解:@MapperScan("com.lynwood.mp.mp_crud_demo.*.mapper**")
注意 扫描包的位置!
配置数据源:
xxxxxxxxxx
# DataSource Config
spring
datasource
# 这里如果有错误是因为 maven mysql包 选择了 runtime 形式的 scope 可以不用管它 继续下一步就好
driver-class-name com.mysql.jdbc.Driver
url jdbc mysql //127.0.0.1 3306/mp_demo_db?characterEncoding=utf-8
username root
password123456
以userMapper
作为范例
查看UserMapper
:
打开UserMapper.java
源代码:
xxxxxxxxxx
public interface UserMapper extends BaseMapper<User> {
}
?
不难发现它继承了BaseMapper<User>
接口
打开com.baomidou.mybatisplus.core.mapper.BaseMapper<T>
查看当前接口的结构(Structure):
原来是MP 将之前的mybatis里面每个mapper的所有方法 经过泛型进行提炼到了一个BaseMapper 接口中,我们只需要将自己的mapper 继承此接口且将泛型指定便可获得强大的CRUD功能!
再去查看UserMapper.xml
文件 :
xxxxxxxxxx
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.lynwood.mp.mp_crud_demo.business.mapper.UserMapper">
?
</mapper>
完全丢弃了Mybatis
中字段映射以及一段段复杂的配置!
xxxxxxxxxx
<dependency>
<groupId>com.baomidou</groupId>
<artifactId>mybatis-plus-boot-starter</artifactId>
<version>3.0.7.1</version>
</dependency>
我们进入mybatis-plus-boot-starter
的pom 发现他帮我们装配了对应版本的mybatis-plus
并且依赖了其他 例如: spring-boot-autoconfigure``spring-boot-starter-jdbc
等;
因为了解SpringBoot
中配置入口是一个@Configuration
那么打开mybatis-plus-boot-starter
的jar
包 看到:MybatisPlusAutoConfiguration.java
:
xxxxxxxxxx
...
public class MybatisPlusAutoConfiguration {
...
public SqlSessionFactory sqlSessionFactory(DataSource dataSource) throws Exception {
...
if (this.applicationContext.getBeanNamesForType(ISqlInjector.class, false, false).length > 0) {
ISqlInjector iSqlInjector = (ISqlInjector)this.applicationContext.getBean(ISqlInjector.class);
globalConfig.setSqlInjector(iSqlInjector);
}
?
factory.setGlobalConfig(globalConfig);
return factory.getObject();
}
...
}
看到它在设置sqlSessionFactory
的时候为我们指定了一个com.baomidou.mybatisplus.core.injector.ISqlInjector.class
作为factory.globalConfig.sqlInjector
(SQL注入器)
然后 我们打开:ISqlInjector
的实现类AbstractSqlInjector
xxxxxxxxxx
...
public abstract class AbstractSqlInjector implements ISqlInjector {
...
public void inspectInject(MapperBuilderAssistant builderAssistant, Class<?> mapperClass) {
...
List<AbstractMethod> methodList = this.getMethodList();
Assert.notEmpty(methodList, "No effective injection method was found.", new Object[0]);
methodList.forEach((m) -> {
m.inject(builderAssistant, mapperClass);
});
...
}
}
methodList
是所有的方法的一个集合 其元素类型都是AbstractMethod.class
类型的, 并且对每个方法都进行了inject(...)
,
那么查看inject()
方法源码:
xxxxxxxxxx
public void inject(MapperBuilderAssistant builderAssistant, Class<?> mapperClass) {
...
this.injectMappedStatement(mapperClass, modelClass, tableInfo);
}
}
原来最终调用了injectMappedStatement()
方法
然而
xxxxxxxxxx
public abstract MappedStatement injectMappedStatement(Class<?> var1, Class<?> var2, TableInfo var3);
是抽象的 需要自己的子类去实现的
我们以其中一个 SelectById.class
作为例子查看
xxxxxxxxxx
public MappedStatement injectMappedStatement(Class<?> mapperClass, Class<?> modelClass, TableInfo tableInfo) {
SqlMethod sqlMethod = SqlMethod.SELECT_BY_ID;
SqlSource sqlSource = new RawSqlSource(this.configuration, String.format(sqlMethod.getSql(), this.sqlSelectColumns(tableInfo, false), tableInfo.getTableName(), tableInfo.getKeyColumn(), tableInfo.getKeyProperty()), Object.class);
return this.addSelectMappedStatement(mapperClass, sqlMethod.getMethod(), sqlSource, modelClass, tableInfo);
}
?
再去查看 SqlMethod.SELECT_BY_ID;
:
xxxxxxxxxx
SELECT_BY_ID("selectById", "根据ID 查询一条数据", "SELECT %s FROM %s WHERE %s=#{ %s}"),
soga~
结束 最后实际上 MP将SQL语句 封装了固定的模板 com.baomidou.mybatisplus.core.enums.SqlMethod
从而提供给了我们便捷的使用!
我们使用非Wrapper的具有代表性的接口作为Demo的演示
Wrapper 在后面会有单独的Demo演示
xxxxxxxxxx
SpringRunner.class) (
public class MpCrudDemoApplicationTests {
?
private UserMapper userMapper;
?
public void simplenessMapperCURD() {
//增加
User addUser = new User();
addUser.setAge(18);
addUser.setEmail("wunian_@hotmail.com");
addUser.setName("Lynwood");
userMapper.insert(addUser); // insert 之后是将id装配到实体对象里的
System.out.println("add:\n" + addUser);
// User(id=1082883152404103169, name=Lynwood, age=18, email=wunian_@hotmail.com)
// id = 1082883152404103169 之所以这么长是因为 MP底层给我们自己以uuid 的形式添加了 user对象的id属性
?
//修改
User updateUser = new User();
updateUser.setId(1082883152404103169L);
updateUser.setName("ok?");
userMapper.updateById(updateUser);
System.out.println("update:\n" + updateUser);
// User(id=1082883152404103169, name=ok?, age=null, email=null)
// 刷新数据库 更改成功 但是没有讲其他对象进行装配
?
//查询
User selectUser = userMapper.selectById(1082883152404103169L);
System.out.println("select:\n" + selectUser);
//User(id=1082883152404103169, name=ok?, age=18, email=wunian_@hotmail.com)
?
//删除
int i = userMapper.deleteById(1082883152404103169L);
if (i==1){
System.out.println("delete:\n" + "删除成功!");
//刷新库 删除成功
}
}
}
MP提供的主键策略有:
MP的主键策略默认使用的是ID_WORKER
(详情:https://mybatis.plus/config/#idtype)
在User 中设定 id字段为@TableId(type = IdType.AUTO)
或者 全局设置 使用主键策略,在yaml 添加:
xxxxxxxxxx
mybatis-plus
global-config
db-config
id-type auto
重要: 因为刚才的测试插入了id为:1082883152404103169
的 数据 我们需要将自增序列首先恢复正常! 否则下一个id为1082883152404103170 看上去也是乱的!! 小心坑哈~
xxxxxxxxxx
delete from user;
alter table user auto_increment= 1;
尝试 增加操作 输出:
xxxxxxxxxx
add:
User(id=1, name=Lynwood, age=18, email=wunian_@hotmail.com)
填充测试数据:
xxxxxxxxxx
DELETE FROM user;
INSERT INTO user ( name, age, email) VALUES
( ‘Lynwood‘,18,‘wunian_@hotmail.com‘)
( ‘Jone‘, 18, ‘test1@baomidou.com‘),
( ‘Jack‘, 20, ‘test2@baomidou.com‘),
( ‘Tom‘, 28, ‘test3@baomidou.com‘),
( ‘Sandy‘, 21, ‘test4@baomidou.com‘),
( ‘Billie‘, 24, ‘test5@baomidou.com‘);
测试:
xxxxxxxxxx
public void batchMapperCURD() {
// 多id 查询
List<Long> idList = new ArrayList<>();
idList.add(1L);
idList.add(3L);
List<User> userList = userMapper.selectBatchIds(idList);// id的多个查询
System.out.println("selectBatch:" );
userList.forEach(System.out::println);
//User(id=1, name=Lynwood, age=18, email=wunian_@hotmail.com)
//User(id=3, name=Jack, age=20, email=test2@baomidou.com)
?
// 多条件 查询
Map<String,Object> stringObjectMap = new HashMap<>();
stringObjectMap.put("age",18);
stringObjectMap.put("id",2);
List<User> selectByMap = userMapper.selectByMap(stringObjectMap);// 字段-值 键值对集合 作为 ‘且‘ 关系
System.out.println("selectByMap:" );
selectByMap.forEach(System.out::println);
//User(id=2, name=Jone, age=18, email=test1@baomidou.com)
// 多id 删除
int deleteCount = userMapper.deleteBatchIds(idList);// id的多个删除
System.out.println("deleteBatch:\n"+ deleteCount );
// 2
// 多条件 删除
int deleteCount2 = userMapper.deleteByMap(stringObjectMap);// id的多个查询
System.out.println("deleteByMap:\n"+ deleteCount2 );
// 1
}
注意使用*ByMap()
方法时 条件是 且关系就ok了!
查看了MP作者说的:
作者在源码注释中是这么写的....:
xxxxxxxxxx
/**
* <p> 批量新增数据,自选字段 insert </p>
* <p> 不同的数据库支持度不一样!!! 只在 mysql 下测试过!!! 只在 mysql 下测试过!!! 只在 mysql 下测试过!!! </p>
* <p> 除了主键是 <strong> 数据库自增的未测试 </strong> 外理论上都可以使用!!! </p>
* <p> 如果你使用自增有报错或主键值无法回写到entity,就不要跑来问为什么了,因为我也不知道!!! </p>
* <p>
* 自己的通用 mapper 如下使用:
* int insertBatchSomeColumn(List<T> entityList);
*
* <li> 注意1: 不要加任何注解 !! </li>
* <li> 注意2: 自选字段 insert !!,如果个别字段在 entity 里为 null 但是数据库中有配置默认值, insert 后数据库字段是为 null 而不是默认值 </li>
*
* <p>
* 常用的构造入参:
* </p>
*/
┓( ′?` )┏ ~
然后分析其作用 觉得既然有wrapper的强大条件构造器 决定不再分析 想了解可以点击:
不过 案例 说明了MP的一些可以自己扩展的一个流程 :
第一步: 在UserMapper
添加方法
xxxxxxxxxx
/** 清空表数据 */
void clearTable();
第二步:自定义实现
在于business
同级下创建mp_injector/methods
目录并创建类名CLearTable.java
要与添加的方法名 相同!
且要实现com.baomidou.mybatisplus.core.injector.AbstractMethod
完成自定义扩展
xxxxxxxxxx
public class ClearTable extends AbstractMethod {
public MappedStatement injectMappedStatement(Class<?> mapperClass, Class<?> modelClass, TableInfo tableInfo) {
/* 执行 SQL */
String sql = "delete from " + tableInfo.getTableName();
/* mapper 接口方法名一致 */
String method = "clearTable";
SqlSource sqlSource = languageDriver.createSqlSource(configuration, sql, modelClass);
return this.addDeleteMappedStatement(mapperClass, method, sqlSource);
}
}
?
第三步:将自定义实现 添加到MP方法列表
在mp_injector
下创建MySqlInjector.java
来进行对MP的扩展操作:
需要继承com.baomidou.mybatisplus.core.injector.DefaultSqlInjector
并且重写 MP获取方法列表的方法
xxxxxxxxxx
?
public class MySqlInjector extends DefaultSqlInjector {
public List<AbstractMethod> getMethodList() {
List<AbstractMethod> methodList = super.getMethodList();
//增加了 自定义方法
methodList.add(new ClearTable());
return methodList;
}
}
?
第四步:测试
xxxxxxxxxx
public void myInjectorMapperCURD() {
userMapper.clearTable();
}
查库 全部删除了
总结:
不难发现其实际上就是 在上文 对MP探个究竟 中探索到的 所有方法的原理
非Wrapper部分基本与Mapper 接口一致 只是将接口提到了service层.
略~
https://github.com/wunian7yulian/MybatisPlusDemo/tree/master/mp_wrapper_demo
xxxxxxxxxx
mybatis-plus
global-config
db-config
id-type auto
备:关于 java8 lambda 表达式 默认为熟悉
因为MP 对外已经有了两个大的版本 2.x 和3.x版本
在2.x版本中 EntityWrapper
作为Wrapper 的主要继承实现,
例:
xxxxxxxxxx
EntityWrapper<User> ew = new EntityWrapper<User>();
ew.setEntity(new User(1));
ew.where("user_name={0}", "‘zhangsan‘").and("id=1")
.orNew("user_status={0}", "0").or("status=1")
.notLike("user_nickname", "notvalue")
.andNew("new=xx").like("hhh", "ddd")
.andNew("pwd=11").isNotNull("n1,n2").isNull("n3")
.groupBy("x1").groupBy("x2,x3")
.having("x1=11").having("x3=433")
.orderBy("dd").orderBy("d1,d2");
System.out.println(ew.getSqlSegment());
?
实际上 此包装实际上是使用的是 数据库字段 不是Pojo 里面的成员变量
在3.x 升级中对Wrapper进行了改动:
全面支持了jdk8的Lambda的使用
Wrapper<T>
实现类的改动
1.EntityWrapper<T>
更名为QueryWrapper<T>
2.新增一个实现类UpdateWrapper<T>
用于update
方法
BaseMapper<T>
的改动
1.去除了insertAllColumn(T entity)
方法 2.去除了updateAllColumn(T entity)
方法 3.新增update(T entity, Wrapper<T> updateWrapper)
方法
在3.x 中将 所有的操作划分成 查询QueryWrapper
和UpdateWrapper
并且将其共有的方法做了一层抽离放到了AbstractWrapper
中
我们查看四个实现类:QueryWrapper
、UpdateWrapper
、LambdaQueryWrapper
、LambdaUpdateWrapper
的一个总体抽象: AbstractWrapper
它将共有的提升到这一层并做了实现,
其实主要是对SQL语言所有DML语句中公用的一些关键字做了统一的接口
为了方便查看最后MP封装转换的最终SQL,在yml配置文件中添加配置:
xxxxxxxxxx
mybatis-plus
configuration
log-impl org.apache.ibatis.logging.stdout.StdOutImpl
xxxxxxxxxx
...
SpringRunner.class) (
public class MpWrapperDemoApplicationAbstractWrapperTests {
private UserMapper userMapper;
?
/**
* 测试 allEq() 等同于 WHERE name = ? AND age = ?
* +
* 使用 selectList() 返回多个指定类型对象 的集合
*
*/
public void abstractWrapperTest_allEq() {
QueryWrapper<User> userQueryWrapper = new QueryWrapper<>();
HashMap<String,Object> param = new HashMap<>();
param.put("name","Lynwood");
param.put("age","18");
userQueryWrapper.allEq(param);
List<User> userList = userMapper.selectList(userQueryWrapper);
userList.forEach(System.out::println);
/**
* 输出:
* ==> Preparing: SELECT id,name,age,email FROM user WHERE name = ? AND age = ?
* ==> Parameters: Lynwood(String), 18(String)
*/
}
?
/**
* 测试 eq() 等同于 WHERE name = ?
* +
* 使用selectOne()
* 当返回多条会报错
*/
public void abstractWrapperTest_eq() {
QueryWrapper<User> userQueryWrapper = new QueryWrapper<>();
userQueryWrapper.eq("name","Lynwood");
User user = userMapper.selectOne(userQueryWrapper);
System.out.println(user);
/**
* 输出:
* Preparing: SELECT id,name,age,email FROM user WHERE name = ?
* Parameters: Lynwood(String)
*/
}
?
/** not equals 缩写 ~~
*
* 测试 ne() 等同于 WHERE age <> ?
* +
* 使用 selectObjs() 返回多个 非指定类型对象 的集合
*
*/
public void abstractWrapperTest_ne() {
QueryWrapper<User> userQueryWrapper = new QueryWrapper<>();
userQueryWrapper.ne("age", 18);
List<Object> objectList = userMapper.selectObjs(userQueryWrapper);
objectList.forEach(System.out::println);
/**
* 输出:
* ==> Preparing: SELECT id,name,age,email FROM user WHERE age <> ?
* ==> Parameters: 18(Integer)
*/
}
?
/***************************************************** 多接口连用 * 默认AND 关系*******************************/
/** 测试
* gt() : greater than 等同于 >
* ge() : greater equals 等同于 >=
* lt() : less than 等同于 <
* le() : less equals 等同于 <=
*
* 使用 selectMaps() 返回多个 指定到Map做封装 的集合
*
*/
public void abstractWrapperTest_gt_ge_lt_le() {
QueryWrapper<User> userQueryWrapper = new QueryWrapper<>();
userQueryWrapper.ge("age", 21);
userQueryWrapper.le("age", 24);
List<Map<String, Object>> mapList = userMapper.selectMaps(userQueryWrapper);
mapList.forEach(System.out::println);
/**
* 输出:
* ==> Preparing: SELECT id,name,age,email FROM user WHERE age >= ? AND age <= ?
* ==> Parameters: 21(Integer), 24(Integer)
*/
}
?
/**
* 测试
* between() 等同于 WHERE age between ? and ?
* notBetween() 等同于 WHERE age not between ? and ?
* +
* 使用 selectList() 返回多个 非指定类型对象 的集合
*
*/
public void abstractWrapperTest_between() {
QueryWrapper<User> userQueryWrapper = new QueryWrapper<>();
userQueryWrapper
.between("age", 18,24)
.notBetween("id",0,11);// 支持链式调用
?
List<User> userList = userMapper.selectList(userQueryWrapper);
userList.forEach(System.out::println);
/**
* 输出:
==> Preparing: SELECT id,name,age,email FROM user WHERE age BETWEEN ? AND ? AND id NOT BETWEEN ? AND ?
==> Parameters: 18(Integer), 24(Integer), 0(Integer), 11(Integer)
*/
}
?
/**
* 测试
* like() 等同于 LIKE ‘%?%‘
* notLike() 等同于 NOT LIKE ‘%?%‘
* likeLeft() 等同于 LIKE ‘%?‘
* likeRight() 等同于 LIKE ‘?%‘
* +
* 使用 selectCount() 返回查询到的条数
*/
public void abstractWrapperTest_like() {
QueryWrapper<User> userQueryWrapper = new QueryWrapper<>();
userQueryWrapper
.like("email", "test")
.notLike("email","test4")
.likeRight("name","J") // J%
.likeLeft("name","e"); //%e
Integer selectCount = userMapper.selectCount(userQueryWrapper);
System.out.println(selectCount);
/**
* 输出:
==> Preparing: SELECT id,name,age,email FROM user WHERE email LIKE ? AND email NOT LIKE ? AND name LIKE ? AND name LIKE ?
==> Parameters: %test%(String), %test4%(String), J%(String), %e(String)
*/
}
?
/**
* 测试
* null() 等同于 is null
* isNotNull() 等同于 is not null
*
*/
public void abstractWrapperTest_null() {
QueryWrapper<User> userQueryWrapper = new QueryWrapper<>();
userQueryWrapper
.isNotNull("name");
Integer selectCount = userMapper.selectCount(userQueryWrapper);
System.out.println(selectCount);
/**
* 输出:
==> Preparing: SELECT COUNT(1) FROM user WHERE name IS NOT NULL
==> Parameters:
<== Columns: COUNT(1)
*/
}
?
/**
* 测试
* in() 等同于 IN (?,?)
* notIn() 等同于 NOT IN (?,?)
* inSql() 等同于 IN (sql)
* notInSql() 等同于 NOT IN (sql)
*/
public void abstractWrapperTest_in() {
QueryWrapper<User> userQueryWrapper = new QueryWrapper<>();
List<Long> idLists = new ArrayList<>();
idLists.add(11L);
idLists.add(13L);
userQueryWrapper
// .in("id",idLists);
.inSql("id","select id from user where id<=15");
List<User> userList = userMapper.selectList(userQueryWrapper);
userList.forEach(System.out::println);
/**
* 输出:
==> Preparing: SELECT id,name,age,email FROM user WHERE id IN (select id from user where id<=15)
==> Parameters:
*/
}
?
/**
* 测试
* groupBy() .. 支持多参数 等同于 GROUP BY age,name,id
*/
public void abstractWrapperTest_group() {
QueryWrapper<User> userQueryWrapper = new QueryWrapper<>();
userQueryWrapper
.groupBy("age","name","id");
List<User> userList = userMapper.selectList(userQueryWrapper);
userList.forEach(System.out::println);
/**
* 输出:
==> Preparing: SELECT id,name,age,email FROM user GROUP BY age,name,id
==> Parameters:
*/
}
?
/**
* 测试
* orderBy() .. 支持多参数 等同于 关于 condition
* orderByDesc() .. 支持多参数 等同于 ORDER BY age DESC , id DESC
* orderByAsc() .. 支持多参数 等同于 ORDER BY age ASC , id ASC
*/
public void abstractWrapperTest_order() {
QueryWrapper<User> userQueryWrapper = new QueryWrapper<>();
userQueryWrapper
.orderByAsc("age","id");
List<User> userList = userMapper.selectList(userQueryWrapper);
userList.forEach(System.out::println);
/**
* 输出:
==> Preparing: SELECT id,name,age,email FROM user ORDER BY age ASC , id ASC
==> Parameters:
*/
}
?
/**
* 测试
* having() .. 支持多参数 等同于 HAVING sum(id)> ?
*/
public void abstractWrapperTest_having() {
QueryWrapper<User> userQueryWrapper = new QueryWrapper<>();
userQueryWrapper
.groupBy("age")
.having("sum(id)>{0}",20);// 替换里面的参数
List<User> userList = userMapper.selectList(userQueryWrapper);
userList.forEach(System.out::println);
/**
* 输出:
==> Preparing: SELECT id,name,age,email FROM user GROUP BY age HAVING sum(id)>?
==> Parameters: 20(Integer)
*/
}
?
/**
* 测试
* or() 等同于 or
* and() 等同于 and
*/
public void abstractWrapperTest_or_and() {
// 简单 or 和and
QueryWrapper<User> userQueryWrapper = new QueryWrapper<>();
userQueryWrapper
.eq("id",11)
.or() // 默认and()
// .and() // 两个不能连用
.eq("id",13);
List<User> userList = userMapper.selectList(userQueryWrapper);
userList.forEach(System.out::println);
/**
* 输出:
==> Preparing: SELECT id,name,age,email FROM user WHERE id = ? OR id = ?
==> Parameters: 11(Integer), 13(Integer)
*/
?
// 嵌套的 or 和and
QueryWrapper<User> userQueryWrapper1 = new QueryWrapper<>();
userQueryWrapper1
.eq("id",14)
.or(i -> i.eq("name", "Lynwood").ne("age", "18"));
List<User> userList1 = userMapper.selectList(userQueryWrapper1);
userList1.forEach(System.out::println);
/**输出:
*
* ==> Preparing: SELECT id,name,age,email FROM user WHERE id = ? OR ( name = ? AND age <> ? )
* ==> Parameters: 14(Integer), Lynwood(String), 18(String)
*/
/**!!!!!!!!!!!! .or(i -> i.eq("name", "Lynwood").ne("age", "18")); 解释 见下文发现问题*/
}
?
/**
* 测试
* apply() 动态传参防止 sql注入 占位符 替换 以值的形式添加
*/
public void abstractWrapperTest_apply() {
QueryWrapper<User> userQueryWrapper = new QueryWrapper<>();
userQueryWrapper
.apply("id>{0}",13);
List<User> userList = userMapper.selectList(userQueryWrapper);
userList.forEach(System.out::println);
/**
* 输出:
==> Preparing: SELECT id,name,age,email FROM user WHERE id>?
==> Parameters: 13(Integer)
*/
}
?
/**
* 测试
* last() 在sql 最后追加
*
* 最常用 last("limit 1")
*/
public void abstractWrapperTest_last() {
QueryWrapper<User> userQueryWrapper = new QueryWrapper<>();
userQueryWrapper
.last("limit 2");
List<User> userList = userMapper.selectList(userQueryWrapper);
userList.forEach(System.out::println);
/**
* 输出:
==> Preparing: SELECT id,name,age,email FROM user limit 2
==> Parameters:
*/
}
?
/**
* 测试
* exists() 拼接 EXISTS ( sql语句 )
* notExists() 拼接 NOT EXISTS ( sql语句 )
*/
public void abstractWrapperTest_exists() {
QueryWrapper<User> userQueryWrapper = new QueryWrapper<>();
userQueryWrapper
.exists("SELECT id,name,age,email FROM user where id= 222");
List<User> userList = userMapper.selectList(userQueryWrapper);
userList.forEach(System.out::println);
/**
* 输出:
==> Preparing: SELECT id,name,age,email FROM user WHERE EXISTS (SELECT id,name,age,email FROM user where id= 222)
==> Parameters:
<== Total: 0
*/
}
?
/**
* 测试
* nested() 正常嵌套 (无 or and 模式嵌套)
*/
public void abstractWrapperTest_nested() {
QueryWrapper<User> userQueryWrapper = new QueryWrapper<>();
userQueryWrapper
.nested(i -> i.eq("name", "Lynwood").eq("age", "18"));
List<User> userList = userMapper.selectList(userQueryWrapper);
userList.forEach(System.out::println);
/**
* 输出:
==> Preparing: SELECT id,name,age,email FROM user WHERE ( name = ? AND age = ? )
==> Parameters: Lynwood(String), 18(String)
*/
}
}
?
boolean condition
、R column
和 Function<This, This> func
三个参数相关问题boolean condition
- 以下出现的第一个入参
boolean condition
表示该条件是否加入最后生成的sql中,默认是true
使用ne()
方法举例 源码 :
xxxxxxxxxx
public This ne(boolean condition, R column, Object val) {
return addCondition(condition, column, NE, val);
}
测试编写:
xxxxxxxxxx
/**
* 测试 boolean condition
*/
public void abstractWrapperTest_Condition() {
Integer age = new Random().nextInt(25);
System.out.println("年龄: " + age);
QueryWrapper<User> userQueryWrapper = new QueryWrapper<>();
boolean condition = age<=18;
userQueryWrapper.ne(condition,"name","Lynwood");
List<User> userList = userMapper.selectList(userQueryWrapper);
userList.forEach(System.out::println);
}
生成的随机数age 小于18岁的 不要让他查到name="Lynwood"
的信息
再此看来等同于*mapper.xml
配置
xxxxxxxxxx
WHERE 1=1
<if test="age <= 18">
AND name <> #{name}
</if>
帮我们提入到了每个方法中,并且省去我们关系 是否写AND
关键字或者 必须有 WHERE 1=1
这些难看却又不必要的配置
R column
- 以下方法在入参中出现的
R
为泛型,在普通wrapper中是String
,在LambdaWrapper中是函数(例:Entity::getId
,Entity
为实体类,getId
为字段id
的getMethod)- 以下方法入参中的
R column
均表示数据库字段,当R
为String
时则为数据库字段名(字段名是数据库关键字的自己用转义符包裹!)!而不是实体类数据字段名!!!
查看源码 发现实际上 eq()、ne()...
等需要传入R column
的方法实际最后都是调用了addCondition(...)
方法
对 R column
参数做了 columnToString(column)
操作
而 AbstractWrapper
实际中的此方法是抽象的:
xxxxxxxxxx
/**
* 获取 columnName
*/
protected abstract String columnToString(R column);
而我们再去查看我们使用的 QueryWrapper
与UpdateWrapper
中的具体实现都为:
xxxxxxxxxx
protected String columnToString(String column) {
return column;
}
实际上是转换成了String
类型, 那么为什么使用了泛型呢?
我们再返回去查看他的另一个实现类AbstractLambdaWrapper
中的实现:
xxxxxxxxxx
protected String columnToString(SFunction<T, ?> column) {
return getColumn(LambdaUtils.resolve(column));
}
原来这里使用泛型 为了扩展Lambda方式使用!
lambda
- 获取
LambdaWrapper
在QueryWrapper
中是获取LambdaQueryWrapper
在UpdateWrapper
中是获取LambdaUpdateWrapper
测试:
xxxxxxxxxx
/**
* 测试 R column
*/
public void abstractWrapperTest_Column() {
QueryWrapper<User> userQueryWrapper = new QueryWrapper<>();
// userQueryWrapper.ne("name","Lynwood");
userQueryWrapper.lambda().eq(User::getName,"Lynwood");
List<User> userList = userMapper.selectList(userQueryWrapper);
userList.forEach(System.out::println);
}
?
Function<This, This> func
其实再测试AbstractWrapper中的 or/and 嵌套中已经使用过了
以or()
举例
需要传入的是 Function
的实现 而Function
的定义是:
xxxxxxxxxx
/**
* Represents a function that accepts one argument and produces a result.
*表示接受一个参数执行生成结果的函数对象。
* @since 1.8
*/
public interface Function<T, R> {
在我们使用过程中 往往是为了嵌套 我们传入的可能是另一个Wrapper 让他和当前的Wrapper去链接/嵌套起来
那么在:
xxxxxxxxxx
userQueryWrapper.ne("name","Lynwood")
.or(i -> i.eq("age", "18"));
中 我们实际上传入了一个匿名的Wrapper对象,那么这个匿名的Wrapper对象怎么符合了Function的要求呢
我们查看这个i
变量 :
他的类型是与调用对象一致的 查看 QueryWrapper<User>
的继承关系:
实际上我们使用的所有接口都去间接继承了ISqlSegment
接口 ,而它:
xxxxxxxxxx
package com.baomidou.mybatisplus.core.conditions;
public interface ISqlSegment extends Serializable {
?
是被@FunctionalInterface 标识的 与:
xxxxxxxxxx
package java.util.function;
public interface Function<T, R> {
是一样的, 所以我们使用它可以这样简便的使用啦:
测试:
xxxxxxxxxx
public void abstractWrapperTest_Func() {
QueryWrapper<User> userQueryWrapper = new QueryWrapper<>();
userQueryWrapper.ne("name","Lynwood");
userQueryWrapper.or(new Function<QueryWrapper<User>, QueryWrapper<User>>() {
public QueryWrapper<User> apply(QueryWrapper<User> userQueryWrapper) {
return userQueryWrapper.eq("age", "18");
}
});
// 等同与
// userQueryWrapper.ne("name","Lynwood")
// .or(i -> i.eq("age", "18"));
List<User> userList = userMapper.selectList(userQueryWrapper);
userList.forEach(System.out::println);
}
其实在上面的所有测试中其返回值都是完全的装配到了实体对象中,但是有的时候 比如有个字段很大 很消耗内存,同时也用不到,那么我如何把他取消掉.设置返回值为我们需要的几个字段就好
select()
测试
lambda()
使用 lambda特性时!xxxxxxxxxx
/**
* 测试 QueryWrapper.select()
*
*/
public void abstractWrapperTest_Select() {
QueryWrapper<User> userQueryWrapper = new QueryWrapper<>();
// userQueryWrapper.eq("age",18)
// .select("id","name");
userQueryWrapper.eq("age",18)
.select(User.class,i -> false);//只返回id
List<User> userList = userMapper.selectList(userQueryWrapper);
// SELECT id FROM user WHERE age = ?
userList.forEach(System.out::println);
?
//前方有坑 注意: 注意!!!!!!!!!!!
?
//关于LambdaQueryWrapper的使用这样用是没问题的
LambdaQueryWrapper<User> lambdaQueryWrapper = new QueryWrapper<User>().lambda();
lambdaQueryWrapper.select(User::getId,User::getAge);
List<User> userList1 = userMapper.selectList(lambdaQueryWrapper);
//SELECT id,age FROM user
userList1.forEach(System.out::println);
?
// 这样设置是无效的!!!!
QueryWrapper<User> userQueryWrapper2 = new QueryWrapper<>();
userQueryWrapper2.lambda().select(User::getId,User::getAge);
List<User> userList2 = userMapper.selectList(userQueryWrapper2);
// SELECT id,name,age,email FROM user
userList2.forEach(System.out::println);
}
?
set() setSql()
测试
xxxxxxxxxx
/**
* 测试 UpdateWrapper.set()
* 测试 UpdateWrapper.setSql()
*/
public void abstractWrapperTest_Set() {
UpdateWrapper<User> userUpdateWrapper = new UpdateWrapper<>();
// 更新id==11 的age 为19
userUpdateWrapper.set("age",19).eq("id",11);
// 附加更新内容 name 设置
User user = new User();
user.setName("Lynwood1");
userMapper.update(user,userUpdateWrapper);
/**
* ==> Preparing: UPDATE user SET name=?, age=? WHERE id = ?
* ==> Parameters: Lynwood1(String), 19(Integer), 11(Integer)
* <== Updates: 1
*/
?
UpdateWrapper<User> userUpdateWrapper1 = new UpdateWrapper<>();
userUpdateWrapper1.setSql("name=‘wunian7yulian‘").eq("id",11);
// 附加更新内容为空时 不能传入null 需要传入空实体对象
userMapper.update(new User(),userUpdateWrapper1);
/**
* ==> Preparing: UPDATE user SET name=‘wunian7yulian‘ WHERE id = ?
* ==> Parameters: 11(Integer)
* <== Updates: 1
*/
}
https://github.com/wunian7yulian/MybatisPlusDemo/tree/master/mp_plugin_demo
初始化:
因为下面演示需要其他字段,所以重新创建一个便于Demo的合适的表格:
xxxxxxxxxx
-- 创建简单表格
DROP TABLE IF EXISTS user;
?
CREATE TABLE `user` (
`id` bigint(20) PRIMARY KEY AUTO_INCREMENT COMMENT ‘主键ID‘,
`name` varchar(30) DEFAULT NULL COMMENT ‘姓名‘,
`age` int(11) DEFAULT NULL COMMENT ‘年龄‘,
`email` varchar(50) DEFAULT NULL COMMENT ‘邮箱‘
) ENGINE=InnoDB DEFAULT CHARSET=utf8;
?
INSERT INTO user ( name, age, email) VALUES
(‘Jone‘, 18, ‘test1@test.com‘),
(‘Jack‘, 20, ‘test2@test.com‘),
(‘Tom‘, 28, ‘test3@test.com‘),
(‘Sandy‘, 21, ‘test4@test.com‘),
(‘Billie‘, 24, ‘test5@test.com‘),
(‘Lynwood‘, 18, ‘wunian_@hotmail.com‘);
xxxxxxxxxx
spring
datasource
driver-class-name com.mysql.jdbc.Driver
url jdbc mysql //127.0.0.1 3306/mp_demo_db?characterEncoding=utf-8
username root
password123456
?
mybatis-plus
global-config
db-config
id-type auto
configuration
log-impl org.apache.ibatis.logging.stdout.StdOutImpl
之前做列表或者报表功能时使用最多的是pageHelper
插件做Mybatis的分页查询,MP为了方便将分页做了一个相关的模块com.baomidou.mybatisplus.extension.plugins.pagination
供我们分页查询时去使用.
在business目录下创建config目录 并在该目录下创建MybatisPlusConfig.java
添加@Configuration
注解声明
xxxxxxxxxx
public class MybatisPlusConfig {
}
xxxxxxxxxx
public class MybatisPlusConfig {
public PaginationInterceptor paginationInterceptor() {
return new PaginationInterceptor();
}
}
xxxxxxxxxx
?
SpringRunner.class) (
public class MpPluginDemoApplicationTests {
private UserMapper userMapper;
/**
* 测试分页插件
*/
public void test_page() {
IPage<User> userIPage = userMapper.selectPage(
new Page<User>()
.setCurrent(1) //设置当前查询页
.setSize(3) // 设置每页条数
.setDesc("age"),//使用page 进行排序
new QueryWrapper<User>()
.lambda()
.likeRight(User::getEmail, "test")
.select(User::getId, User::getName, User::getAge)
);
?
List<User> records = userIPage.getRecords();
records.forEach(System.out::println);
/**
* ==> Preparing: SELECT id,name,age FROM user WHERE email LIKE ? ORDER BY age DESC LIMIT ?,?
* ==> Parameters: test%(String), 0(Long), 3(Long)
*/
}
}
?
完美! 不过因为page
对象在3.0.6
版本还没有支持lambda方式 page上在设置排序字段时 还是会有一些魔法值出现,不过我们也是可以直接将 排序 写在wrapper里的. 有强迫症的童鞋等待3.1.0
版本吧.
xxxxxxxxxx
spring
datasource
driver-class-name com.mysql.jdbc.Driver
url jdbc mysql //127.0.0.1 3306/mp_demo_db?characterEncoding=utf-8
username root
password123456
?
mybatis-plus
global-config
db-config
id-type auto
logic-delete-value 1 # 逻辑已删除值(默认为 1)
logic-not-delete-value 0 # 逻辑未删除值(默认为 0)
configuration
log-impl org.apache.ibatis.logging.stdout.StdOutImpl
在MybatisPlusConfig中添加插件bean
xxxxxxxxxx
public class MybatisPlusConfig {
...
public ISqlInjector sqlInjector() {
return new LogicSqlInjector();
}
}
在User
中的 del字段上添加@TableLogic
注解
xxxxxxxxxx
callSuper = false) (
chain = true) (
public class User implements Serializable {
...
/**
* 逻辑删除 0-未删除 1-删除
*/
private Integer del;
...
}
xxxxxxxxxx
/**
* 测试逻辑删除插件
*/
public void test_logic_delete() {
userMapper.delete(new QueryWrapper<User>()
.lambda()
.notLike(User::getEmail, "test")
.select(User::getId, User::getName, User::getAge));
/**
* ==> Preparing: UPDATE user SET del=1 WHERE del=0 AND email NOT LIKE ?
* ==> Parameters: %test%(String)
*/
//那么查询呢?
List<User> userList = userMapper.selectList(null);
userList.forEach(System.out::println);
//发现查询也帮我们设置了过滤字段 del = 0
/**
* ==> Preparing: SELECT id,name,age,email,del,version FROM user WHERE del=0
* ==> Parameters:
*/
?
//那么我想查出这个删除的用户 更改为 正常呢?
List<Map<String, Object>> mapList = userMapper.selectMaps(
new QueryWrapper<User>()
.lambda()
.eq(User::getDel, 1)
.select(User.class,i -> false)
);
Assert.assertNotNull(mapList);
Assert.assertEquals(mapList.size(),1);
/** select id from user where del = 0 and del = 1
* java.lang.AssertionError:
* Expected :0
* Actual :1
*/
// 失败了
//
?
}
询问MP开发者后 开发者说明 因为大部分情况在删除之后不会恢复 所以没有设定相关恢复或者跳过 当前 筛选的 接口
当要更新一条记录的时候,希望这条记录没有被别人更新
特别说明:
newVersion = oldVersion + 1
newVersion
会回写到 entity
中updateById(id)
与 update(entity, wrapper)
方法乐观锁实现方式:
1、配置乐观锁插件:
在MybatisPlusConfig
添加:
xxxxxxxxxx
public OptimisticLockerInterceptor optimisticLockerInterceptor() {
return new OptimisticLockerInterceptor();
}
2、添加乐观锁版本字段注解:
xxxxxxxxxx
callSuper = false) (
chain = true) (
public class User implements Serializable {
...
/**
* 乐观锁版本字段
*/
private Integer version;
}
3、编写测试类:
xxxxxxxxxx
/**
* 测试乐观锁插件
*/
public void test_Optimistic_Locking() throws InterruptedException {
User oldUser = userMapper.selectById(1);
oldUser.setAge(19);
System.out.println("模拟中途有人更改"+ "begin....");
Thread.sleep(10000);
System.out.println("模拟中途有人更改"+ "end....");
if(userMapper.updateById(oldUser)==1){
System.out.println("success \n"+ oldUser);
//success
//User(id=1, name=Jone, age=19, email=test1@test.com, del=0, version=2)
}else {
System.out.println("fail \n");
//==> Preparing: UPDATE user SET name=?, age=?, email=?, version=? WHERE id=? AND version=? AND del=0
//==> Parameters: Jone(String), 19(Integer), test1@test.com(String), 3(Integer), 1(Long), 2(Integer)
//<== Updates: 0
//fail
}
}
其他插件 如 热加载等 如有需要 再做更新
MP优秀于简化了Mybatis大部分XML配置 将他归总到起来生成一个强大的Wrapper
现有MP也是有了两个版本大的版本2.x与3.x ,酌情使用比较合理 3.x虽然有了Lambda的支持但是还不完善,
后续版本的更新应该也会去查漏现版本的缺陷.
对于插件,像乐观锁分页逻辑删真的是贴心,不过也有相对应场景不适用问题,比如上面说到的逻辑删除的我还要查是查不到的,还是需要去自定义sql的
我相信 有了mp这种强大的利器,对于一个微型项目 或者微服务 来说真的是爽,写起来真的是非常有效率
个人--
作为头一个被我收拾的应用层框架,看到了开发者的用心和初心, 看来排上名并不是那么绝非偶然,也并非那么"功力深厚",只要你有想法开始做,总有一个好的结果.
下一框架寻找中...
MyBatis-Plus 官方文档 : https://mp.baomidou.com/
MyBatis-Plus 配置进阶 : https://mp.baomidou.com/config/
MyBatis-Plus 代码生成器配置 : https://mp.baomidou.com/config/generator-config.html
MyBatis-Plus sql注入原理 : https://www.liangzl.com/get-article-detail-19831.html
Mybatis-Plus 使用全解 : https://www.jianshu.com/p/7299cba2adec
Mybatis-Plus的填坑之路 - Lynwood/wunian7yulian
标签:tooltip row record .net pad generator prope 搭建 error
原文地址:https://www.cnblogs.com/wunian7yulian/p/10276219.html