`

Mybatis批量操作

 
阅读更多
Mybatis批量操作有两种方式:
  (1) 在mapper.xml文件动态生成多条sql语句,生成的sql语句类似如下:
      <insert id="insert" parameterType="sdc.mybatis.test.Student">
          <!-- WARNING - @mbggenerated This element is automatically generated by
               MyBatis Generator, do not modify. This element was generated on Mon May 09
               11:09:37 CST 2011. -->
          insert into student (id, name, sex,
          address, telephone, t_id
          )
          values (#{id,jdbcType=INTEGER}, #{name,jdbcType=VARCHAR},
          #{sex,jdbcType=VARCHAR},
          #{address,jdbcType=VARCHAR}, #{telephone,jdbcType=VARCHAR}, #{tId,jdbcType=INTEGER}
          )
       </insert>   
      
  (2) 使用sqlSessionFactory.openSession(ExecutorType.BATCH, false)开启一个批量操作的session,后续使用从session中获取的mapper对象进行数据库操作时,自动会采用JDBC的批量操作,但前提是:必须连续调用某一个mapper对象的方法,否则会产生多个PrepareStatement对象。数量过大后会导致“超出打开游标的最大数”异常
 
    Mybatis代码举例:
    结论:batchInserts1方法只使用两个Cursor而batchInserts2会使用6000个Cursour。区别在于方法2中对mapper的方法进行了交叉调用
    代码:
     public void batchInserts1() {
        String clientId = "102101000004";

        SqlSession sqlSession = sqlSessionFactory.openSession(ExecutorType.BATCH, false);
        try {
            DeviceDataMapper deviceDataMapper = sqlSession.getMapper(DeviceDataMapper.class);
            RfGprsTagDataMapper tagDataMapper = sqlSession.getMapper(RfGprsTagDataMapper.class);
            for (int i = 0; i < 3000; i++) {
                DeviceData deviceData = new DeviceData();
                deviceData.setClientId(clientId);
                deviceData.setDeviceId("6");
                deviceData.setRecId(BigDecimal.valueOf(UIDUtils.getInstance().generateUID(UIDTypeCode.DEVICEDATA).longValue()));
                deviceData.setCreatedBy(4L);
                deviceDataMapper.insert(deviceData);
            }
            for (int i = 0; i < 3000; i++) {
                RfGprsTagData tagData = new RfGprsTagData();
                tagData.setClientId(clientId);
                tagData.setTagId("F01000000000000000000194");
                tagData.setRecId(BigDecimal.valueOf(UIDUtils.getInstance().generateUID(UIDTypeCode.RFGPRSTAGDATA)
                        .longValue()));
                tagData.setCreatedBy(4L);
                tagDataMapper.insert(tagData);
            }
            sqlSession.commit();
        } catch (Exception e) {
            e.printStackTrace();
            sqlSession.rollback();
        } finally {
            sqlSession.close();
        }
    }

    public void batchInserts2() {
        String clientId = "102101000004";

        SqlSession sqlSession = sqlSessionFactory.openSession(ExecutorType.BATCH, false);
        try {
            DeviceDataMapper deviceDataMapper = sqlSession.getMapper(DeviceDataMapper.class);
            RfGprsTagDataMapper tagDataMapper = sqlSession.getMapper(RfGprsTagDataMapper.class);
            for (int i = 0; i < 3000; i++) {
                DeviceData deviceData = new DeviceData();
                deviceData.setClientId(clientId);
                deviceData.setDeviceId("6");
                deviceData.setRecId(BigDecimal.valueOf(UIDUtils.getInstance().generateUID(UIDTypeCode.DEVICEDATA).longValue()));
                deviceData.setCreatedBy(4L);
                deviceDataMapper.insert(deviceData);
               
                RfGprsTagData tagData = new RfGprsTagData();
                tagData.setClientId(clientId);
                tagData.setTagId("F01000000000000000000194");
                tagData.setRecId(BigDecimal.valueOf(UIDUtils.getInstance().generateUID(UIDTypeCode.RFGPRSTAGDATA).longValue()));
                tagData.setCreatedBy(4L);
                tagDataMapper.insert(tagData);
            }
            sqlSession.commit();
        } catch (Exception e) {
            e.printStackTrace();
            sqlSession.rollback();
        } finally {
            sqlSession.close();
        }
    }


PS: 游标说明
         1.对于oracle中Cursor分隐式和显式的两种,具体的定义可以自行去网上查下,Cursor数量在oracle里有限制的,而且也有一定量的内存消耗,同时打开的数量越大,内存的消耗肯定越大。
         2. JDBC里对Cursor打开和关闭对应如下:
            a. 只要创建一个statement对象就会打开一个Cursor
            b. 调用statement对象的close方法将会关闭相应的Cursor;
            c. 在执行Connection对象的close方法时也会去关闭该Connection对象所打开的所有Cursor(在忘执行statement对象的close方法时产生的)
分享到:
评论

相关推荐

    Mybatis批量foreach merge into的用法

    Mybatis批量foreach merge into的用法 Mybatis批量foreach merge into的用法是通过Mybatis的动态SQL语法foreach循环插入实现的,这种方法可以批量插入时间价格表数据。如果某个套餐的某天的价格存在,则更新,不...

    mybatis数据操作(增删改查+批量操作)

    在"mybatis数据操作(增删改查+批量操作)"这个主题中,我们将深入探讨如何利用MyBatis进行基本的数据操作,包括插入(Insert)、删除(Delete)、更新(Update)和查询(Select),以及如何执行批量操作。...

    Java实现mybatis批量插入数据到Oracle

    在Java开发中,MyBatis是一个非常流行的持久层框架,它简化了数据库操作,使得开发者可以更加专注于SQL语句的编写。本篇文章将详细介绍如何利用Java和MyBatis实现批量插入数据到Oracle数据库中。 首先,我们需要...

    mybatis plus 5种批量操作性能测试

    MyBatis Plus 是 MyBatis 的一个扩展,它在 MyBatis 的基础上提供了更多的便捷功能,包括但不限于批量操作。在数据库交互中,批量操作能够显著提高效率,减少数据库连接的开销。本测试主要探讨了 MyBatis Plus 中的...

    MyBatis批量插入Update

    * 不需要额外添加回滚处理:MyBatis批量插入可以自动处理回滚操作,无需额外添加回滚处理。 需要注意的是,MyBatis批量插入可能会出现内存不足的问题,因此需要提前修改MySql的配置文件,增加max_allowed_packet的...

    Mybatis与JDBC批量插入MySQL数据库性能测试

    通过这样的性能测试,我们可以了解到在特定场景下,Mybatis和JDBC哪个更适合批量插入操作。通常,Mybatis由于其封装和优化,可能会在易用性和性能之间取得更好的平衡。但具体选择应根据项目需求和实际环境进行权衡。...

    mybatis批量添加实现1

    【Mybatis批量添加实现详解】 在数据库操作中,批量插入数据是常见的需求,尤其是在处理大量数据时,批量插入能够显著提高效率。Mybatis,作为一款轻量级的持久层框架,提供了灵活的方式来处理批量添加。本文将详细...

    mybatis 通用分页插件和批量操作插件

    NULL 博文链接:https://hzs0502030128.iteye.com/blog/2254585

    MyBatis批量插入(insert)数据操作

    此外,对于支持批量操作的数据库(如MySQL),还可以利用数据库级别的批量插入API来进一步提升性能。 总的来说,MyBatis的批量插入功能结合了Java代码的灵活性和SQL的高效性,是处理大批量数据插入的理想选择。通过...

    Mybatis实现多表联合查询和批量插入

    Mybatis实现多表联合查询和批量插入 Mybatis是一款流行的持久层框架,它可以帮助开发者快速、高效地访问数据库。在实际开发中,经常需要对多个表进行联合查询,或者对大量数据进行批量插入。本文将详细介绍如何使用...

    Mybatis批量删除多表

    Mybatis批量删除多表 MyBatis是一个功能强大且灵活的持久层框架,它能够帮助开发者快速高效地实现数据的持久化操作。在实际开发中,我们经常需要对多个表进行批量删除操作,这时就需要使用MyBatis的批量删除功能。...

    Mybatis Plus 自定义批量插入或批量更新(根据唯一索引)

    Mybatis Plus 是 Mybatis 的一个扩展工具,它在 Mybatis 的基础上提供了许多便捷的功能,包括自动 CRUD 操作、条件构造器、批量操作等。在实际的项目开发中,批量插入和批量更新是常见的数据处理场景,尤其是在处理...

    Mybatis 3+Mysql 实现批量插入

    综上所述,利用MyBatis结合MySQL实现批量插入不仅可以大幅提高数据处理效率,还能有效降低系统资源消耗,是数据库操作中不可或缺的一项技能。通过上述详细讲解,相信读者已经对如何实现批量插入有了清晰的理解。

    Mybatis批量修改的操作代码

    Mybatis批量修改操作代码详解 Mybatis是一款流行的持久层框架,提供了批量修改操作的功能。本文将详细介绍Mybatis批量修改的操作代码,包括批量修改的基本语法、参数说明、trim标签的使用等。 一、基本语法 ...

    mybatis postgresql 批量删除操作方法

    MyBatis PostgreSQL 批量删除操作方法 MyBatis 是一个基于 Java 的持久层框架,它提供了一个简单的方式来交互数据库。在本文中,我们将介绍如何使用 MyBatis 实现 PostgreSQL 批量删除操作。 PostgreSQL 简介 ...

    mybatis 批量插入 嵌套select.pdf

    这个问题的描述是关于如何在MyBatis中正确地执行一个批量插入操作,其中一个字段的值依赖于对同一张表的SELECT查询结果。 原始的XML映射文件中的SQL插入语句尝试在FROM子句中直接更新目标表'chat_messages',这是不...

    MyBatis批量添加、修改和删除

    总结来说,MyBatis 提供的批量操作功能通过动态 SQL 和集合遍历来简化大量数据处理,提高了数据库操作的效率。开发者可以根据实际需求选择合适的批量操作方式,并通过编写 SQL 映射文件来定制操作逻辑。注意,批量...

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

    MyBatis批量提交大量数据是一种高效的数据批量操作方式,通过MyBatis的BATCH方式执行增删改方法,可以实现在短时间内处理大量数据。下面对MyBatis批量提交大量数据的实现进行了详细的介绍。 MyBatis批量提交的优点 ...

    SpringBoot使用mybatis批量新增500万数据到mysql数据库Demo

    在本项目中,我们主要探讨的是如何利用SpringBoot集成Mybatis框架进行大数据量(例如500万条)的批量插入操作,并将其高效地存入MySQL数据库。这个Demo旨在提供一个学习实例,帮助开发者理解并优化大数据处理的性能...

    Mybatis批量插入的四种方式.docx

    Mybatis批量插入的四种方式 Mybatis 是一个流行的 Java 持久层框架,提供了多种方式来实现批量插入操作。下面将详细介绍 Mybatis 批量插入的四种方式。 1. 循环插入 循环插入是最简单的批量插入方式,即通过循环...

Global site tag (gtag.js) - Google Analytics