mybatis |
您所在的位置：网站首页 › mybatis-plus的update › mybatis |
mybatis
|
mybatis-plus关于savebatch,saveorupdatebatch遇到的坑及解决办法
一.背景 最近mybatis-plus框架的更新，让我们基础开发中如虎添翼。其中基本的增删改查，代码生成器想必大家用着那叫一个爽。本人在使用中，也遇到一些坑。比如savebatch,saveorupdatebatch，看着这不是批量新增，批量新增或更新嘛，看着api进行开发，感觉也太好用啦。开发完一测试，速度跟蜗牛一样，针对大数据量真是无法忍受。在控制台上发现，怎么名义上是批量插入，还是一条一条的进行插入，难怪速度龟速。 二.解决办法 查阅网上资料，大体有两种解决方案： （1）.使用mybatis的xml,自己进行sql语句编写。该方法一个缺点是如果表的字段较多，有个几十个字段，写批量新增，批量新增修改的sql语句真是个噩梦。 INSERT INTO t (id, age) VALUES (3, 28), (4, 29) ON DUPLICATE KEY UPDATE id = VALUES(id), age = VALUES(age);(2)mybatis-plus 新添加了一个sql注入器，通过sql注入器可以实现批量新增，批量新增修改功能。一次注入，随时使用，使用极其方便。缺点就是项目启动时候，会进行sql注入器注册，稍微影响启动速度。 三.sql注入器实现批量更新，批量新增或更新功能 (1)自定义mapper接口，继承BaseMapper，定义实现的方法。 import com.baomidou.mybatisplus.core.mapper.BaseMapper; import org.apache.ibatis.annotations.Param; import java.util.List; /** * 根Mapper，给表Mapper继承用的，可以自定义通用方法 * {@link BaseMapper} * {@link com.baomidou.mybatisplus.extension.service.IService} * {@link com.baomidou.mybatisplus.extension.service.impl.ServiceImpl} */ public interface RootMapper extends BaseMapper { /** * 自定义批量插入 * 如果要自动填充，@Param(xx) xx参数名必须是 list/collection/array 3个的其中之一 */ int insertBatch(@Param("list") List list); /** * 自定义批量新增或更新 * 如果要自动填充，@Param(xx) xx参数名必须是 list/collection/array 3个的其中之一 */ int mysqlInsertOrUpdateBath(@Param("list") List list); }（2）批量插入、批量新增或更新具体方法实现 批量插入具体方法实现如下： import com.baomidou.mybatisplus.core.injector.AbstractMethod; import com.baomidou.mybatisplus.core.metadata.TableInfo; import lombok.extern.slf4j.Slf4j; import org.apache.ibatis.executor.keygen.NoKeyGenerator; import org.apache.ibatis.mapping.MappedStatement; import org.apache.ibatis.mapping.SqlSource; /** * 批量插入方法实现 */ @Slf4j public class InsertBatchMethod extends AbstractMethod { /** * insert into user(id, name, age) values (1, "a", 17), (2, "b", 18); insert into user(id, name, age) values #{item.id}, #{item.name}, #{item.age} */ @Override public MappedStatement injectMappedStatement(Class mapperClass, Class modelClass, TableInfo tableInfo) { final String sql = "insert into %s %s values %s"; final String fieldSql = prepareFieldSql(tableInfo); final String valueSql = prepareValuesSql(tableInfo); final String sqlResult = String.format(sql, tableInfo.getTableName(), fieldSql, valueSql); log.debug("sqlResult----->{}", sqlResult); SqlSource sqlSource = languageDriver.createSqlSource(configuration, sqlResult, modelClass); // 第三个参数必须和RootMapper的自定义方法名一致 return this.addInsertMappedStatement(mapperClass, modelClass, "insertBatch", sqlSource, new NoKeyGenerator(), null, null); } private String prepareFieldSql(TableInfo tableInfo) { StringBuilder fieldSql = new StringBuilder(); fieldSql.append(tableInfo.getKeyColumn()).append(","); tableInfo.getFieldList().forEach(x -> { fieldSql.append(x.getColumn()).append(","); }); fieldSql.delete(fieldSql.length() - 1, fieldSql.length()); fieldSql.insert(0, "("); fieldSql.append(")"); return fieldSql.toString(); } private String prepareValuesSql(TableInfo tableInfo) { final StringBuilder valueSql = new StringBuilder(); valueSql.append(""); valueSql.append("#{item.").append(tableInfo.getKeyProperty()).append("},"); tableInfo.getFieldList().forEach(x -> valueSql.append("#{item.").append(x.getProperty()).append("},")); valueSql.delete(valueSql.length() - 1, valueSql.length()); valueSql.append(""); return valueSql.toString(); } }批量插入或更新具体方法如下： import com.baomidou.mybatisplus.core.injector.AbstractMethod; import com.baomidou.mybatisplus.core.metadata.TableInfo; import org.apache.ibatis.executor.keygen.NoKeyGenerator; import org.apache.ibatis.mapping.MappedStatement; import org.apache.ibatis.mapping.SqlSource; import org.springframework.util.StringUtils; public class MysqlInsertOrUpdateBath extends AbstractMethod { @Override public MappedStatement injectMappedStatement(Class mapperClass, Class modelClass, TableInfo tableInfo) { final String sql = "insert into %s %s values %s ON DUPLICATE KEY UPDATE %s"; final String tableName = tableInfo.getTableName(); final String filedSql = prepareFieldSql(tableInfo); final String modelValuesSql = prepareModelValuesSql(tableInfo); final String duplicateKeySql =prepareDuplicateKeySql(tableInfo); final String sqlResult = String.format(sql, tableName, filedSql, modelValuesSql,duplicateKeySql); //System.out.println("savaorupdatesqlsql="+sqlResult); SqlSource sqlSource = languageDriver.createSqlSource(configuration, sqlResult, modelClass); return this.addInsertMappedStatement(mapperClass, modelClass, "mysqlInsertOrUpdateBath", sqlSource, new NoKeyGenerator(), null, null); } /** * 准备ON DUPLICATE KEY UPDATE sql * @param tableInfo * @return */ private String prepareDuplicateKeySql(TableInfo tableInfo) { final StringBuilder duplicateKeySql = new StringBuilder(); if(!StringUtils.isEmpty(tableInfo.getKeyColumn())) { duplicateKeySql.append(tableInfo.getKeyColumn()).append("=values(").append(tableInfo.getKeyColumn()).append("),"); } tableInfo.getFieldList().forEach(x -> { duplicateKeySql.append(x.getColumn()) .append("=values(") .append(x.getColumn()) .append("),"); }); duplicateKeySql.delete(duplicateKeySql.length() - 1, duplicateKeySql.length()); return duplicateKeySql.toString(); } /** * 准备属性名 * @param tableInfo * @return */ private String prepareFieldSql(TableInfo tableInfo) { StringBuilder fieldSql = new StringBuilder(); fieldSql.append(tableInfo.getKeyColumn()).append(","); tableInfo.getFieldList().forEach(x -> { fieldSql.append(x.getColumn()).append(","); }); fieldSql.delete(fieldSql.length() - 1, fieldSql.length()); fieldSql.insert(0, "("); fieldSql.append(")"); return fieldSql.toString(); } private String prepareModelValuesSql(TableInfo tableInfo){ final StringBuilder valueSql = new StringBuilder(); valueSql.append(""); if(!StringUtils.isEmpty(tableInfo.getKeyProperty())) { valueSql.append("#{item.").append(tableInfo.getKeyProperty()).append("},"); } tableInfo.getFieldList().forEach(x -> valueSql.append("#{item.").append(x.getProperty()).append("},")); valueSql.delete(valueSql.length() - 1, valueSql.length()); valueSql.append(""); return valueSql.toString(); } }（3）sql注入器实现 import com.baomidou.mybatisplus.core.injector.AbstractMethod; import com.baomidou.mybatisplus.core.injector.DefaultSqlInjector; import java.util.List; /** * 自定义方法SQL注入器 */ public class CustomizedSqlInjector extends DefaultSqlInjector { /** * 如果只需增加方法，保留mybatis plus自带方法， * 可以先获取super.getMethodList()，再添加add */ @Override public List getMethodList(Class mapperClass) { List methodList = super.getMethodList(mapperClass); methodList.add(new InsertBatchMethod()); methodList.add(new UpdateBatchMethod()); methodList.add(new MysqlInsertOrUpdateBath()); return methodList; } }（4）在自己想使用的mapper上继承自定义的mapper. import com.sy.adp.common.mybatisPlusExtend.RootMapper; import com.sy.adp.flowfull.entity.InfMpmPds; import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import org.apache.ibatis.annotations.Param; import org.springframework.stereotype.Component; @Component public interface InfMpmPdsMapper extends RootMapper { IPage selectPageList(Page page, @Param("infMpmPds") InfMpmPds infMpmPds); }(5)在controller或serviceImpi中引入mapper,使用自定义的方法。 >>>>>>>>>>>>>>>>>>>>引入mapper>>>>>>>>>>>>>>>
>>>>>>>>>>>>>>>>>>>>>>>>>方法使用>>>>>>>>>>>>
完成上述步骤，就可以运行项目进行测试看看，数据提升是不是几个数量级。 关于mybatis-plus 关于savebatch,saveorupdatebatch遇到的坑及解决办法的文章就介绍至此，更多相关mybatis-plus savebatch,saveorupdatebatch内容请搜索编程宝库以前的文章，希望以后支持编程宝库！ 下一节：详解MyBatis-Puls中saveBatch批量添加慢的问题Java编程技术问题在项目过程中使用MyBatis-Puls的saveBatch一次性添加大量数据时很慢 原因MyBatis-Puls的saveBatch默认并没有批量 ... |
【本文地址】
今日新闻 |
推荐新闻 |