Mybatis-plus批量插入的2種方式總結
前言
Mybatis-plus很強,為我們誕生了極簡CURD操作,但對于數據批量操作,顯然默認提供的insert方法是不夠看的了,于是它和它來了!!! Mybatis-plus提供的兩種插入方式
- 繼承IService(偽批量)
- insertBatchSomeColumn
一、繼承IService(偽批量)
在Mapper繼承BaseMapper<T>
import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.example.demo.entity.UserStudy; import org.apache.ibatis.annotations.Mapper; @Mapper public interface UserStudyMapper extends BaseMapper<UserStudy> { }
在Service中繼承IService<T>
import com.baomidou.mybatisplus.extension.service.IService; import com.example.demo.entity.UserStudy; /******************************************************************************** ** @author : ZYJ ** @date :2023/04/20 ** @description :廠長老婆催的睡覺了-批量插入Service *********************************************************************************/ public interface UserStudyService extends IService<UserStudy> { }
在Service實現類繼承ServiceImpl<M,T>
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.example.demo.entity.UserStudy; import com.example.demo.mapper.UserStudyMapper; import org.springframework.stereotype.Service; import javax.annotation.Resource; /******************************************************************************** ** @author : ZYJ ** @date :2023/04/04 ** @description :廠長加班寫代碼-批量插入 *********************************************************************************/ @Service public class UserStudyServiceImpl extends ServiceImpl<UserStudyMapper, UserStudy> implements UserStudyService { @Resource private UserStudyMapper userStudyMapper; }
測試代碼,調用IService的saveBatch方法
/* *批量插入 */ @Override public void greatMany() { List<UserStudy> userStudyList = new ArrayList<>(); UserStudy userStudy1 = new UserStudy(); userStudy1.setName("張三"); UserStudy userStudy2 = new UserStudy(); userStudy2.setName("李四"); userStudyList.add(userStudy1); userStudyList.add(userStudy2); //調用IService的saveBatch方法 this.saveBatch(userStudyList); }
Mybatis-plus的SQL日志打印在配置文件application.yml配置
mybatis-plus: configuration: log-impl: org.apache.ibatis.logging.stdout.StdOutImpl #開啟sql日志 # log-impl: org.apache.ibatis.logging.nologging.NoLoggingImpl #關閉sql日志
測試結果,代碼執(zhí)行打印了兩條SQL,所以可以看得出saveBatch底層也是遍歷循環(huán)完成
saveBatch方法分析
底層也是通過for來完成,默認是一個事務一次提交1000條數據,點擊進入saveBatch可以看到, 也可以自定義每次提交多少條,自定義如下
//調用IService的saveBatch方法 this.saveBatch(userStudyList,2000);
二、insertBatchSomeColumn
自定義SQL注入器
import com.baomidou.mybatisplus.core.injector.AbstractMethod; import com.baomidou.mybatisplus.core.injector.DefaultSqlInjector; import com.baomidou.mybatisplus.extension.injector.methods.InsertBatchSomeColumn; import java.util.List; /******************************************************************************** ** @author : ZYJ ** @date :2023/03/09 ** @description :廠長加班寫代碼-批量插入SQL注入器 *********************************************************************************/ public class InsertBatchSqlInjector extends DefaultSqlInjector { @Override public List<AbstractMethod> getMethodList(Class<?> mapperClass) { List<AbstractMethod> methodList = super.getMethodList(mapperClass); methodList.add(new InsertBatchSomeColumn()); //添加InsertBatchSomeColumn方法 return methodList; } }
把SQL注入器交給Spring
import org.springframework.context.annotation.Bean; import org.springframework.stereotype.Component; @Component public class MybatisPlusConfig { /******************************************************************************** ** @author : ZYJ ** @date :2023/04/14 ** @description :注入配置 *********************************************************************************/ @Bean public InsertBatchSqlInjector easySqlInjector () { return new InsertBatchSqlInjector(); } }
到此定義完畢,在Mapper中生成insertBatchSomeColumn(必須是這個方法名)方法,你就可以撒手不管了,直接調用就行,或者直接在ServiceImpl通過Mapper調用insertBatchSomeColumn,然后ALT+回車生成此方法。
import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.example.demo.entity.UserStudy; import org.apache.ibatis.annotations.Mapper; import org.apache.ibatis.annotations.Param; import java.util.List; @Mapper public interface UserStudyMapper extends BaseMapper<UserStudy> { void insertBatchSomeColumn(@Param("list") List<UserStudy> userStudyList); }
測試代碼,調用insertBatchSomeColumn方法
@Resource private UserStudyMapper userStudyMapper; /* *批量插入 */ @Override public void greatMany() { List<UserStudy> userStudyList = new ArrayList<>(); UserStudy userStudy1 = new UserStudy(); userStudy1.setName("張三"); UserStudy userStudy2 = new UserStudy(); userStudy2.setName("李四"); userStudyList.add(userStudy1); userStudyList.add(userStudy2); //調用insertBatchSomeColumn方法 userStudyMapper.insertBatchSomeColumn(userStudyList); //調用IService的saveBatch方法 //this.saveBatch(userStudyList,2000); }
測試結果,代碼執(zhí)行打印一條SQL,所以可以看出是一條SQL便新增完成
注意:SQL有語句長度限制,在MySQL中被參數max_allowed_packet限制,默認為1M,如果拼接長度超過此限制就會報錯,兩種解決方式,一個是調整MySQL的max_allowed_packet 限制,另一個則是通過代碼控制每次的提交數量。
通過代碼控制每次提交數量,模擬造五條數據,每次提交兩條數據
/* *批量插入 */ @Override public void greatMany() { List<UserStudy> userStudyList = new ArrayList<>(); UserStudy userStudy1 = new UserStudy(); userStudy1.setName("張三"); UserStudy userStudy2 = new UserStudy(); userStudy2.setName("李四"); UserStudy userStudy3 = new UserStudy(); userStudy3.setName("王五"); UserStudy userStudy4 = new UserStudy(); userStudy4.setName("趙六"); UserStudy userStudy5 = new UserStudy(); userStudy5.setName("小紅"); userStudyList.add(userStudy1); userStudyList.add(userStudy2); userStudyList.add(userStudy3); userStudyList.add(userStudy4); userStudyList.add(userStudy5); //創(chuàng)建入庫的list List<UserStudy> userStudyCount = new ArrayList<>(); for (int i = 0; i < userStudyList.size(); i++) { //調用insertBatchSomeColumn方法 userStudyCount.add(userStudyList.get(i)); //控制每次提交數量 if(userStudyCount.size()==2){ userStudyMapper.insertBatchSomeColumn(userStudyCount); //將入庫的list清空重新新增 userStudyCount.clear(); } } //將list中size不夠2的數據在此處新增 userStudyMapper.insertBatchSomeColumn(userStudyCount); //調用IService的saveBatch方法 //this.saveBatch(userStudyList,2000); }
結果分析,五條數據應該請求三次新增,打印三條SQL,完美結束
總結:
默認的insert的方法對尋常業(yè)務來說是非常之高效,但對于批量數據的產生確實災難性的,就是慢,很慢,巨慢,IService的saveBatch方法優(yōu)于默認的insert方法,但是我選通過SQL注入器的方法insertBatchSomeColumn。
到此這篇關于Mybatis-plus批量插入的2種方式總結的文章就介紹到這了,更多相關Mybatis-plus批量插入內容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家!
相關文章
springmvc+mybatis 做分頁sql 語句實例代碼
本文通過一段實例代碼給大家介紹了springmvc+mybatis 做分頁sql 語句的方法,代碼簡單易懂,非常不錯,具有參考借鑒價值,需要的朋友參考下吧2017-07-07關于Spring的AnnotationAwareAspectJAutoProxyCreator類解析
這篇文章主要介紹了關于Spring的AnnotationAwareAspectJAutoProxyCreator類解析,Spring是一個開源免費的框架 , 容器,是一個輕量級的框架 ,需要的朋友可以參考下2023-05-05