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

Bertha 。 2022-02-02 04:45 313阅读 0赞

批量更新数据两种写法的效率问题。

实现方式有两种，

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

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

下面进行实现。

注意第一种方法要想成功，需要在db链接url后面带一个参数

&allowMultiQueries=true

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

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

<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>
     
     
      
      <update id="batchUpdate" parameterType="java.util.Map">
        
        <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>

<update id="batchUpdateCaseWhen" parameterType="java.util.Map">
        update t_customer
        <trim prefix="set" suffixOverrides=",">
          
          
          
          
     
          
          <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学习之路----批量更新数据 ][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));
      }

开始进行测试效率问题。

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

测试类

@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;
      }

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96eWM4OC5ibG9nLmNzZG4ubmV0_size_16_color_FFFFFF_t_70][]

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

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

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96eWM4OC5ibG9nLmNzZG4ubmV0_size_16_color_FFFFFF_t_70 1][]

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

继续加大数据量到1000条

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96eWM4OC5ibG9nLmNzZG4ubmV0_size_16_color_FFFFFF_t_70 2][]

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

继续加大数据量到10000条

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96eWM4OC5ibG9nLmNzZG4ubmV0_size_16_color_FFFFFF_t_70 3][]

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

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

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

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

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

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

您可能感兴趣的文章:

*  [Mybatis中使用updateBatch进行批量更新][Mybatis_updateBatch]
 *  [Mybatis批量更新报错问题][Mybatis]
 *  [mybatis执行批量更新batch update 的方法（oracle,mysql两种）][mybatis_batch update _oracle_mysql]

[mybatis_----]: https://www.jb51.net/article/155833.htm
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96eWM4OC5ibG9nLmNzZG4ubmV0_size_16_color_FFFFFF_t_70]: /images/20220202/a552ef4e2892461c90eaff743239a80e.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96eWM4OC5ibG9nLmNzZG4ubmV0_size_16_color_FFFFFF_t_70 1]: /images/20220202/a1257abe6a504a4c994305196d652450.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96eWM4OC5ibG9nLmNzZG4ubmV0_size_16_color_FFFFFF_t_70 2]: /images/20220202/36f0a12ce6854cb09133b8208c696e14.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96eWM4OC5ibG9nLmNzZG4ubmV0_size_16_color_FFFFFF_t_70 3]: /images/20220202/b1ac251b34a34be988c21b7c2cca0fc3.png
[Mybatis_updateBatch]: https://www.jb51.net/article/138756.htm
[Mybatis]: https://www.jb51.net/article/104288.htm
[mybatis_batch update _oracle_mysql]: https://www.jb51.net/article/102593.htm