首页 > 其他分享 >MyBatis批量插入的五种方式，哪种最强？？？

MyBatis批量插入的五种方式，哪种最强？？？

时间：2023-02-11 21:59:16浏览次数：58  
标签：批量 UserMapper System 五种 user 一万条 MyBatis User

前言：

这里我列举了MyBatis和MyBatis-Plus常用的五种批量插入的方式，进行了详细的总结归纳，写的非常详细，整体思路清晰明了，只分享干货。

目录

一、准备工作

二、MyBatis利用For循环批量插入

三、MyBatis的手动批量提交

四、MyBatis以集合方式批量新增（推荐）

五、MyBatis-Plus提供的SaveBatch方法

六、MyBatis-Plus提供的InsertBatchSomeColumn方法（推荐）

七、总结

一、准备工作

1、导入pom.xml依赖

  1.         <dependency>
  2.             <groupId>mysql</groupId>
  3.             <artifactId>mysql-connector-java</artifactId>
  4.             <scope>runtime</scope>
  5.         </dependency>
  6.  
  7.         <!--Mybatis依赖-->
  8.         <dependency>
  9.             <groupId>org.mybatis.spring.boot</groupId>
  10.             <artifactId>mybatis-spring-boot-starter</artifactId>
  11.             <version>2.2.2</version>
  12.         </dependency>
  13.  
  14.         <!--Mybatis-Plus依赖-->
  15.         <dependency>
  16.             <groupId>com.baomidou</groupId>
  17.             <artifactId>mybatis-plus-boot-starter</artifactId>
  18.             <version>3.5.2</version>
  19.         </dependency>
  20.  
  21.         <dependency>
  22.             <groupId>org.projectlombok</groupId>
  23.             <artifactId>lombok</artifactId>
  24.             <optional>true</optional>
  25.         </dependency>

