当前位置： 首页 > news >正文

MyBatis Plus

news 2025/5/23 14:34:18

MybatisPlus

快速入门

1.引入MybatisPlus的起步依赖

MyBatisPlus官方提供了starter，其中集成了Mybatis和MybatisPlus的所有功能，并且实现了自动装配效果。

因此我们可以用MybatisPlus的starter代替Mybatis的starter：

<!-- MyBatis-Plus Spring Boot启动器依赖，用于集成MyBatis-Plus到Spring Boot框架中 -->
<dependency><groupId>com.baomidou</groupId><artifactId>mybatis-plus-boot-starter</artifactId><version>3.5.3.1</version>
</dependency>

2.定义Mapper

自定义的Mapper继承MybatisPlus提供的BaseMapper接口：

@Mapper
public interface UserMapper extends BaseMapper<User>{}

入门案例

需求：基于课前资料提供的项目，实现下列功能：

①新增用户功能

②根据id查询用户

③根据id批量查询用户

④根据id更新用户

⑤根据id删除用户

@SpringBootTest
class UserMapperTest {@Autowiredprivate UserMapper userMapper;// ①新增用户功能@Testvoid  testInsert(){User user = new User();user.setId(5L);user.setUsername("cammy");user.setPassword("123456");user.setPhone("13211000000");user.setInfo("{\"age\": 24, \"intro\": \"英文老师\", \"gender\": \"female\"}");user.setStatus(1);user.setBalance(100000);user.setCreateTime(LocalDateTime.now());user.setUpdateTime(LocalDateTime.now());userMapper.insert(user);}// ②根据id查询用户@Testvoid testSelectById(){User user = userMapper.selectById(5L);System.out.println("user = " + user);}// ③根据id批量查询用户@Testvoid testSelectBatchIds(){List<User> users = userMapper.selectBatchIds(List.of(1L, 2L, 3L, 4L, 5L));users.forEach(System.out::println);}// ④根据id更新用户@Testvoid testUpdateById(){User user = new User();user.setId(5L);user.setBalance(200000);userMapper.updateById(user);}// ⑤根据id删除用户@Testvoid testDeleteById(){userMapper.deleteById(5L);}
}

常见注解

MyBatisPlus通过扫描实体类，并基于反射获取实体类信息作为数据库表信息。

@Mapper
public interface UserMapper extends BaseMapper<User>{
}

@TableName("user")
@Data
public class User {/*** 用户id*/@TableId // 主键注解，标识实体类中的主键字段private Long id;/*** 用户名*/private String username;/*** 密码*/private String password;/*** 注册手机号*/private String phone;/*** 详细信息*/private String info;/*** 使用状态（1正常 2冻结）*/private Integer status;/*** 账户余额*/private Integer balance;/*** 创建时间*/private LocalDateTime createTime;/*** 更新时间*/private LocalDateTime updateTime;}

•类名驼峰转下划线作为表名

•名为id****的字段作为主键

•变量名驼峰转下划线作为表的字段名

MybatisPlus中比较常见的几个注解如下：

@TableName：用来指定表名 —— 表名注解，标识实体类对应的表

@TableId：用来指定表中的主键字段 —— 主键注解，标识实体类中的主键字段

@TableFiled：用来指定表中的普通字段信息 —— 普通字段注解，特殊情况才需要加这个注解，比如：

1.成员变量名与数据库字段名不一致

2.成员变量是以_<font style="color:#000000;">isXXX</font>_命名，按照_<font style="color:#000000;">JavaBean</font>_的规范，_<font style="color:#000000;">MybatisPlus</font>_识别字段时会把_<font style="color:#000000;">is</font>_去除，这就导致与数据库不符

3.成员变量名与数据库一致，但是与数据库的关键字冲突。使用_<font style="color:#000000;">@TableField</font>_注解给字段名添加转义字符：_<font style="color:#000000;">``</font>_

@TableName("tb_user")
public class User {@TableId(value="id",type=IdType.AUTO)private Long id;private String name;private Integer age;@TableField("is_married")private Boolean isMarried;@TableField("`order`")private String order;
}

IdType枚举：

  • AUTO：数据库自增长
  • INPUT：通过set方法自行输入
  • ASSIGN_ID：分配ID，接口IdentifierGenerator的方法nextId来生成idm，默认实现类为DefaultIdentifierGenerator雪花算法

使用@TableField的常见场景：

