mybatis批量插入、mybatis-plus批量插入、mybatis实现insertList、mybatis ...

众所周知，mybatisplus提供的BaseMapper里只有单条插入的方法，没有批量插入的方法，
而在Service层的批量插入并不是真的批量插入，实际上是遍历insert，但也不是一次insert就一次IO，而是到一定数目才会去IO一次，性能不是很差，但也不够好。
怎么才气实现真正的批量插入呢？
这里是mybatisplus官方的演示仓库，可以先去了解一下。
一、mybatis新增批量插入

1.1、引入依赖

本文基于mybatis-plus3.5.0举行讲解，不同的版本写法稍微有点不同。

1. <!--mybatis-plus-->
2. <dependency>
3.      <groupId>com.baomidou</groupId>
4.      <artifactId>mybatis-plus-boot-starter</artifactId>
5.      <version>3.5.0</version>
6. </dependency>

复制代码

1.2、自定义通用批量插入Mapper

1.新建一个InsertListMapper文件，提供insertList方法，后续需要用到批量插入的dao继续该Mapper即可拥有批量插入接口。

1. import org.apache.ibatis.annotations.Param;
2. import java.util.List;
4. /**
5. * 通用Mapper接口,特殊方法，批量插入，支持批量插入的数据库都可以使用，例如mysql,h2等
6. *
7. * @param <T> 不能为空
8. * @author
9. */
10. public interface InsertListMapper<T> {
11.     /**
12.      * 批量插入，支持批量插入的数据库可以使用，例如MySQL,H2等
13.      * <p>
14.      * 注意：
15.      * 1.若实体类中设置了@TableId注解，则需要设置value值  如：@TableId(value = "id")
16.      * 2.若建表语句中设置了default, 需要在插入时手动设置默认值，否则存储的是null。
17.      * 如：delete_flag tinyint default 0 comment '删除标志 0-未删除 1-已删除'，这种需要在insert的时候设置实体类改字段值。setDeleteFlag(0)
18.      * <p>
19.      *
20.      * @param recordList
21.      * @return
22.      */
23.     int insertList(@Param("list") List<T> recordList);
24. }

复制代码

1.3、把通用方法注册到mybatisplus注入器中

1. import com.baomidou.mybatisplus.core.injector.AbstractMethod;
2. import com.baomidou.mybatisplus.core.injector.DefaultSqlInjector;
3. import com.baomidou.mybatisplus.core.metadata.TableInfo;
4. import org.springframework.stereotype.Component;
6. import java.util.List;
8. /**
9. * 添加Sql注入方法,支持空字段更新
10. */
11. @Component
12. public class CustomerSqlInjector extends DefaultSqlInjector {
13.     @Override
14.     public List<AbstractMethod> getMethodList(Class<?> mapperClass, TableInfo tableInfo){
15.         List<AbstractMethod> methodList=super.getMethodList(mapperClass, tableInfo);
16.         //注册自定义方法
17.         //注意：InsertList中的name需要与xxxMapper中的方法名一致，即insertList
18.         methodList.add(new InsertList("insertList"));
20.         return methodList;
21.     }
22. }

复制代码

关键的一句在于methodList.add(new InsertList("insertList"));，意为注册一个新的方法叫insertList，详细实如今InsertList类。
1.4、实现InsertList类

