基于mybatis batch实现批量提交大量数据

 更新时间:2020年05月30日 11:27:57   作者:随风而逝,只是飘零  
这篇文章主要介绍了基于mybatis batch实现批量提交大量数据,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下

很多人在用 MyBatis 或者 通用 Mapper 时,经常会问有没有批量插入和批量更新的方法。

实际上许多时候没必要用 <foreach> 去实现特别复杂的批量操作。直接通过 MyBatis 的 BATCH 方式执行增删改方法即可。

下面是一个批量用法的例子:

在xml文件配置多条参数同时插入:

<insert id="insertBatch2" parameterType="ctas.entity.SharkFlt">
   <selectKey keyProperty="recId" order="BEFORE" resultType="Long">
   select SEQ_CTAS_SHARK_FLT.nextval as recId from dual
  </selectKey>
   insert into CTAS_SHARK_FLT (<include refid="Base_Column_List"/>) SELECT SEQ_TEST.NEXTVAL, A.*
   FROM (
   <foreach collection="list" item="item" index="index" open="" close="" separator="union all">
    select #{item.awbType,jdbcType=VARCHAR}, #{item.awbPre,jdbcType=VARCHAR},... from dual
 </foreach>
  ) A
 </insert>

在Java代码中,oracle中一次执行的sql语句长度是有限制的,如果最后拼出来的sql字符串过长,会导致执行失败,所以java端还要做一个分段处理,参考下面的处理:

List<SharkFlt> data = new ArrayList<SharkFlt>();
     for (TSharkFlt f : sharkFlts) {
       data.add(getSharkFlt(f));
     }
 
    System.out.println(data.size());
     long beginTime = System.currentTimeMillis();
    System.out.println("开始插入...");
     SqlSessionFactory sqlSessionFactory 
=ctx.getBean(SqlSessionFactory.class);
     SqlSession session = null;
    try {
       session = sqlSessionFactory.openSession(ExecutorType.BATCH, false);
       int a = 2000;//每次提交2000条
       int loop = (int) Math.ceil(data.size() / (double) a);
 
       List<SharkFlt> tempList = new ArrayList<SharkFlt>(a);
      int start, stop;
      for (int i = 0; i < loop; i++) {
        tempList.clear();
        start = i * a;
        stop = Math.min(i * a + a - 1, data.size() - 1);
        System.out.println("range:" + start + " - " + stop);
        for (int j = start; j <= stop; j++) {
           tempList.add(data.get(j));
        }
         session.insert("ctas.importer.writer.mybatis.mappper.SharkFltMapper.insertBatch2", tempList);
        session.commit();
        session.clearCache();
         System.out.println("已经插入" + (stop + 1) + " 条");
       }
     } catch (Exception e) {
       e.printStackTrace();
       session.rollback();
    } finally {
      if (session != null) {
        session.close();
      }
     }
    long endTime = System.currentTimeMillis();
    System.out.println("插入完成,耗时 " + (endTime - beginTime) + " 毫秒!");

以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持脚本之家。

相关文章

  • 使用Maven打包时包含资源文件和源码到jar的方法

    使用Maven打包时包含资源文件和源码到jar的方法

    这篇文章主要介绍了使用Maven打包时包含资源文件和源码到jar的方法,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
    2022-08-08
  • 详解如何为SpringBoot Web应用的日志方便追踪

    详解如何为SpringBoot Web应用的日志方便追踪

    在Web应用程序领域,有效的请求监控和可追溯性对于维护系统完整性和诊断问题至关重要,SpringBoot是一种用于构建Java应用程序的流行框架,在本文中,我们探讨了在SpringBoot中向日志添加唯一ID的重要性,需要的朋友可以参考下
    2023-11-11
  • RabbitMQ实现消息可靠性传递过程讲解

    RabbitMQ实现消息可靠性传递过程讲解

    消息的可靠性传递是指保证消息百分百发送到消息队列中去,这篇文章主要介绍了RabbitMQ实现消息可靠性传递过程,感兴趣想要详细了解可以参考下文
    2023-05-05
  • ZooKeeper入门教程三分布式锁实现及完整运行源码

    ZooKeeper入门教程三分布式锁实现及完整运行源码

    本文是ZooKeeper入门系列教程,分布式锁有多种实现方式,比如通过数据库、redis都可实现。作为分布式协同工具ZooKeeper,当然也有着标准的实现方式。本文介绍在zookeeper中如何实现排他锁
    2022-01-01
  • Java零基础入门数组

    Java零基础入门数组

    数组对于每一门编程语言来说都是重要的数据结构之一,当然不同语言对数组的实现及处理也不尽相同。Java 语言中提供的数组是用来存储固定大小的同类型元素
    2022-04-04
  • Spring Boot 整合 Mockito提升Java单元测试的高效实践案例

    Spring Boot 整合 Mockito提升Java单元测试的高效实践案例

    Mockito与Spring Boot的整合为Java开发者提供了一套完整的解决方案,使得单元测试更为精准、高效,从而确保了代码质量、降低了维护成本,并促进了项目的持续集成与交付,感兴趣的朋友跟随小编一起看看吧
    2024-04-04
  • Java中的Null到底是什么

    Java中的Null到底是什么

    null是没有地址,""是有地址但是里面的内容是空的,好比做饭 null说明连锅都没有 而""则是有锅没米,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,下面我们来详细学习一下它吧
    2019-06-06
  • 深入理解可视化JVM 故障处理工具

    深入理解可视化JVM 故障处理工具

    这篇文章主要介绍了深入理解可视化JVM 故障处理工具,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2020-10-10
  • 详解用Spring Boot零配置快速创建web项目

    详解用Spring Boot零配置快速创建web项目

    本篇文章主要介绍了详解用Spring Boot零配置快速创建web项目,具有一定的参考价值,感兴趣的小伙伴们可以参考一下。
    2017-03-03
  • 深入解析System.load 与 System.loadLibrary

    深入解析System.load 与 System.loadLibrary

    以下是对System.load与System.loadLibrary进行了详细的分析介绍。需要的朋友可以过来参考下
    2013-08-08

最新评论