2、配置yml文件

  1. server:
  2.   port: 8080
  3.  
  4. spring:
  5.   datasource:
  6.     username: mysql用户名
  7.     password: mysql密码
  8.     url: jdbc:mysql://localhost:3306/数据库名字?useUnicode=true&characterEncoding=utf-8&useSSL=false&serverTimezone=UTC
  9.     driver-class-name: com.mysql.cj.jdbc.Driver
  10.  
  11. mybatis:
  12.   mapper-locations: classpath:mapping/*.xml

 3、公用的User类

  1. @Data
  2. public class User {
  3.  
  4.     private int id;
  5.     private String username;
  6.     private String password;
  7. }

二、MyBatis利用For循环批量插入

1、编写UserService服务类，测试一万条数据耗时情况

  1. @Service
  2. public class UserService {
  3.  
  4.     @Resource
  5.     private UserMapper userMapper;
  6.  
  7.     public void InsertUsers(){
  8.         long start = System.currentTimeMillis();
  9.         for(int i = 0 ;i < 10000; i++) {
  10.             User user = new User();
  11.             user.setUsername("name" + i);
  12.             user.setPassword("password" + i);
  13.             userMapper.insertUsers(user);
  14.         }
  15.         long end = System.currentTimeMillis();
  16.         System.out.println("一万条数据总耗时：" + (end-start) + "ms" );
  17.     }
  18.  
  19. }

2、编写UserMapper接口

  1. @Mapper
  2. public interface UserMapper {
  3.  
  4.     Integer insertUsers(User user);
  5. }

3、编写UserMapper.xml文件

  1. <?xml version="1.0" encoding="UTF-8" ?>
  2. <!DOCTYPE mapper
  3.         PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
  4.         "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
  5. <mapper namespace="com.ithuang.demo.mapper.UserMapper">
  6.     <insert id="insertUsers">
  7.         INSERT INTO user (username, password)
  8.         VALUES(#{username}, #{password})
  9.     </insert>
  10. </mapper>

4、进行单元测试

  1. @SpringBootTest
  2. class DemoApplicationTests {
  3.  
  4.     @Resource
  5.     private UserService userService;
  6.  
  7.     @Test
  8.     public void insert(){
  9.         userService.InsertUsers();
  10.     }
  11.  
  12. }

5、结果输出

一万条数据总耗时：26348ms

三、MyBatis的手动批量提交

1、其他保持不变，Service层作稍微的变化

  1. @Service
  2. public class UserService {
  3.  
  4.     @Resource
  5.     private UserMapper userMapper;
  6.  
  7.     @Resource
  8.     private SqlSessionTemplate sqlSessionTemplate;
  9.  
  10.     public void InsertUsers(){
  11.         //关闭自动提交
  12.         SqlSession sqlSession = sqlSessionTemplate.getSqlSessionFactory().openSession(ExecutorType.BATCH, false);
  13.         UserMapper userMapper = sqlSession.getMapper(UserMapper.class);
  14.         long start = System.currentTimeMillis();
  15.         for(int i = 0 ;i < 10000; i++) {
  16.             User user = new User();
  17.             user.setUsername("name" + i);
  18.             user.setPassword("password" + i);
  19.             userMapper.insertUsers(user);
  20.         }
  21.         sqlSession.commit();
  22.         long end = System.currentTimeMillis();
  23.         System.out.println("一万条数据总耗时：" + (end-start) + "ms" );
  24.     }
  25.  
  26. }

2、结果输出

一万条数据总耗时：24516ms

四、MyBatis以集合方式批量新增（推荐）

1、编写UserService服务类

  1. @Service
  2. public class UserService {
  3.  
  4.     @Resource
  5.     private UserMapper userMapper;
  6.  
  7.     public void InsertUsers(){
  8.         long start = System.currentTimeMillis();
  9.         List<User> userList = new ArrayList<>();
  10.         User user;
  11.         for(int i = 0 ;i < 10000; i++) {
  12.             user = new User();
  13.             user.setUsername("name" + i);
  14.             user.setPassword("password" + i);
  15.             userList.add(user);
  16.         }
  17.         userMapper.insertUsers(userList);
  18.         long end = System.currentTimeMillis();
  19.         System.out.println("一万条数据总耗时：" + (end-start) + "ms" );
  20.     }
  21.  
  22. }

3、编写UserMapper接口

  1. @Mapper
  2. public interface UserMapper {
  3.  
  4.     Integer insertUsers(List<User> userList);
  5. }

4、编写UserMapper.xml文件

  1. <?xml version="1.0" encoding="UTF-8" ?>
  2. <!DOCTYPE mapper
  3.         PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
  4.         "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
  5. <mapper namespace="com.ithuang.demo.mapper.UserMapper">
  6.     <insert id="insertUsers">
  7.         INSERT INTO user (username, password)
  8.         VALUES
  9.         <foreach collection ="userList" item="user" separator =",">
  10.             (#{user.username}, #{user.password})
  11.         </foreach>
  12.     </insert>
  13. </mapper>

5、输出结果

一万条数据总耗时：521ms

五、MyBatis-Plus提供的SaveBatch方法

1、编写UserService服务

  1. @Service
  2. public class UserService extends ServiceImpl<UserMapper, User> implements IService<User> {
  3.  
  4.     public void InsertUsers(){
  5.         long start = System.currentTimeMillis();
  6.         List<User> userList = new ArrayList<>();
  7.         User user;
  8.         for(int i = 0 ;i < 10000; i++) {
  9.             user = new User();
  10.             user.setUsername("name" + i);
  11.             user.setPassword("password" + i);
  12.             userList.add(user);
  13.         }
  14.         saveBatch(userList);
  15.         long end = System.currentTimeMillis();
  16.         System.out.println("一万条数据总耗时：" + (end-start) + "ms" );
  17.     }
  18. }

2、编写UserMapper接口

  1. @Mapper
  2. public interface UserMapper extends BaseMapper<User> {
  3.  
  4. }

3、单元测试结果

一万条数据总耗时：24674ms

六、MyBatis-Plus提供的InsertBatchSomeColumn方法（推荐）

1、编写EasySqlInjector 自定义类

  1. public class EasySqlInjector extends DefaultSqlInjector {
  2.  
  3.  
  4.     @Override
  5.     public List<AbstractMethod> getMethodList(Class<?> mapperClass, TableInfo tableInfo) {
  6.         // 注意：此SQL注入器继承了DefaultSqlInjector(默认注入器)，调用了DefaultSqlInjector的getMethodList方法，保留了mybatis-plus的自带方法
  7.         List<AbstractMethod> methodList = super.getMethodList(mapperClass, tableInfo);
  8.         methodList.add(new InsertBatchSomeColumn(i -> i.getFieldFill() != FieldFill.UPDATE));
  9.         return methodList;
  10.     }
  11.  
  12. }

2、定义核心配置类注入此Bean

  1. @Configuration
  2. public class MybatisPlusConfig {
  3.  
  4.     @Bean
  5.     public EasySqlInjector sqlInjector() {
  6.         return new EasySqlInjector();
  7.     }
  8. }

3、编写UserService服务类

  1. public class UserService{
  2.  
  3.     @Resource
  4.     private UserMapper userMapper;
  5.     public void InsertUsers(){
  6.         long start = System.currentTimeMillis();
  7.         List<User> userList = new ArrayList<>();
  8.         User user;
  9.         for(int i = 0 ;i < 10000; i++) {
  10.             user = new User();
  11.             user.setUsername("name" + i);
  12.             user.setPassword("password" + i);
  13.             userList.add(user);
  14.         }
  15.         userMapper.insertBatchSomeColumn(userList);
  16.         long end = System.currentTimeMillis();
  17.         System.out.println("一万条数据总耗时：" + (end-start) + "ms" );
  18.     }
  19. }

4、编写EasyBaseMapper接口

  1. public interface EasyBaseMapper<T> extends BaseMapper<T> {
  2.     /**
  3.      * 批量插入 仅适用于mysql
  4.      *
  5.      * @param entityList 实体列表
  6.      * @return 影响行数
  7.      */
  8.     Integer insertBatchSomeColumn(Collection<T> entityList);
  9. }

