详解mybatis 批量更新数据两种方法效率对比

 更新时间:2019年02月01日 14:42:13   作者:第一小菜鸟  
这篇文章主要介绍了详解mybatis 批量更新数据两种方法效率对比,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧

上节探讨了批量新增数据,这节探讨批量更新数据两种写法的效率问题。

实现方式有两种,

一种用for循环通过循环传过来的参数集合,循环出N条sql,

另一种 用mysql的case when 条件判断变相的进行批量更新  

下面进行实现。

注意第一种方法要想成功,需要在db链接url后面带一个参数  &allowMultiQueries=true

即:  jdbc:mysql://localhost:3306/mysqlTest?characterEncoding=utf-8&allowMultiQueries=true

其实这种东西写过来写过去就是差不多一样的代码,不做重复的赘述,直接上代码。

 <!-- 这次用resultmap接收输出结果 -->
  <select id="findByName" parameterType="string" resultMap="customerMap">
    select * from t_customer where c_name like concat('%', #{name},'%') order by c_ceroNo limit 0,100
  </select>
 
 
  <!-- 批量更新第一种方法,通过接收传进来的参数list进行循环着组装sql -->
  <update id="batchUpdate" parameterType="java.util.Map">
    <!-- 接收list参数,循环着组装sql语句,注意for循环的写法
       separator=";" 代表着每次循环完,在sql后面放一个分号
       item="cus" 循环List的每条的结果集
       collection="list" list 即为 map传过来的参数key -->
    <foreach collection="list" separator=";" item="cus">
      update t_customer set
      c_name = #{cus.name},
      c_age = #{cus.age},
      c_sex = #{cus.sex},
      c_ceroNo = #{cus.ceroNo},
      c_ceroType = #{cus.ceroType}
      where id = #{cus.id}
    </foreach>
  </update>
 
  <!-- 批量更新第二种方法,通过 case when语句变相的进行批量更新 -->
  <update id="batchUpdateCaseWhen" parameterType="java.util.Map">
    update t_customer
    <trim prefix="set" suffixOverrides=",">
      <!-- 拼接case when 这是一种写法 -->
      <!--<foreach collection="list" separator="" item="cus" open="c_age = case id" close="end, ">-->
      <!--when #{cus.id} then #{cus.age}-->
      <!--</foreach>-->
 
      <!-- 拼接case when 这是另一种写法,这种写着更专业的感觉 -->
      <trim prefix="c_name =case" suffix="end,">
        <foreach collection="list" item="cus">
          <if test="cus.name!=null">
            when id=#{cus.id} then #{cus.name}
          </if>
        </foreach>
      </trim>
      <trim prefix="c_age =case" suffix="end,">
        <foreach collection="list" item="cus">
          <if test="cus.age!=null">
            when id=#{cus.id} then #{cus.age}
          </if>
        </foreach>
      </trim>
      <trim prefix="c_sex =case" suffix="end,">
        <foreach collection="list" item="cus">
          <if test="cus.sex!=null">
            when id=#{cus.id} then #{cus.sex}
          </if>
        </foreach>
      </trim>
      <trim prefix="c_ceroNo =case" suffix="end,">
        <foreach collection="list" item="cus">
          <if test="cus.ceroNo!=null">
            when id=#{cus.id} then #{cus.ceroNo}
          </if>
        </foreach>
      </trim>
      <trim prefix="c_ceroType =case" suffix="end,">
        <foreach collection="list" item="cus">
          <if test="cus.ceroType!=null">
            when id=#{cus.id} then #{cus.ceroType}
          </if>
        </foreach>
      </trim>
    </trim>
    <where>
      <foreach collection="list" separator="or" item="cus">
        id = #{cus.id}
      </foreach>
    </where>
  </update>

接口

 List<Customer> findByName(String name);
 
  int batchUpdate(Map<String,Object> param);
 
  int batchUpdateCaseWhen(Map<String,Object> param);

实现类

 /**
   * 用于更新时,获取更新数据
   * @param name
   * @return
   */
  public List<Customer> findByName(String name) {
    SqlSession sqlSession = null;
    try {
      sqlSession = SqlsessionUtil.getSqlSession();
      return sqlSession.selectList("customer.findByName", name);
    } catch (Exception e) {
      e.printStackTrace();
    } finally {
      SqlsessionUtil.closeSession(sqlSession);
    }
    return new ArrayList<Customer>();
  }
 
 
  /**
   * 批量更新第一种方式
   * @param param
   * @return
   */
  public int batchUpdate(Map<String,Object> param) {
    return bathUpdate("customer.batchUpdate",param);
  }
 
  /**
   * 批量更新第二种方式
   * @param param
   * @return
   */
  public int batchUpdateCaseWhen(Map<String,Object> param) {
    return bathUpdate("customer.batchUpdateCaseWhen",param);
  }
 
  /**
   * 公共部分提出
   * @param statementId
   * @param param
   * @return
   */
  private int bathUpdate(String statementId,Map param){
    SqlSession sqlSession = null;
    try {
      sqlSession = SqlsessionUtil.getSqlSession();
      int key = sqlSession.update(statementId, param);
      // commit
      sqlSession.commit();
      return key;
    } catch (Exception e) {
      sqlSession.rollback();
      e.printStackTrace();
    } finally {
      SqlsessionUtil.closeSession(sqlSession);
    }
    return 0;
  }

测试前准备   首先用上节的 mybatis学习之路----批量更新数据 批量插入,插入10000条数据以备下面的批量更新用。

@Test
  public void batchInsert() throws Exception {
    Map<String,Object> param = new HashMap<String,Object>();
    List<Customer> list = new ArrayList<Customer>();
    for(int i=0;i<10000;i++){
      Customer customer = new Customer();
      customer.setName("准备数据" + i);
      customer.setAge(15);
      customer.setCeroNo("111111111111"+i);
      customer.setCeroType(2);
      customer.setSex(1);
      list.add(customer);
    }
    param.put("list",list);
    Long start = System.currentTimeMillis();
    int result = customerDao.batchInsert(param);
    System.out.println("耗时 : "+(System.currentTimeMillis() - start));
  }

开始进行测试效率问题。

首先进行的是测试十条数据。调整查询数据为查询十条

  <!-- 这次用resultmap接收输出结果 -->
  <select id="findByName" parameterType="string" resultMap="customerMap">
    select * from t_customer where c_name like concat('%', #{name},'%') order by c_ceroNo limit 0,10
  </select>

测试类

  @Test
  public void batchudpate() throws Exception {
    Map<String,Object> param = new HashMap<String,Object>();
 
    param.put("list",getFindByName("准备数据","批量更新01"));
    Long start = System.currentTimeMillis();
    customerDao.batchUpdate(param);
    System.out.println("耗时 : "+(System.currentTimeMillis() - start));
  }
 
  @Test
  public void batchudpateCaseWhen() throws Exception {
    Map<String,Object> param = new HashMap<String,Object>();
    param.put("list",getFindByName("批量更新01","准备数据"));
    Long start = System.currentTimeMillis();
    customerDao.batchUpdateCaseWhen(param);
    System.out.println("耗时 : "+(System.currentTimeMillis() - start));
  }
 
  private List<Customer> getFindByName(String name, String change){
    List<Customer> list = customerDao.findByName(name);
    System.out.println("查询出来的条数 : " + list.size());
    if(null != change && !"".equals(change)){
      for(Customer customer : list){
        customer.setName(change);
      }
    }
 
    return list;
  }

第一种拼完整sql的方式耗时:

第二种case when 耗时情况:


结果可以看出,其实case when 耗时比较多。

下面来加大数据量到100条;

第一种拼完整sql的方式耗时:

第二种case when 耗时情况:


结果可以看出,其实case when 耗时仍然比第一种多。

继续加大数据量到1000条

第一种拼完整sql的方式耗时:

第二种case when 耗时情况:

结果可以看出,其实case when 耗时仍然比第一种多。

继续加大数据量到10000条

第一种拼完整sql的方式耗时:

第二种case when 耗时情况:

结果可以看出,两种方式进行批量更新,效率已经不在一个数量级了。case when明显的慢的多。

看网上有人说第一种的效率跟用代码循环着一条一条的循环着插入的效率差不多,通过测试我就有疑问了,他是怎么做到的。难道我的代码有问题?明明第一种的效率很高嘛。

第一种效率其实相当高的,因为它仅仅有一个循环体,只不过最后update语句比较多,量大了就有可能造成sql阻塞。

第二种虽然最后只会有一条更新语句,但是xml中的循环体有点多,每一个case when 都要循环一遍list集合,所以大批量拼sql的时候会比较慢,所以效率问题严重。使用的时候建议分批插入。

根据效率,安全方面综合考虑,选择适合的很重要。

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

相关文章

  • Java集合框架之Map详解

    Java集合框架之Map详解

    这篇文章主要为大家详细介绍了Java集合框架之Map,文中示例代码介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们可以参考一下,希望能够给你带来帮助
    2022-03-03
  • 重新认识Java中的ThreadLocal

    重新认识Java中的ThreadLocal

    ThreadLocal是JDK包提供的,它提供线程本地变量,如果创建一个ThreadLocal变量,那么访问这个变量的每个线程都会有这个变量的一个副本,在实际多线程操作的时候,操作的是自己本地内存中的变量,从而规避了线程安全问题
    2021-05-05
  • 128进制加密数据示例分享

    128进制加密数据示例分享

    这篇文章主要介绍了128进制加密数据示例,这里使用JAVA实现,需要的朋友可以参考下
    2014-03-03
  • Java字母加数字组合比较大小

    Java字母加数字组合比较大小

    这篇文章主要通过实现Comarable接口来比较(如"a20"和"a9"这种)字符串的大小,希望能给大家做一个参考。
    2016-06-06
  • 教你如何更改IDEA项目的路径

    教你如何更改IDEA项目的路径

    这篇文章主要介绍了教你如何更改IDEA项目的路径,本文通过实例代码给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下
    2023-01-01
  • SpringBoot+SpringSecurity实现认证的流程详解

    SpringBoot+SpringSecurity实现认证的流程详解

    这篇文章主要介绍了SpringBoot+SpringSecurity实现认证的流程,文中通过代码示例和图文结合的方式讲解的非常详细,对大家的学习或工作有一定的帮助,需要的朋友可以参考下
    2024-05-05
  • MyBatis Plus 导入IdType失败的解决

    MyBatis Plus 导入IdType失败的解决

    这篇文章主要介绍了MyBatis Plus 导入IdType失败的解决方案,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
    2021-12-12
  • java性能优化四种常见垃圾收集器汇总

    java性能优化四种常见垃圾收集器汇总

    这篇文章主要介绍了java性能优化四种常见垃圾收集器汇总,每种垃圾收集器都有其不同的算法实现和步骤,下面我们简单描述下我们常见的四种垃圾收集器的算法过程,感兴趣的同学们最好先看下以下的两篇文章去增加理解
    2022-07-07
  • Java集合Set的简单使用解析

    Java集合Set的简单使用解析

    这篇文章主要介绍了Java集合Set的简单使用解析,Set接口是Collection的子接口,Set接口相较于Collection接口没有提供额外的方法,Set 集合不允许包含相同的元素,如果试把两个相同的元素加入同一个 Set 集合中,则添加操作失败,需要的朋友可以参考下
    2023-11-11
  • Java技巧:快速获取图片拍摄时间

    Java技巧:快速获取图片拍摄时间

    想知道如何用Java读取图片的拍摄时间吗?在这篇指南中,我将向你展示如何利用Java编程语言轻松获取图像的拍摄时间信息,不要错过这个简单而有用的技巧!
    2023-12-12

最新评论