1. import com.baomidou.mybatisplus.core.injector.AbstractMethod;
2. import com.baomidou.mybatisplus.core.metadata.TableInfo;
3. import org.apache.ibatis.executor.keygen.KeyGenerator;
4. import org.apache.ibatis.executor.keygen.NoKeyGenerator;
5. import org.apache.ibatis.mapping.MappedStatement;
6. import org.apache.ibatis.mapping.SqlSource;
7. import java.util.Collections;
9. public class InsertList extends AbstractMethod {
11.     public InsertList(String name) {
12.         super(name);
13.     }
15.     @Override
16.     public MappedStatement injectMappedStatement(Class<?> mapperClass, Class<?> modelClass, TableInfo tableInfo) {
17.         KeyGenerator keyGenerator = new NoKeyGenerator();
18.         SqlSource sqlSource = languageDriver.createSqlSource(configuration, getBatchInsertSql(tableInfo,modelClass), Collections.class);
19.         return this.addInsertMappedStatement(mapperClass,modelClass,"insertList",sqlSource,keyGenerator,null,null);
21.     }
23.     private String getBatchInsertSql(TableInfo tableInfo, Class<?> modelClass){
24.         String batchInsertSql="<script> INSERT INTO %s (%s) values %s</script>";
26.         //要插入的字段 即insert into table(要插入的字段) values
27.         StringBuilder insertColumnSql=new StringBuilder();
28.         insertColumnSql.append(tableInfo.getKeyColumn()).append(",");
30.         StringBuilder valueSql=new StringBuilder();
31.         valueSql.append("<foreach collection='list' item='item' open='(' separator='),(' close=')' >\n");
32.         valueSql.append("#{item."+tableInfo.getKeyProperty()+"},");
34.         tableInfo.getFieldList().forEach(x->{
35.             insertColumnSql.append(x.getColumn()).append(",");
36.             valueSql.append("#{item."+x.getProperty()+"},");
37.         });
39.         insertColumnSql.delete(insertColumnSql.length()-1,insertColumnSql.length());
40.         valueSql.delete(valueSql.length()-1,valueSql.length());
41.         valueSql.append("</foreach>");
43.         return  String.format(batchInsertSql,tableInfo.getTableName(),insertColumnSql,valueSql);
44.     }
46. }

复制代码

1.5、需要批量插入的dao层继续批量插入Mapper

1. import com.baomidou.mybatisplus.core.mapper.BaseMapper;
2. import com.demo.common.mapper.InsertListMapper;
3. import com.demo.entity.User;
5. /**
6. * @Entity generator.domain.User
7. */
8. public interface UserMapper extends BaseMapper<User>, InsertListMapper<User> {
11. }

复制代码

以上代码全都放在gitee仓库，详情见：
代码仓库地点
二、大概遇到的题目

2.1、Invalid bound statement

1. org.apache.ibatis.binding.BindingException: Invalid bound statement (not found): com.demo.mapper.User1Mapper.insertList
3.         at org.apache.ibatis.binding.MapperMethod$SqlCommand.<init>(MapperMethod.java:235)
4.         at com.baomidou.mybatisplus.core.override.MybatisMapperMethod.<init>(MybatisMapperMethod.java:50)
5.         at com.baomidou.mybatisplus.core.override.MybatisMapperProxy.lambda$cachedInvoker$0(MybatisMapperProxy.java:111)
6.         at java.util.concurrent.ConcurrentHashMap.computeIfAbsent(ConcurrentHashMap.java:1660)
7.         at com.baomidou.mybatisplus.core.toolkit.CollectionUtils.computeIfAbsent(CollectionUtils.java:115)
8.         at com.baomidou.mybatisplus.core.override.MybatisMapperProxy.cachedInvoker(MybatisMapperProxy.java:98)
9.         at com.baomidou.mybatisplus.core.override.MybatisMapperProxy.invoke(MybatisMapperProxy.java:89)
10.         at com.sun.proxy.$Proxy70.insertList(Unknown Source)
11.         at com.demo.User1Test.test1(User1Test.java:50)
12.         at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
13.         at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
14.         at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
15.         at java.lang.reflect.Method.invoke(Method.java:498)
16.         at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50)
17.         at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
18.         at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
19.         at org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)

复制代码

办理方法： ：https://blog.csdn.net/weixin_49114503/article/details/140645048






参考文章：https://blog.csdn.net/m0_51390969/article/details/134730527
https://blog.csdn.net/m0_63297646/article/details/131843517

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。