5、编写UserMapper接口

  1. @Mapper
  2. public interface UserMapper<T> extends EasyBaseMapper<User> {
  3.     
  4. }

6、单元测试结果

一万条数据总耗时：575ms

七、总结

以上就是我对目前MyBatis常用的批量插入方法的总结

来源：https://blog.csdn.net/HJW_233/article/details/126909439

标签：批量,UserMapper,System,五种,user,一万条,MyBatis,User
From： https://www.cnblogs.com/konglxblog/p/17112631.html

相关文章

  • Mybatis plus按照时间排序后分页查询有重复情况
    场景有一个根据create_time排序的分页接口，在第二页会出现第一页出现过的重复记录排查思路排查1、入参处理时对分页相关数据的处理有问题排查2、sql的入参数有问题经......
  • 014_SpringBoot整合MyBatisPlus
    MyBatis-Plus与MyBatis区别：导入坐标不同；数据层实现简化。①：在pom.xml手动添加SpringBoot整合MyBatis-Plus的坐标，可以通过mvnrepository获取  ②：在dao层里......
  • java加快批量插入的两个方法
    一：配置参数：关于rewriteBatchedStatements这个参数介绍：MySQL的JDBC连接的url中要加rewriteBatchedStatements参数，并保证5.1.13以上版本的驱动，才能实现高性能的批量插入。......
  • Go使用协程批量获取数据，加快接口返回速度
    服务端经常需要返回一个列表，里面包含很多用户数据，常规做法当然是遍历然后读缓存。使用Go语言后，可以并发获取，极大提升效率。使用channelpackagemainimport("fmt"......
  • MybatisPlus 多表关联分页关联查询
     我这里提供的是mybatisplus和xml配置文件结合的方式：直接从service层开始写：service//这是service层，多表分页的简单逻辑处理，重点是IPage和Map，//IPage就是分......
  • 【spring-boot-route（七）整合jdbcTemplate操作数据库+（八）整合mybatis操作数据库】
    在一部分内容中，我们学习了Restful接口的编写，及接口文档的生成。我们需要将接口数据进行持久化存储，这一部分我们主要学习几种持久化框架将数据进行存储。本部分内容中，我们都......
  • delphi FireDAC使用ApplyUpdates批量提交数据
    简单的设计一下界面,大致如下:要求:审核或者反审核用户选择的数据1.当记录已审核时,再点审核会提示出错,反审核也一样2.正常点审核时,审核=true,审核人=当前用......
  • 013_整合MyBatis（基础操作）
    SPringBoot整合MyBatis：①：创建新模块，选择Spring初始化，并配置模块相关基础信息 ②：选择当前模块需要使用的技术集（MyBatis、MySQL）   ③：设置数据源参数（数据库连......
  • mybatis 没写sql语句，怎么知道去查哪张表呢
      我们在继承BaseMapper时，指定了泛型是<User>，默认就把类的名称User作为表名称、把类中的属性作为数据库字段。不区分大小写......
  • Postman 的批量登录案例
    Postman的批量登录案例在并发项目中，需要测试多用户场景下的超买超卖项目中的用户登录状态检测使用redis中的token因此为了模拟多用户下单的情况，需要足够多的活跃用户，......

赞助商

阅读排行

网站主页关于我们联系我们网站地图

本网站内容转载自其他媒体，侵权联系[admin##ips99.com]。

Copyright © 2020-2023 IPS99 版权所有 IPS99