Mybatis批量更新三种方式的实现

2019-11-26 09:17:36

字体：大中小

来源：转载

供稿：网友

Mybatis实现批量更新操作

方式一:

<update id="updateBatch" parameterType="java.util.List">   <foreach collection="list" item="item" index="index" open="" close="" separator=";">    update tableName    <set>      name=${item.name},      name2=${item.name2}    </set>    where id = ${item.id}  </foreach>   </update>

但Mybatis映射文件中的sql语句默认是不支持以" ; " 结尾的，也就是不支持多条sql语句的执行。所以需要在连接mysql的url上加 &allowMultiQueries=true 这个才可以执行。

方式二:

<update id="updateBatch" parameterType="java.util.List">    update tableName    <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>    <where>      <foreach collection="list" separator="or" item="cus">        id = #{cus.id}      </foreach>    </where></update>

这种方式貌似效率不高，但是可以实现，而且不用改动mysql连接

效率参考文章:https://www.VeVB.COm/article/155835.htm

方式三:

临时改表sqlSessionFactory的属性，实现批量提交的java,但无法返回受影响数量。

public int updateBatch(List<Object> list){    if(list ==null || list.size() <= 0){      return -1;    }    SqlSessionFactory sqlSessionFactory = SpringContextUtil.getBean("sqlSessionFactory");    SqlSession sqlSession = null;    try {      sqlSession = sqlSessionFactory.openSession(ExecutorType.BATCH,false);      Mapper mapper = sqlSession.getMapper(Mapper.class);      int batchCount = 1000;//提交数量,到达这个数量就提交      for (int index = 0; index < list.size(); index++) {        Object obj = list.get(index);        mapper.updateInfo(obj);        if(index != 0 && index%batchCount == 0){          sqlSession.commit();        }                }      sqlSession.commit();      return 0;    }catch (Exception e){      sqlSession.rollback();      return -2;    }finally {      if(sqlSession != null){        sqlSession.close();      }    }    }

其中 SpringContextUtil 是自己定义的工具类用来获取spring加载的bean对象，其中getBean() 获得的是想要得到的sqlSessionFactory。Mapper 是自己的更具业务需求的Mapper接口类，Object是对象。

总结

方式一需要修改mysql的连接url，让全局支持多sql执行，不太安全
方式二当数据量大的时候，效率明显降低
方式三需要自己控制，自己处理，一些隐藏的问题无法发现。

附件：SpringContextUtil.java

@Componentpublic class SpringContextUtil implements ApplicationContextAware{  private static ApplicationContext applicationContext;  @Override  public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {    SpringContextUtil.applicationContext = applicationContext;  }  public static ApplicationContext getApplicationContext(){    return applicationContext;  }  public static Object getBean(Class T){    try {      return applicationContext.getBean(T);    }catch (BeansException e){      return null;    }  }  public static Object getBean(String name){    try {      return applicationContext.getBean(name);    }catch (BeansException e){      return null;    }  }}

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

上一篇：BeanDefinition基础信息讲解

下一篇：Java回调函数原理实例与代理模式的区别讲解