  • 成员变量名与数据库字段名不一致
  • 成员变量名以is开头，且是布尔值
  • 成员变量名与数据库关键字冲突
  • 成员变量不是数据库字段

@TableField支持的其它属性如下：

属性类型必填默认值描述
valueString否“”数据库字段名
existboolean否true是否为数据库表字段
conditionString否“”字段 where 实体查询比较条件，有值设置则按设置的值为准，没有则为默认全局的 %s=#{%s}，参考(opens new window)
updateString否“”字段 update set 部分注入，例如：当在version字段上注解update=“%s+1” 表示更新时会 set version=version+1 （该属性优先级高于 el 属性）
insertStrategyEnum否FieldStrategy.DEFAULT举例：NOT_NULL insert into table_a(column) values (#{columnProperty})
updateStrategyEnum否FieldStrategy.DEFAULT举例：IGNORED update table_a set column=#{columnProperty}
whereStrategyEnum否FieldStrategy.DEFAULT举例：NOT_EMPTY where column=#{columnProperty}
fillEnum否FieldFill.DEFAULT字段自动填充策略
selectboolean否true是否进行 select 查询
keepGlobalFormatboolean否false是否保持使用全局的 format 进行处理
jdbcTypeJdbcType否JdbcType.UNDEFINEDJDBC 类型 (该默认值不代表会按照该值生效)
typeHandlerTypeHander否类型处理器 (该默认值不代表会按照该值生效)
numericScaleString否“”指定小数点后保留的位数

MybatisPlus是如何获取实现CRUD的数据库表信息的？

  • 默认把类名驼峰转下划线
  • 默认把名为id的字段作为主键
  • 默认把变量名驼峰转下划线作为表的字段名

MybatisPlus的常用注解？

  • @TableName：指定表名称及全局配置
  • @TableId：指定id字段及相关配置
  • @TableField：指定普通字段及相关配置

IdType的常见类型有哪些？

  • AUTO、ASSIGN_ID、INPUT

使用@TableField的常见场景是？

  • 成员变量名与数据库字段名不一致
  • 成员变量名以is开头，且是布尔值
  • 成员变量名与数据库关键字冲突
  • 成员变量不是数据库字段

MybatisPlus的配置项继承了Mybatis原生配置和一些自己特有的配置。例如：

MybatisPlus也支持基于yaml文件的自定义配置，详见官方文档：MyBatis-Plus 🚀 为简化开发而生

大多数的配置都有默认值，因此我们都无需配置。但还有一些是没有默认值的，例如:

  • 实体类的别名扫描包
  • 全局id类型
mybatis-plus:type-aliases-package: com.itheima.mp.domain.poglobal-config:db-config:id-type: auto # 全局id类型为自增长

需要注意的是，MyBatisPlus也支持手写SQL的，而mapper文件的读取地址可以自己配置：

mybatis-plus:mapper-locations: "classpath*:/mapper/**/*.xml" # Mapper.xml文件地址，当前这个是默认值。

可以看到默认值是classpath*:/mapper/**/*.xml，也就是说我们只要把mapper.xml文件放置这个目录下就一定会被加载。

例如，我们新建一个UserMapper.xml文件：

<?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.itheima.mp.mapper.UserMapper"><select id="queryById" resultType="User">SELECT * FROM user WHERE id = #{id}</select>
</mapper>

@Test
void testQuery() {User user = userMapper.queryById(1L);System.out.println("user = " + user);
}

MybatisPlus使用的基本流程是什么？

  1. 引入起步依赖
  2. 自定义Mapper基础BaseMapper
  3. 在实体类上添加注解声明表信息
  4. 在application.yaml中根据需要添加配置

核心功能

条件构造器

除了新增以外，修改、删除、查询的SQL语句都需要指定where条件。因此BaseMapper中提供的相关方法除了以id作为where条件以外，还支持更加复杂的where条件。

QueryWrapper

查询

// 查询出名字中带o的，存款大于等于1000元的人
@Test
void testQueryWrapper() {// 1.构建查询条件 where name like "%o%" AND balance >= 1000QueryWrapper<User> wrapper = new QueryWrapper<User>().select("id", "username", "info", "balance").like("username", "o").ge("balance", 1000);// 2.查询数据List<User> users = userMapper.selectList(wrapper);users.forEach(System.out::println);
}

更新

// 更新用户名为jack的用户的余额为2000
@Test
void testUpdateByQueryWrapper() {// 1.构建查询条件 where name = "Jack"QueryWrapper<User> wrapper = new QueryWrapper<User>().eq("username", "jack");// 2.更新数据，user中非null字段都会作为set语句User user = new User();user.setBalance(2000);userMapper.update(user, wrapper);
}
UpdateWrapper
// 更新id为1,2,4的用户的余额，扣200
@Test
void testUpdateWrapper() {// 对应的SQL语句 UPDATE user SET balance = balance - 200 WHERE id in (1, 2, 4)List<Long> ids = List.of(1L, 2L, 4L);// 1.生成SQLUpdateWrapper<User> wrapper = new UpdateWrapper<User>().setSql("balance = balance - 200") // SET balance = balance - 200.in("id", ids); // WHERE id in (1, 2, 4)// 2.更新，注意第一个参数可以给null，也就是不填更新字段和数据，而是基于UpdateWrapper中的setSQL来更新userMapper.update(null, wrapper);
}
★LambdaQueryWrapper

其中一种办法是基于变量的gettter方法结合反射技术。因此我们只要将条件对应的字段的getter方法传递给MybatisPlus，它就能计算出对应的变量名了。而传递方法可以使用JDK8中的方法引用和Lambda表达式。 因此MybatisPlus又提供了一套基于Lambda的Wrapper，包含两个：

  • LambdaQueryWrapper
  • LambdaUpdateWrapper

分别对应QueryWrapper和UpdateWrapper

上面查询案例通过LambdaQueryWrapper演示如下：

// 查询出名字中带o的，存款大于等于1000元的人
@Test
void testLambdaQueryWrapper(){// 1.构建条件 WHERE username LIKE "%o%" AND balance >= 1000LambdaQueryWrapper<User> lambdaQueryWrapper = new LambdaQueryWrapper<User>().select(User::getId, User::getUsername, User::getInfo, User::getBalance).like(User::getUsername, "o").ge(User::getBalance, 1000);// 2.查询数据List<User> users = userMapper.selectList(lambdaQueryWrapper);users.forEach(System.out::println);
}

自定义SQL

在演示UpdateWrapper的案例中，我们在代码中编写了更新的SQL语句：

这种写法在某些企业也是不允许的，因为SQL语句最好都维护在持久层，而不是业务层。就当前案例来说，由于条件是in语句，只能将SQL写在Mapper.xml文件，利用foreach来生成动态SQL。

所以，MybatisPlus提供了自定义SQL功能，可以让我们利用Wrapper生成查询条件，再结合Mapper.xml编写SQL。

基本用法
@Test
void testCustomWrapper() {// 1.准备自定义查询条件List<Long> ids = List.of(1L, 2L, 3L);QueryWrapper<User> wrapper = new QueryWrapper<User>().in("id", ids);// 2.调用mapper的自定义方法，直接传递WrapperuserMapper.deductBalanceByIds(200, wrapper);
}

@Select("update user set balance = balance-#{money} ${ew.customSqlSegment}")
void deductBalanceByIds(@Param("money") int i, @Param("ew") QueryWrapper<User> wrapper);
多表关联

理论上来讲MyBatisPlus是不支持多表查询的，不过我们可以利用Wrapper中自定义条件结合自定义SQL来实现多表查询的效果。 例如，我们要查询出所有收货地址在北京的并且用户id在1、2、4之中的用户 要是自己基于mybatis实现SQL，大概是这样的：

<select id="queryUserByIdAndAddr" resultType="com.itheima.mp.domain.po.User">SELECT *FROM user uINNER JOIN address a ON u.id = a.user_idWHERE u.id<foreach collection="ids" separator="," item="id" open="IN (" close=")">#{id}</foreach>AND a.city = #{city}</select>

可以看出其中最复杂的就是WHERE条件的编写，如果业务复杂一些，这里的SQL会更变态。

但是基于自定义SQL结合Wrapper的玩法，我们就可以利用Wrapper来构建查询条件，然后手写SELECT及FROM部分，实现多表查询。

查询条件这样来构建：

@Test
void testCustomJoinWrapper() {// 1.准备自定义查询条件QueryWrapper<User> wrapper = new QueryWrapper<User>().in("u.id", List.of(1L, 2L, 4L)).eq("a.city", "北京");// 2.调用mapper的自定义方法List<User> users = userMapper.queryUserByWrapper(wrapper);users.forEach(System.out::println);
}

然后在UserMapper中自定义方法：

@Select("SELECT u.* FROM user u INNER JOIN address a ON u.id = a.user_id ${ew.customSqlSegment}")
List<User> queryUserByWrapper(@Param("ew")QueryWrapper<User> wrapper);

当然，也可以在UserMapper.xml中写SQL：

<select id="queryUserByIdAndAddr" resultType="com.itheima.mp.domain.po.User">SELECT * FROM user u INNER JOIN address a ON u.id = a.user_id ${ew.customSqlSegment}
</select>

Service接口

MybatisPlus不仅提供了BaseMapper，还提供了通用的Service接口及默认实现，封装了一些常用的service模板方法。 通用接口为IService，默认实现为ServiceImpl，其中封装的方法可以分为以下几类：

  • save：新增
  • remove：删除
  • update：更新
  • get：查询单个结果
  • list：查询集合结果
  • count：计数
  • page：分页查询

CRUD

新增

  • save是新增单个元素
  • saveBatch是批量新增
  • saveOrUpdate是根据id判断，如果数据存在就更新，不存在则新增
  • saveOrUpdateBatch是批量的新增或修改

删除

  • removeById：根据id删除
  • removeByIds：根据id批量删除
  • removeByMap：根据Map中的键值对为条件删除
  • remove(Wrapper<T>)：根据Wrapper条件删除
  • ~~removeBatchByIds~~：暂不支持

修改

  • updateById：根据id修改
  • update(Wrapper<T>)：根据UpdateWrapper修改，Wrapper中包含set和where部分
  • update(T，Wrapper<T>)：按照T内的数据修改与Wrapper匹配到的数据
  • updateBatchById：根据id批量修改

Get

  • getById：根据id查询1条数据
  • getOne(Wrapper<T>)：根据Wrapper查询1条数据
  • getBaseMapper：获取Service内的BaseMapper实现，某些时候需要直接调用Mapper内的自定义SQL时可以用这个方法获取到Mapper

List

  • listByIds：根据id批量查询
  • list(Wrapper<T>)：根据Wrapper条件查询多条数据
  • list()：查询所有

Count

  • count()：统计所有数量
  • count(Wrapper<T>)：统计符合Wrapper条件的数据数量

getBaseMapper

当我们在service中要调用Mapper中自定义SQL时，就必须获取service对应的Mapper，就可以通过这个方法

基本用法
编号接口请求方式请求路径请求参数返回值
1新增用户POST/users用户表单实体无
2删除用户DELETE/users/{id}用户id无
3根据id查询用户GET/users/{id}用户id用户VO
4根据id批量查询GET/users用户id集合用户VO集合
package com.itheima.mp.domain.dto;import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;@Data
@ApiModel(description = "用户表单实体")
public class UserFormDTO {@ApiModelProperty("id")private Long id;@ApiModelProperty("用户名")private String username;@ApiModelProperty("密码")private String password;@ApiModelProperty("注册手机号")private String phone;@ApiModelProperty("详细信息，JSON风格")private String info;@ApiModelProperty("账户余额")private Integer balance;
}

package com.itheima.mp.domain.vo;import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;@Data
@ApiModel(description = "用户VO实体")
public class UserVO {@ApiModelProperty("用户id")private Long id;@ApiModelProperty("用户名")private String username;@ApiModelProperty("详细信息")private String info;@ApiModelProperty("使用状态（1正常 2冻结）")private Integer status;@ApiModelProperty("账户余额")private Integer balance;
}

package com.itheima.mp.service;import com.baomidou.mybatisplus.extension.service.IService;
import com.itheima.mp.domain.po.User;public interface IUserService extends IService<User> {
}

package com.itheima.mp.service.impl;import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.itheima.mp.domain.po.User;
import com.itheima.mp.mapper.UserMapper;
import com.itheima.mp.service.IUserService;
import org.springframework.stereotype.Service;@Service
public class IUserServiceImpl extends ServiceImpl<UserMapper, User> implements IUserService{
}

package com.itheima.mp.contoller;import cn.hutool.core.bean.BeanUtil;
import com.itheima.mp.domain.dto.UserFormDTO;
import com.itheima.mp.domain.po.User;
import com.itheima.mp.domain.vo.UserVO;
import com.itheima.mp.service.IUserService;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import lombok.RequiredArgsConstructor;
import org.springframework.beans.BeanUtils;
import org.springframework.web.bind.annotation.*;import java.util.List;/*** @author : Cammy.Wu* Description : 用户管理接口*/@Api(tags = "用户管理接口")
@RequiredArgsConstructor
@RestController
@RequestMapping("users")
public class UserController {private final IUserService userService;@ApiOperation("新增用户")@PostMappingpublic void saveUser(@RequestBody UserFormDTO userFormDTO){// 1.转换DTO为POUser user = BeanUtil.copyProperties(userFormDTO, User.class);// 2.新增userService.save(user);}@ApiOperation("删除用户")@DeleteMapping("/{id}")public void deleteUser(@PathVariable("id") Long userId){userService.removeById(userId);}@ApiOperation("根据id查询用户")@GetMapping("/{id}")public UserVO queryUserById(@PathVariable("id")  Long userId){// 1.查询用户User user = userService.getById(userId);// 2，处理voreturn BeanUtil.copyProperties(user, UserVO.class);}@ApiOperation("根据id集合查询用户")@GetMappingpublic UserVO queryUserByIds(@RequestParam("ids") List<Long> ids){// 1.查询用户List<User> users = userService.listByIds(ids);// 2.处理voreturn BeanUtil.copyProperties(users, UserVO.class);}}

可以看到上述接口都直接在controller即可实现，无需编写任何service代码，非常方便。

不过，一些带有业务逻辑的接口则需要在service中自定义实现了。例如下面的需求：

  • 根据id扣减用户余额

这看起来是个简单修改功能，只要修改用户余额即可。但这个业务包含一些业务逻辑处理：

  • 判断用户状态是否正常
  • 判断用户余额是否充足

这些业务逻辑都要在service层来做，另外更新余额需要自定义SQL，要在mapper中来实现。因此，我们除了要编写controller以外，具体的业务还要在service和mapper中编写。

Lambda

IService中还提供了Lambda功能来简化我们的复杂查询及更新功能。我们通过两个案例来学习一下。

案例一：实现一个根据复杂条件查询用户的接口，查询条件如下：

  • name：用户名关键字，可以为空
  • status：用户状态，可以为空
  • minBalance：最小余额，可以为空
  • maxBalance：最大余额，可以为空

可以理解成一个用户的后台管理界面，管理员可以自己选择条件来筛选用户，因此上述条件不一定存在，需要做判断。

package com.itheima.mp.domain.query;import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;@Data
@ApiModel(description = "用户查询条件实体")
public class UserQuery {@ApiModelProperty("用户名关键字")private String name;@ApiModelProperty("用户状态：1-正常，2-冻结")private Integer status;@ApiModelProperty("余额最小值")private Integer minBalance;@ApiModelProperty("余额最大值")private Integer maxBalance;
}

@ApiOperation("根据id集合查询用户")
@GetMapping("/list")
public List<UserVO> queryUsers(UserQuery query){// 1.组织条件String username = query.getName();Integer status = query.getStatus();Integer minBalance = query.getMinBalance();Integer maxBalance = query.getMaxBalance();LambdaQueryWrapper<User> queryWrapper = new QueryWrapper<User>().lambda().like(username != null, User::getUsername, username).eq(status != null, User::getStatus, status).ge(minBalance != null, User::getBalance, minBalance).le(maxBalance != null, User::getBalance, maxBalance);// 2.查询用户List<User> users = userService.list(queryWrapper);// 3.处理voreturn BeanUtil.copyToList(users, UserVO.class);
}

在组织查询条件的时候，我们加入了 username != null 这样的参数，意思就是当条件成立时才会添加这个查询条件，类似Mybatis的mapper.xml文件中的<if>标签。这样就实现了动态查询条件效果了。

不过，上述条件构建的代码太麻烦了。 因此Service中对LambdaQueryWrapper和LambdaUpdateWrapper的用法进一步做了简化。我们无需自己通过new的方式来创建Wrapper，而是直接调用lambdaQuery和lambdaUpdate方法：

@ApiOperation("根据id集合查询用户")
@GetMapping("/list")
public List<UserVO> queryUsers(UserQuery query){// 1.组织条件String username = query.getName();Integer status = query.getStatus();Integer minBalance = query.getMinBalance();Integer maxBalance = query.getMaxBalance();// LambdaQueryWrapper<User> queryWrapper = new QueryWrapper<User>().lambda()//         .like(username != null, User::getUsername, username)//         .eq(status != null, User::getStatus, status)//         .ge(minBalance != null, User::getBalance, minBalance)//         .le(maxBalance != null, User::getBalance, maxBalance);// 2.查询用户// List<User> users = userService.list(queryWrapper);List<User> users = userService.lambdaQuery().like(username != null, User::getUsername, username).eq(status != null, User::getStatus, status).ge(minBalance != null, User::getBalance, minBalance).le(maxBalance != null, User::getBalance, maxBalance).list();// 3.处理voreturn BeanUtil.copyToList(users, UserVO.class);
}

可以发现lambdaQuery方法中除了可以构建条件，还需要在链式编程的最后添加一个list()，这是在告诉MP我们的调用结果需要是一个list集合。这里不仅可以用list()，可选的方法有：

  • .one()：最多1个结果
  • .list()：返回集合结果
  • .count()：返回计数结果

MybatisPlus会根据链式编程的最后一个方法来判断最终的返回结果。

与lambdaQuery方法类似，IService中的lambdaUpdate方法可以非常方便的实现复杂更新业务。

案例二：改造根据id修改用户余额的接口，要求如下：

  • 如果扣减后余额为0，则将用户status修改为冻结状态（2），也就是说我们在扣减用户余额时，需要对用户剩余余额做出判断，如果发现剩余余额为0，则应该将status修改为2，这就是说update语句的set部分是动态的。
/*** 扣减用户余额* @param id* @param money*/
@Transactional
@Override
public void deductBalance(Long id, Integer money) {// 1.查询用户User user = getById(id);// 2.判断用户状态if (user == null || user.getStatus() == 2) {throw new RuntimeException("用户状态异常");}// 3.判断用户余额if (user.getBalance() < money) {throw new RuntimeException("用户余额不足");}// 4，扣减余额 update user set balance = balance - ?// userMapper.deductMoneyById(id, money);int remainBalance = user.getBalance() - money;lambdaUpdate().set(User::getBalance,remainBalance) // 更新余额.set(remainBalance==0,User::getStatus,2) // 动态判断，是否更新status.eq(User::getId,id).eq(User::getBalance,user.getBalance()) // 乐观锁.update();
}
批量新增

IService中的批量新增功能使用起来非常方便，但有一点注意事项，我们先来测试一下。 首先我们测试逐条插入数据：

@Test
void testSaveOneByOne() {long b = System.currentTimeMillis();for (int i = 1; i <= 100000; i++) {userService.save(buildUser(i));}long e = System.currentTimeMillis();System.out.println("耗时：" + (e - b));
}private User buildUser(int i) {User user = new User();user.setUsername("user_" + i);user.setPassword("123");user.setPhone("" + (18688190000L + i));user.setBalance(2000);user.setInfo("{\"age\": 24, \"intro\": \"英文老师\", \"gender\": \"female\"}");user.setCreateTime(LocalDateTime.now());user.setUpdateTime(user.getCreateTime());return user;
}

速度非常慢。

然后再试试MybatisPlus的批处理：

@Test
void testSaveBatch() {// 准备10万条数据List<User> list = new ArrayList<>(1000);long b = System.currentTimeMillis();for (int i = 1; i <= 100000; i++) {list.add(buildUser(i));// 每1000条批量插入一次if (i % 1000 == 0) {userService.saveBatch(list);list.clear();}}long e = System.currentTimeMillis();System.out.println("耗时：" + (e - b));
}

批处理比逐条新增效率提高了10倍左右。

MybatisPlus源码

/*** 批量插入** @param entityList ignore* @param batchSize  ignore* @return ignore*/
@Transactional(rollbackFor = Exception.class)
@Override
public boolean saveBatch(Collection<T> entityList, int batchSize) {String sqlStatement = getSqlStatement(SqlMethod.INSERT_ONE);return executeBatch(entityList, batchSize, (sqlSession, entity) -> sqlSession.insert(sqlStatement, entity));
}

/*** 执行批量操作** @param entityClass 实体类* @param log         日志对象* @param list        数据集合* @param batchSize   批次大小* @param consumer    consumer* @param <E>         T* @return 操作结果* @since 3.4.0*/
public static <E> boolean executeBatch(Class<?> entityClass, Log log, Collection<E> list, int batchSize, BiConsumer<SqlSession, E> consumer) {Assert.isFalse(batchSize < 1, "batchSize must not be less than one");return !CollectionUtils.isEmpty(list) && executeBatch(entityClass, log, sqlSession -> {int size = list.size();int idxLimit = Math.min(batchSize, size);int i = 1;for (E element : list) {consumer.accept(sqlSession, element);if (i == idxLimit) {sqlSession.flushStatements();idxLimit = Math.min(idxLimit + batchSize, size);}i++;}});
}

MybatisPlus的批处理是基于PrepareStatement的预编译模式，然后批量提交，最终在数据库执行时还是会有多条insert语句，逐条插入数据。SQL类似这样：

Preparing: INSERT INTO user ( username, password, phone, info, balance, create_time, update_time ) VALUES ( ?, ?, ?, ?, ?, ?, ? )
Parameters: user_1, 123, 18688190001, "", 2000, 2023-07-01, 2023-07-01
Parameters: user_2, 123, 18688190002, "", 2000, 2023-07-01, 2023-07-01
Parameters: user_3, 123, 18688190003, "", 2000, 2023-07-01, 2023-07-01

而如果想要得到最佳性能，最好是将多条SQL合并为一条，类似这样：

INSERT INTO user ( username, password, phone, info, balance, create_time, update_time )
VALUES 
(user_1, 123, 18688190001, "", 2000, 2023-07-01, 2023-07-01),
(user_2, 123, 18688190002, "", 2000, 2023-07-01, 2023-07-01),
(user_3, 123, 18688190003, "", 2000, 2023-07-01, 2023-07-01),
(user_4, 123, 18688190004, "", 2000, 2023-07-01, 2023-07-01);

该怎么做呢？

MySQL的客户端连接参数中有这样的一个参数：rewriteBatchedStatements。顾名思义，就是重写批处理的statement语句。

rewriteBatchedStatements这个参数的默认值是false，我们需要修改连接参数，将其配置为true。

该怎么改呢？

修改项目中的application.yml文件，在jdbc的url后面添加参数&rewriteBatchedStatements=true:

spring:datasource:url: jdbc:mysql://localhost:3306/mp?useUnicode=true&characterEncoding=UTF-8&autoReconnect=true&serverTimezone=Asia/Shanghai&rewriteBatchedStatements=truedriver-class-name: com.mysql.cj.jdbc.Driverusername: rootpassword: MySQL0913

拓展功能

to be continue…

插件功能

to be continue…


http://www.mrgr.cn/news/52662.html

相关文章：

  • Linux中pip安装python包失败原因是缺少python3-dev
  • C/C++逆向与反汇编01-寻找主函数
  • vue组件调用生命周期
  • [Unity Demo]从零开始制作空洞骑士Hollow Knight第十四集：制作新的场景以及制作创建切换管理系统
  • 详解Shell脚本与Ansible自动化工具差异
  • 为什么你总碰到渣男？伯克森悖论
  • 执行jar文件no main manifest attribute错误
  • 毕业设计选题：基于django+vue的个人博客系统设计与开发
  • Redis-2
  • OJ-1017中文分词模拟器
  • Linux基础指令
  • HTML+Node+Mysql+Navicat 实现注册登录的接口
  • frameworks 之 触摸事件窗口查找
  • Lintcode 135 · 数字组合【中的 排列组合问题 DFS Java】
  • 植物大战僵尸杂交版即将新增内容介绍
  • 【每日一题】LeetCode每日一题-无重复字符的最长子串
  • 浅谈es6箭头函数
  • 碳酸二辛酯行业分析：未来几年年复合增长率CAGR为3.37%
  • 【前端】Matter：过滤与高级碰撞检测
  • ssm基于SSM的社区管理系统+vue