MybatisPlus 基础
1、MybatisPlus简介
MyBatis-Plus(简称 MP)是一个 MyBatis的增强工具,在 MyBatis 的基础上只做增强不做改变,为简化开发、提高效率而生。
特性:
无侵入、损耗小
强大的 CRUD 操作:内置通用 Mapper、通用 Service,仅仅通过少量配置即可实现单表大部分CRUD 操作,更有强大的条件构造器,满足各类使用需求
支持 Lambda 形式调用:通过 Lambda 表达式,方便的编写各类查询条件,无需再担心字段写错
支持主键自动生成:支持多达 4 种主键策略(内含分布式唯一 ID 生成器 - Sequence),可自由配置,完美解决主键问题
支持 ActiveRecord 模式:支持 ActiveRecord 形式调用,实体类只需继承 Model 类即可进行强大的 CRUD 操作
支持自定义全局通用操作:支持全局通用方法注入( Write once, use anywhere )
内置代码生成器:采用代码或者 Maven 插件可快速生成 Mapper 、 Model 、 Service 、Controller 层代码,支持模板引擎,更有超多自定义配置等您来使用
内置分页插件:基于 MyBatis 物理分页,开发者无需关心具体操作,配置好插件之后,写分页等同于普通 List 查询
分页插件支持多种数据库:支持 MySQL、MariaDB、Oracle、DB2、H2、HSQL、SQLite、Postgre、SQLServer 等多种数据库
内置性能分析插件:可输出 SQL 语句以及其执行时间,建议开发测试时启用该功能,能快速揪出慢查询
内置全局拦截插件:提供全表 delete 、 update 操作智能分析阻断,也可自定义拦截规则,预防误操作
支持数据库:
MySQL,Oracle,DB2,H2,HSQL,SQLite,PostgreSQL,SQLServer,Phoenix,Gauss ,
ClickHouse,Sybase,OceanBase,Firebird,Cubrid,Goldilocks,csiidb
达梦数据库,虚谷数据库,人大金仓数据库,南大通用(华库)数据库,南大通用数据库,神通数据
库,瀚高数据库
框架结构:
代码文档地址:
官方地址: http://mp.baomidou.com
代码发布地址:
Github: https://github.com/baomidou/mybatis-plus
Gitee: https://gitee.com/baomidou/mybatis-plus
文档发布地址: https://baomidou.com/pages/24112f
2、入门案例
1、创建、配置springboot工程
加入依赖:
<dependencies>
<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>com.baomidou</groupId>
<artifactId>mybatis-plus-boot-starter</artifactId>
<version>3.5.2</version>
</dependency>
<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
<optional>true</optional>
</dependency>
<dependency>
<groupId>com.mysql</groupId>
<artifactId>mysql-connector-j</artifactId>
<version>8.0.32</version>
</dependency>
</dependencies>
<build>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
</plugin>
</plugins>
</build>
配置数据源:
spring:
#配置数据源
datasource:
#数据源类型
type: com.zaxxer.hikari.HikariDataSource
#各个信息
driver-class-name: com.mysql.cj.jdbc.Driver
url: jdbc:mysql://localhost:3306/mybatis_plus?serverTimezone=GMT%2B8&characterEncoding=utf-8&useSSL=false
username: root
password: root
2、创建实体类
@Data
public class User {
private Long id;
private String name;
private Integer age;
private String email;
}
@Data注解:导入lombok依赖,在实体类上添加@Data注解,直接生成对应的get,set,有参,无参,equals,hashcode方法
3、创建mapper
public interface UserMapper extends BaseMapper<User> {
}
BaseMapper是MyBatis-Plus提供的模板mapper,其中**包含了基本的CRUD方法,泛型为操作的实体类型 **
4、测试
创建测试类
Wrapper:条件构造器,当查询时有条件可以创建Wrapper对象,如果没有就设置null为参数
@SpringBootTest
public class MybatisPlusTest {
@Autowired
UserMapper userMapper;//运行时,mapperScan扫描mapper接口会创建代理实现类,并放入IOC容器中,编译阶段的报错可以忽略
//可以通过在Mapper上添加@Repository注解(持久层注解)消除报错
@Test
public void testSelectList(){
//selectList方法中传入Wrapper
//Wrapper:条件构造器,当查询时有条件可以创建Wrapper对象,如果没有就设置null为参数
List<User> list = userMapper.selectList(null);
list.forEach(System.out::println);
}
}
添加日志:
在application.yml中配置日志输出
## 配置MyBatis日志
mybatis-plus:
configuration:
log-impl: org.apache.ibatis.logging.stdout.StdOutImpl
3、基本CRUD
1、BaseDAO
mapper接口继承了BaseDAO,查看BaseDAO的源码(下载源码)
MyBatis-Plus中的基本CRUD在内置的BaseMapper中都已得到了实现,我们可以直接使用
2、插入
mapper.insert(对象)
@Test
public void testInsert(){
//新增用户信息
User user = new User();
user.setName("ZS");
user.setAge(23);
user.setEmail("123@qq.com");
//insert into user (id,name,age,email) values (?,?,?,?)
int result = userMapper.insert(user);
System.out.println("result:"+result);
System.out.println("id:"+user.getId());
}
3、删除
mapper.deleteById(id) 根据id删除
mapper.deleteByMap(map) 根据map中对应的条件删除
mapper.deleteBatchIds(list) 根据list中所有的id删除
@Test
public void testDelete(){
//通过id删除用户信息
//delete from user where id=?
int result = userMapper.deleteById(1630444150786678785L);
System.out.println("result:"+result);
//根据map集合中设置的条件删除数据
//delete from user where name=? and age=?
Map<String,Object> map = new HashMap<>();
map.put("name","ZS");
map.put("age",23);
int res = userMapper.deleteByMap(map);
System.out.println("result:"+res);
//通过多个id进行批量删除
List<Long> list = Arrays.asList(1L, 2L, 3L);
userMapper.deleteBatchIds(list);
}
4、更新
mapper.updateById(对象) 根据对象的id更新数据,null值不做修改
@Test
public void testUpdate(){
//修改用户信息
//update user set name=?,email=? where id=?
User user = new User();
user.setId(4L);
user.setName("李四");
int result = userMapper.updateById(user);
System.out.println("result:"+result);
}
5、查找
mapper.selectById(id) 根据id查询用户信息
mapper.selectBatchIds(list) 根据list中的值查询用户信息
mapper.selectByMap(map) 根据map中的条件查询用户信息
mapper.selectList(null) 根据wrapper查询用户信息,如果为null表示所有的
@Test
public void testSelect(){
//通过id查询用户信息
//select id,name,age,email, from user where id=?
User user = userMapper.selectById(1L);
System.out.println(user);
//根据多个id查询多个信息
//select id,name,age,email from user where id in(?,?,?)
List<Long> list = Arrays.asList(1L, 2L, 3L);
List<User> users = userMapper.selectBatchIds(list);
users.forEach(System.out::println);
//根据map集合中的条件查询用户信息
//select id,name,age,email form user where name=? and age=?
Map<String,Object> map = new HashMap<>();
map.put("name","Jack");
map.put("age",20);
List<User> lists = userMapper.selectByMap(map);
lists.forEach(System.out::println);
//select * from user
List<User> list1 = userMapper.selectList(null);//如果修改器为null表示为所有的
list1.forEach(System.out::println);
//自定义功能
//select id,name,age,email from user where id = ?
Map<String, Object> map1 = userMapper.selectMapById(1L);
System.out.println(map1);
}
自定义功能:
在mapper接口中新建抽象方法,在resources文件夹下新建mapper文件夹,创建映射文件XXXMapper.xml,编写sql语句
6、通用Service
MyBatis-Plus中有一个接口IService和其实现类ServiceImpl,封装了常见的业务层逻辑。详情查看源码IService和ServiceImpl
通用 Service CRUD 封装IService接口,进一步封装 CRUD 采用 get 查询单行 remove 删
除 list 查询集合 page 分页 前缀命名方式区分 Mapper 层避免混淆(方法名与mapper调用的方法名不同)
泛型 T 为任意实体对象
建议如果存在自定义通用 Service 方法的可能,请创建自己的 IBaseService 继承Mybatis-Plus 提供的基类
举例:
创建UserService接口继承IService接口,IServie泛型填写对应实体类
编写UserService接口的实现类UserServiceImpl继承ServiceImpl实现UserService接口
ServiceImpl泛型编写mapper和对应的实体类
由于ServiceImpl实现了IService接口,因此UserServiceImpl不需要实现IService的方法
在UserServiceImol上添加**@Service注解**
代码示例:
public interface UserService extends IService<User> {
}
@Service
public class UserServiceImpl extends ServiceImpl<UserMapper, User> implements UserService {
}
@SpringBootTest
public class MybatisPlusServiceTest {
@Autowired
private UserService userService;
@Test
public void testGetCount(){
//查询总记录数
//select count(*) from user
long count = userService.count();
System.out.println("总记录数:"+count);
}
@Test
public void testInsertMore(){
List<User> list = new ArrayList<>();
for (int i = 0; i < 10; i++) {
User user = new User();
user.setName("abc" + i);
user.setAge(20 + i);
list.add(user);
}
//INSERT INTO user ( id, name, age ) VALUES ( ?, ?, ? )
boolean b = userService.saveBatch(list);
System.out.println(b);
}
}
4、常用注解
1、@TableName
由此得出结论,MyBatis-Plus在确定操作的表时,由BaseMapper的泛型决定,即实体类型决定,且**默认操作的表名和实体类型的类名一致 **
如果实体类类名与表名不一致,可以在实体类上标注**@TableName("")**注解,标识实体类对应的表
如果所有表名都含有相同的前缀,可以使用MyBatis-Plus提供的全局配置,为实体类所对应的表名设置默认的前缀
mybatis-plus:
configuration:
# 配置MyBatis日志
log-impl: org.apache.ibatis.logging.stdout.StdOutImpl
global-config:
db-config:
# 配置MyBatis-Plus操作表的默认前缀
table-prefix: t_
2、@TableId
MyBatis-Plus在实现CRUD时,会默认将id作为主键列,并在插入数据时,默认基于雪花算法的策略生成id
如果表的主键字段名不为id,crud会出现错误
因此可以在实体类中uid属性上通过**@TableId将其标识为主键**,即可成功执行SQL语句
@TableId的value属性
若实体类中主键对应的属性为id,而表中表示主键的字段为uid,此时若只在属性id上添加注解@TableId,则抛出异常Unknown column 'id' in 'field list',即MyBatis-Plus仍然会将id作为表的主键操作,而表中表示主键的是字段uid
@Data
public class User{
//将属性所对应的字段指定为主键
//@TableId注解的value属性用于指定主键的字段
@TableId(value="uid")
private Long id;
}
@TableId的type属性
type属性用来定义主键策略
常用的主键策略:
值 | 描述 |
---|---|
IdType.ASSIGN_ID(默 认) | 基于雪花算法的策略生成数据id,与数据库id是否设置自增无关 |
IdType.AUTO | 使用数据库的自增策略,注意,该类型请确保数据库设置了id自增, 否则无效 |
@Data
public class User{
//将属性所对应的字段指定为主键
//@TableId注解的value属性用于指定主键的字段
//@TableId注解的IdType属性用于指定主键生成策略
@TableId(value = "uid",type = IdType.AUTO)
private Long id;
}
配置全局主键策略:
mybatis-plus:
configuration:
# 配置MyBatis日志
log-impl: org.apache.ibatis.logging.stdout.StdOutImpl
global-config:
db-config:
# 配置MyBatis-Plus操作表的默认前缀
table-prefix: t_
# 配置MyBatis-Plus的主键策略
id-type: auto
雪花算法:
背景:需要选择合适的方案去应对数据规模的增长,以应对逐渐增长的访问压力和数据量。数据库的扩展方式主要包括:业务分库、主从复制,数据库分表。
数据库分表:
将不同业务数据分散存储到不同的数据库服务器,能够支撑百万甚至千万用户规模的业务,但如果业务继续发展,同一业务的单表数据也会达到单台数据库服务器的处理瓶颈。例如,淘宝的几亿用户数据,如果全部存放在一台数据库服务器的一张表中,肯定是无法满足性能要求的,此时就需要对单表数据进行拆分。
单表数据拆分有两种方式:垂直分表和水平分表。
垂直分表:垂直分表适合将表中某些不常用且占了大量空间的列拆分出去。
水平分表:水平分表适合表行数特别大的表,有的公司要求单表行数超过 5000 万就必须进行分表,这个数字可以作为参考,但并不是绝对标准,关键还是要看表的访问性能。对于一些比较复杂的表,可能超过 1000万就要分表了;而对于一些简单的表,即使存储数据超过 1 亿行,也可以不分表。但不管怎样,当看到表的数据量达到千万级别时,作为架构师就要警觉起来,因为这很可能是架构的性能瓶颈或者隐患。
水平分表相比垂直分表,会引入更多的复杂性,例如要求全局唯一的数据id该如何处理 :
①主键自增
②取模
③雪花算法
雪花算法是由Twitter公布的分布式主键生成算法,它能够保证不同表的主键的不重复性,以及相同表的主键的有序性。
1、核心思想:
长度共64bit(一个long型)。
首先是一个符号位,1bit标识,由于long基本类型在Java中是带符号的,最高位是符号位,正数是0,负数是1,所以id一般是正数,最高位是0。41bit时间截(毫秒级),存储的是时间截的差值(当前时间截 - 开始时间截),结果约等于69.73年。
10bit作为机器的ID(5个bit是数据中心,5个bit的机器ID,可以部署在1024个节点)。
12bit作为毫秒内的流水号(意味着每个节点在每毫秒可以产生 4096 个 ID)。
2、优点:整体上按照时间自增排序,并且整个分布式系统内不会产生ID碰撞,并且效率较高。
3、@TableField
**MyBatis-Plus会自动将下划线命名风格转化为驼峰命名风格 **,所以无需手动开启驼峰转换
若实体类中的属性和表中的字段不同且也不是下划线、驼峰风格,此时需要在实体类属性上使用**@TableField("")**设置属性所对应的字段名
例如实体类属性name,表中字段username :
@TableField("username")
private String name
4、@TableLogic
物理删除:真实删除,将对应数据从数据库中删除,之后查询不到此条被删除的数据
逻辑删除:假删除,将对应数据中代表是否被删除字段的状态修改为“被删除状态”,之后在数据库中仍旧能看到此条数据记录
使用场景:可以进行数据恢复
实现逻辑删除:
①数据库中创建逻辑删除状态列,设置默认值为0
②实体类中添加逻辑删除属性
③测试
测试删除功能,真正执行的是修改
UPDATE t_user SET is_deleted=1 WHERE id=? AND is_deleted=0
测试查询功能,被逻辑删除的数据默认不会被查询
SELECT id,username AS name,age,email,is_deleted FROM t_user WHERE is_deleted=0
5、条件构造器和常用接口
1、Wrapper介绍
wrapper可以链式添加规则
Wrapper : 条件构造抽象类,最顶端父类
AbstractWrapper : 用于查询条件封装,生成 sql 的 where 条件
QueryWrapper : 查询条件封装
UpdateWrapper : Update 条件封装
AbstractLambdaWrapper : 使用Lambda 语法
LambdaQueryWrapper :用于Lambda语法使用的查询Wrapper
LambdaUpdateWrapper : Lambda 更新封装Wrapper
创建新的Wrapper对象,泛型为对应的实体类,给Wrapper添加条件,通过自动注入的mapper对象调用方法,执行wrapper条件
2、QueryWrapper
创建测试类,注入userMapper
①组装查询条件:
@Test
public void test01(){
//查询用户名包含a,年龄在20到30之间,邮箱信息不为null的用户信息
QueryWrapper<User> queryWrapper = new QueryWrapper<>();
queryWrapper.like("name","a")
.between("age",20,30)
.isNotNull("email");
List<User> users = userMapper.selectList(queryWrapper);
users.forEach(System.out::println);
}
②组装排序条件
@Test
public void test02(){
//查询用户信息,按照年龄降序排序,若年龄相同,按照id升序排序
QueryWrapper<User> queryWrapper = new QueryWrapper<>();
queryWrapper.orderByDesc("age").orderByAsc("id");
List<User> list = userMapper.selectList(queryWrapper);
list.forEach(System.out::println);
}
③组装删除条件
@Test
public void test03(){
//删除邮箱为null的用户
QueryWrapper<User> queryWrapper = new QueryWrapper<>();
queryWrapper.isNull("email");
int result = userMapper.delete(queryWrapper);
System.out.println(result);
}
④条件的优先级
@Test
public void test04(){
//将年龄大于20并用户名中包含a 或 邮箱为null的用户信息修改
QueryWrapper<User> queryWrapper = new QueryWrapper<>();
queryWrapper.gt("age",20).like("name","a")
.or().isNull("email");
User user = new User();
user.setName("aaa");
user.setEmail("12345@aa.com");
int result = userMapper.update(user, queryWrapper);
System.out.println(result);
}
@Test
public void test05(){
//将年龄大于20 并 用户名中包含a或邮箱为null的用户信息修改
//lambda中的条件优先执行
QueryWrapper<User> queryWrapper = new QueryWrapper<>();
queryWrapper.like("name","a")
.and(i->i.gt("age",20).or().isNull("email"));
User user = new User();
user.setName("bbb");
user.setEmail("12345@aa.com");
int result = userMapper.update(user, queryWrapper);
System.out.println(result);
}
⑤组装select字句
@Test
public void test06(){
//查询用户的用户名,年龄,邮箱信息
QueryWrapper<User> queryWrapper = new QueryWrapper<>();
queryWrapper.select("name","age","email");
List<Map<String, Object>> maps = userMapper.selectMaps(queryWrapper);
maps.forEach(System.out::println);
}
⑥实现子查询
@Test
public void test07(){
//查询id小于等于100的用户信息
//SELECT id,name,age,email FROM user WHERE (id IN (select id from user where id <= 100))
QueryWrapper<User> queryWrapper = new QueryWrapper<>();
queryWrapper.inSql("id","select id from user where id <= 100");
List<User> list = userMapper.selectList(queryWrapper);
list.forEach(System.out::println);
}
3、UpdateWrapper
@Test
public void test08(){
//将用户名中包含a 并且 年龄大于20或邮箱为null的用户信息修改
UpdateWrapper<User> updateWrapper = new UpdateWrapper<>();
updateWrapper.like("name","a")
.and(i -> i.gt("age",20).or().isNull("email"));
updateWrapper.set("name","ccc").set("email","abc@dd.com");
int result = userMapper.update(null, updateWrapper);
System.out.println(result);
}
4、组装条件
在真正开发的过程中,组装条件是常见的功能,而这些条件数据来源于用户输入,是可选的,因此我们在组装这些条件时,必须先判断用户是否选择了这些条件,若选择则需要组装该条件,若没有选择则一定不能组装,以免影响SQL执行的结果
思路一:
@Test
public void test09(){
String username = "";
Integer ageBegin = 20;
Integer ageEnd = 30;
//SELECT id,name,age,email FROM user WHERE (age > ? AND age <= ?)
QueryWrapper<User> queryWrapper= new QueryWrapper<>();
if(StringUtils.isNotBlank(username)){
//注意StringUtils类是Mybatis包下的
//isNotBlank:判断某个字符串是否不为空字符串,不为null,不为空白符
queryWrapper.like("name",username);
}
if(ageBegin != null){
queryWrapper.gt("age",ageBegin);
}
if(ageEnd != null){
queryWrapper.le("age",ageEnd);
}
List<User> list = userMapper.selectList(queryWrapper);
list.forEach(System.out::println);
}
思路二:
上面的实现方案没有问题,但是代码比较复杂,我们可以使用带condition参数的重载方法构建查询条件,简化代码的编写
@Test
public void test10(){
String username = "a";
Integer ageBegin = null;
Integer ageEnd = 30;
//SELECT id,name,age,email FROM user WHERE (name LIKE ? AND age <= ?)
QueryWrapper<User> queryWrapper = new QueryWrapper<>();
queryWrapper.like(StringUtils.isNotBlank(username),"name",username)
.ge(ageBegin != null, "age",ageBegin)
.le(ageEnd != null,"age",ageEnd);
List<User> list = userMapper.selectList(queryWrapper);
list.forEach(System.out::println);
}
5、LambdaQueryWrapper
使用实体类的方法引用,避免写错实体类的字段名
@Test
public void test11(){
String username = "a";
Integer ageBegin = null;
Integer ageEnd = 30;
LambdaQueryWrapper<User> lambdaQueryWrapper = new LambdaQueryWrapper<>();
lambdaQueryWrapper.like(StringUtils.isNotBlank(username),User::getName,username)
.ge(ageBegin!=null,User::getAge,ageBegin)
.le(ageEnd != null,User::getAge,ageEnd);
List<User> list = userMapper.selectList(lambdaQueryWrapper);
list.forEach(System.out::println);
}
6、LambdaUpdateWrapper
@Test
public void test12(){
LambdaUpdateWrapper<User> lambdaUpdateWrapper = new LambdaUpdateWrapper<>();
lambdaUpdateWrapper.like(User::getName,"a")
.and(i->i.gt(User::getAge,20).or().isNull(User::getEmail));
lambdaUpdateWrapper.set(User::getName,"ddd").set(User::getEmail,"fff@aa.com");
int result = userMapper.update(null, lambdaUpdateWrapper);
System.out.println(result);
}
6、插件
1、分页插件
MyBatis Plus自带分页插件,只要简单的配置即可实现分页功能
1、添加配置类
@Configuration
@MapperScan("com.t4mako.mybatisplus.mapper") //可以将主类中的注解移到此处
public class MybatisPlusConfig {
@Bean
public MybatisPlusInterceptor mybatisPlusInterceptor(){
MybatisPlusInterceptor interceptor = new MybatisPlusInterceptor();
//添加分页插件
interceptor.addInnerInterceptor(new PaginationInnerInterceptor(DbType.MYSQL)); //配置数据库类型为MySQL
return interceptor;
}
}
2、测试
@SpringBootTest
public class MybatisPlusPluginsTest {
@Autowired
private UserMapper userMapper;
@Test
public void testPage(){
//创建page对象,参数为当前页为第几页,每页显示几条数据
Page<User> page = new Page<>(2,3);
//两个参数,第一个为page对象,第二个为条件构造器,如果条件构造器为null则选择所有数据
userMapper.selectPage(page,null);
//当前查询出来的数据分装在page中
System.out.println(page);
}
}
page对象可以获取当前页码,是否有上一页,下一页,总页数等数据
2、xml自定义分页
1、UserMapper中定义接口方法
//通过年龄查询用户信息并分页
Page<User> selectPageVo(Page<User> page,Integer age);
2、UserMapper.xml中编写SQL
可以再yaml文件中配置类型别名,在maper中编写resultType无需从com开始编写:
mybatis-plus:
#配置类型别名所对应的包
type-aliases-package: com.t4mako.mybatisplus.pojo
<!--Page<User> selectPageVo(Page<User> page,Integer age);-->
<select id="selectPageVo" resultType="User"><!--配置类型别名简写resultType-->
select id,name,age,email from user where age > #{age}
</select>
3、乐观锁
1、乐观锁实现流程 :
数据库中添加version字段
取出记录时,获取当前version
更新时,version + 1,如果where语句中的version版本不对,则更新失败
2、Mybatis-Plus实现乐观锁
①修改实体类
package com.atguigu.mybatisplus.entity;
import com.baomidou.mybatisplus.annotation.Version;
import lombok.Data;
@Data
public class Product {
private Long id;
private String name;
private Integer price;
@Version
private Integer version;
}
添加mapper
public interface ProductMapper extends BaseMapper<Product> {
}
②添加乐观锁插件配置
在mybatisPlus配置文件中添加乐观锁配置
@Configuration
@MapperScan("com.t4mako.mybatisplus.mapper") //可以将主类中的注解移到此处
public class MybatisPlusConfig {
@Bean
public MybatisPlusInterceptor mybatisPlusInterceptor(){
MybatisPlusInterceptor interceptor = new MybatisPlusInterceptor();
//添加分页插件
interceptor.addInnerInterceptor(new PaginationInnerInterceptor(DbType.MYSQL)); //配置数据库类型为MySQL
//添加乐观锁插件
interceptor.addInnerInterceptor(new OptimisticLockerInnerInterceptor());
return interceptor;
}
}
测试修改冲突
@Test
public void testConcurrentVersionUpdate() {
//小李取数据
Product p1 = productMapper.selectById(1L);
//小王取数据
Product p2 = productMapper.selectById(1L);
//小李修改 + 50
p1.setPrice(p1.getPrice() + 50);
int result1 = productMapper.updateById(p1);
System.out.println("小李修改的结果:" + result1);
//小王修改 - 30
p2.setPrice(p2.getPrice() - 30);
int result2 = productMapper.updateById(p2);
System.out.println("小王修改的结果:" + result2);
if(result2 == 0){
//失败重试,重新获取version并更新
p2 = productMapper.selectById(1L);
p2.setPrice(p2.getPrice() - 30);
result2 = productMapper.updateById(p2);
}
System.out.println("小王修改重试的结果:" + result2);
//老板看价格
Product p3 = productMapper.selectById(1L);
System.out.println("老板看价格:" + p3.getPrice());
}
7、通用枚举
表中的有些字段值是固定的,例如性别(男或女),此时我们可以使用MyBatis-Plus的通用枚举来实现
数据库表添加字段sex
①创建通用枚举类型:
package com.atguigu.mp.enums;
import com.baomidou.mybatisplus.annotation.EnumValue;
import lombok.Getter;
@Getter
public enum SexEnum {
MALE(1, "男"),
FEMALE(2, "女");
@EnumValue
private Integer sex;
private String sexName;
SexEnum(Integer sex, String sexName) {
this.sex = sex;
this.sexName = sexName;
}
}
配置扫描通用枚举(可以省略)
②测试
@Test
public void testSexEnum(){
User user = new User();
user.setName("Enum");
user.setAge(20);
//设置性别信息为枚举项,会将@EnumValue注解所标识的属性值存储到数据库
user.setSex(SexEnum.MALE);
//INSERT INTO t_user ( username, age, sex ) VALUES ( ?, ?, ? )
//Parameters: Enum(String), 20(Integer), 1(Integer)
userMapper.insert(user);
}
8、代码生成器
比逆向工程更加强大,自动生成controller,entitu,mapper,service
1、引入依赖
<dependency>
<groupId>com.baomidou</groupId>
<artifactId>mybatis-plus-generator</artifactId>
<version>3.5.1</version>
</dependency>
<dependency>
<groupId>org.freemarker</groupId>
<artifactId>freemarker</artifactId>
<version>2.3.31</version>
</dependency>
2、快速生成
举例:
将生成的controller,entitu,mapper,service,mapper文件与java类放到指定的目录下
public class FastAutoGeneratorTest {
public static void main(String[] args) {
FastAutoGenerator.create("jdbc:mysql://localhost:3306/mybatis_plus?serverTimezone=GMT%2B8&characterEncoding=utf-8&useSSL=false"
, "root", "root")
.globalConfig(builder -> {
builder.author("t4mako") // 设置作者
//.enableSwagger() // 开启 swagger 模式(快速生成)
.fileOverride() // 覆盖已生成文件
.outputDir("E://mybatis_plus"); // 指定输出目录
})
.packageConfig(builder -> {
builder.parent("com.t4mako") // 设置父包名
.moduleName("mybatisplus") // 设置父包模块名
.pathInfo(Collections.singletonMap(OutputFile.mapperXml, "E://mybatis_plus"));// 设置mapperXml生成路径
})
.strategyConfig(builder -> { //策略配置
builder.addInclude("user") // 设置需要生成的表名
.addTablePrefix("t_", "c_"); // 设置过滤表前缀
})
.templateEngine(new FreemarkerTemplateEngine()) // 使用Freemarker 引擎模板,默认的是Velocity引擎模板
.execute();
}
}
9、多数据源
适用于多种场景:纯粹多库、 读写分离、 一主多从、 混合模式等
场景说明:
我们创建两个库,分别为:mybatis_plus(以前的库不动)与mybatis_plus_1(新建),将mybatis_plus库的product表移动到mybatis_plus_1库,这样每个库一张表,通过一个测试用例分别获取用户数据与商品数据,如果获取到说明多库模拟成功
创建新的数据库和新的工程
1、引入依赖
<dependency>
<groupId>com.baomidou</groupId>
<artifactId>dynamic-datasource-spring-boot-starter</artifactId>
<version>3.5.0</version>
</dependency>
2、配置多数据源
spring:
# 配置数据源信息
datasource:
dynamic:
# 设置默认的数据源或者数据源组,默认值即为master
primary: master
# 严格匹配数据源,默认false。true表示未匹配到指定数据源时抛异常,false未匹配到则使用默认数据源
strict: false
datasource:
#主数据源
master:
url: jdbc:mysql://localhost:3306/mybatis_plus?serverTimezone=GMT%2B8&characterEncoding=utf-8&useSSL=false
driver-class-name: com.mysql.cj.jdbc.Driver
username: root
password: root
#从数据源
slave_1:
url: jdbc:mysql://localhost:3306/mybatis_plus2?serverTimezone=GMT%2B8&characterEncoding=utf-8&useSSL=false
driver-class-name: com.mysql.cj.jdbc.Driver
username: root
password: root
3、创建用户service
public interface UserService extends IService<User> {
}
@DS("master") //指定所操作的数据源
@Service
public class UserServiceImpl extends ServiceImpl<UserMapper, User> implements UserService {
}
4、创建商品service
public interface ProductService extends IService<Product> {
}
@DS("slave_1")
@Service
public class ProductServiceImpl extends ServiceImpl<ProductMapper, Product> implements ProductService {
}
5、测试
@Autowired
private UserService userService;
@Autowired
private ProductService productService;
@Test
public void testDynamicDataSource(){
System.out.println(userService.getById(1L));
System.out.println(productService.getById(1L));
}
1、都能顺利获取对象,则测试成功
2、如果我们实现读写分离,将写操作方法加上主库数据源,读操作方法加上从库数据源,自动切
换,是不是就能实现读写分离?
10、MyBatisX插件
MyBatis-Plus为我们提供了强大的mapper和service模板,能够大大的提高开发效率
但是在真正开发过程中,MyBatis-Plus并不能为我们解决所有问题,例如一些复杂的SQL,多表联查,我们就需要自己去编写代码和SQL语句,我们该如何快速的解决这个问题呢,这个时候可以使用MyBatisX插件
MyBatisX一款基于 IDEA 的快速开发插件,为效率而生。
MyBatisX插件用法:https://baomidou.com/pages/ba5b24/