mybatis 批量更新，首先要在数据库连接 url 上添加配置 &allowMultiQueries=true，因为 mysql 默认不支持批量更新，所以需要开发人员手动设置
 
spring:
  datasource:
    url:  jdbc:mysql://localhost:3306/test?useUnicode=true&characterEncoding=utf-8&useSSL=false&allowMultiQueries=true
    driver-class-name:  com.mysql.jdbc.Driver
    username:  root
    password:  root
 
 
 
定义 mapper 接口
 
package com.music.mapper;

import com.music.bean.Music;
import org.apache.ibatis.annotations.Param;
import java.util.List;

public interface MusicMapper {

    //批量更新
    int updataMusicForeach(@Param("list") List<Music> list);
}
 
 
 
mapper.xml 文件
 
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.music.mapper.MusicMapper">

    <resultMap id="BaseResultMap" type="com.music.bean.Music">
        <id column="m_music_id" jdbcType="BIGINT" property="mMusicId" />
        <result column="m_music_problem" jdbcType="VARCHAR" property="mMusicProblem" />
    </resultMap>

    <!--批量更新-->
    <update id="updataMusicForeach" parameterType="java.util.List">
        <foreach collection="list" item="item" index="index" open="" close=";" separator=";">
            update m_music set m_music_problem = #{item.mMusicProblem} where m_music_id = #{item.mMusicId}
        </foreach>
    </update>
  
</mapper>
 
 

MyBatis批量更新
 
操作oracle
 
XML文档中，update标签中的语句使用了标签$和#来传递参数。通常前者用来传递数据库对象，如字段名、表名；后者传递参数值。
 
＃方式能够很大程度防止sql注入。
 
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">

<mapper 
<update id="updateCoordinatesByTableAndId" parameterType="java.util.List">  

       <foreach collection="list" item="item" index="index" open="begin" close=";end;" separator=";">  
                UPDATE ${item.table_name} t  
                <set>  
                  t.AMAP_LAT = #{item.lat},
                  t.AMAP_LON = #{item.lon} 
                </set>  
                WHERE t.id = #{item.id}  
       </foreach>  

    </update>   
</mapper>
 
其中批量更新的参数通过List传递，List元素为Map对象，对象中的Key-Value对和上述XML文档中的保持一致，如下：
 
package com.autonavi.method;

import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

import com.autonavi.domain.Coordinate;
import com.autonavi.service.impl.DataUpdateServiceImpl;

public class DataUpdate {

    public static Integer update(List<Coordinate> list){

        List<Map<String,String>> listmap = new ArrayList<Map<String,String>>();

        for(Coordinate coor : list){

            Map<String,String> map = new HashMap<String,String>();
            map.put("table_name", coor.getName());
            map.put("lon", coor.getLon()+"");
            map.put("lat", coor.getLat()+"");
            map.put("id", coor.getId()+"");

            //System.out.println("table_name:"+coor.getName());
            listmap.add(map);
        }

        Integer counts = new DataUpdateServiceImpl().updateDataByPara(listmap);

        return counts;              
    }

}
 
MyBatis默认批量更新成功，返回结果counts=-1, 而不是返回更新的纪录条数。

 分类：  Mybatis 
 2013-01-24 10:31 
  4221人阅读 
 评论(0) 
 收藏 
  举报 
 

 Mybatis
 java
 数据库批量操作
 
 
 
 
目录(?)[+]
 
 
实现目标
批量更新的sql语句
Mybatis中mapper-xml
 
 
 
 
 
Mybatis批量更新
 
 
批量操作就不进行赘述了。减少服务器与数据库之间的交互。网上有很多关于批量插入还有批量删除的帖子。但是批量更新却没有详细的解决方案。
 
 

 
 
 
 
 
实现目标
 
 
 
 
 
 
这里主要讲的是1张table中。根据不同的id值，来update不同的property。
 
 
数据表：1张。Tblsupertitleresult。错题结果统计。
 
 
表结构：
 
 
 
 
 
 
表中每一条数据必须通过两个字段来确定：userHhCode+titleId
 
 
需要批量更新的字段是：correctDate,result,checkState。
 
 
 
 
 
 
批量更新的sql语句
 
 
 
  
 我用的数据库是mysql。其他数据库的sql语句也都大同小异。
 
  
用mybatis的mapper-xml进行组装sql之前需要写出批量操作的sql语句。
 
  
Sql：
 
  
 
   
 
    

     [sql] 
      view plain
     copy
     print
     ?
    
 
   
 
   
update tblsupertitleresult set result =case   
  
when (userHhCode=2001 and titleId=1)then  90  
   
when (userHhCode=2001 and titleId=2)then  70  
   
end  
   
,checkState = case    
  
when (userHhCode=2001 and titleId=1)then  80  
   
when (userHhCode=2001 andtitleId=2)then  120  
   
end  
   
where (userHhCode=2001 and titleId=1) or(userHhCode=2001 and titleId=2)  
 
  
 
  
update tblsupertitleresult set result =case 

when (userHhCode=2001 and titleId=1)then  90
 
when (userHhCode=2001 and titleId=2)then  70
 
end
 
,checkState = case  

when (userHhCode=2001 and titleId=1)then  80
 
when (userHhCode=2001 andtitleId=2)then  120
 
end
 
where (userHhCode=2001 and titleId=1) or(userHhCode=2001 and titleId=2)
  
 
  
关于这个批量更新的sql语句做一个简单的解释。
 
  
要更新userHhCode=2001，titleId=1和userHhCode=2001 ，titleId=2的两条数据。
 
  
当userHhCode=2001，titleId=1时，将result设置为90，checkState设置为80
 
  
当userHhCode=2001，titleId=2时，将result设置为80，checkState设置为120.
 
  
这是mysql语句。运行没有问题。接下来就是mybatis的mapper-xml
 
  
 
 
 
 
Mybatis中mapper-xml
 
 
这里，首先介绍实体类。
 
 
 
 
 
  
 
   

    [java] 
     view plain
    copy
    print
    ?
   
 
  
 
  
public classWrongTitle {  
   
    //manipulatetable of tblsupertitleresult    
  
    privateString titleId;  
   
    privateString titleIdNew;  
   
    privateString result;  
   
    privateString checkState;  
   
    privateString isCollect;  
   
    privateString times;  
   
    privateString wrongDate;  
   
    privateString wrongNum;  
   
    privateString collectDate;  
   
    privateString userHhCode;  
   
    privateString correctDate;  
   
    privateString tid;// teacher who will review this wrong title   
   
    privateString paperTitleId;  
   
getter和set方法省略。  
 
 
 
 
public classWrongTitle {
 
    //manipulatetable of tblsupertitleresult 

    privateString titleId;
 
    privateString titleIdNew;
 
    privateString result;
 
    privateString checkState;
 
    privateString isCollect;
 
    privateString times;
 
    privateString wrongDate;
 
    privateString wrongNum;
 
    privateString collectDate;
 
    privateString userHhCode;
 
    privateString correctDate;
 
    privateString tid;// teacher who will review this wrong title
 
    privateString paperTitleId;
 
getter和set方法省略。
 
 
 
 
 
好了现在开始介绍mybatis里面的几个标签。由于一些原因，mybatis的技术文档和用户指南所介绍得并不详细。
 
 
<foreach>标签：foreach元素的属性主要有item，index，collection，open，separator，close。item表示集合中每一个元素进行迭代时的别名，
 
 
index指定一个名字，用于表示在迭代过程中，每次迭代到的位置，
 
 
open表示该语句以什么开始，
 
 
separator表示在每次进行迭代之间以什么符号作为分隔符，
 
 
close表示以什么结束，
 
 
在使用foreach的时候最关键的也是最容易出错的就是collection属性，该属性是必须指定的，但是在不同情况下，该属性的值是不一样的，主要有一下3种情况：
 
 
1.如果传入的是单参数且参数类型是一个List的时候，collection属性值为list；
 
 
2.如果传入的是单参数且参数类型是一个array数组的时候，collection的属性值为array；
 
 
3.如果传入的参数是多个的时候，我们就需要把它们封装成一个Map了，当然单参数也可以封装成map，实际上如果你在传入参数的时候，在MyBatis里面也是会把它封装成一个Map的，map的key就是参数名，所以这个时候collection属性值就是传入的List或array对象在自己封装的map里面的key；
 
 
关于以上三种collection的用法。百度上有很多帖子。这里不进行赘述。
 
 
 
 
 
 
 
 
<trim>标签：有四个属性：
 
 
Prefix：指的是<trim></trim>所包含的部分（body）以什么开头。
 
 
prefixOverrides：指<trim>中如果有内容时可忽略（body）前的匹配字符。
 
 
suffix：指的是<trim></trim>所包含的部分（body）以什么结尾。
 
 
suffixOverrides：指<trim>中如果有内容时可忽略（body）后的匹配字符。
 
 
 
 
接下来直接上：
 
 
Mapper-xml
 
 
 
  
 
   

    [html] 
     view plain
    copy
    print
    ?
   
 
  
 
  
<update id="batchUpdate">   
            update tblsupertitleresult   
            <trim prefix="set" suffixOverrides=",">  
            <trim prefix="checkState =case" suffix="end,">  
                <foreach collection="list" item="i"  index="index">  
                        <if test="i.checkState!=null">  
                         when (userHhCode=#{i.userHhCode} and titleId=#{i.titleId}) then #{i.checkState}  
                        </if>  
                </foreach>  
             </trim>  
             <trim prefix=" correctDate =case"  suffix="end,">  
                <foreach collection="list" item="i"  index="index">  
                        <if test="i.correctDate!=null">  
                         when (userHhCode=#{i.userHhCode} and titleId=#{i.titleId}) then #{i.correctDate}  
                        </if>  
                </foreach>  
             </trim>   
             <trim prefix="result =case"  suffix="end,"  >  
                <foreach collection="list"item="i" index="index">   
                        <if test="i.result!=null">  
                         when (userHhCode=#{i.userHhCode} and titleId=#{i.titleId}) then #{i.result}  
                        </if>  
                </foreach>  
             </trim>   
             </trim>   
            where   
            <foreach collection="list" separator="or"item="i" index="index" >  
             (userHhCode =#{i.userHhCode} andtitleId=#{i.titleId})  
         </foreach>  
</update>  
 
 
 
 
<update id="batchUpdate"> 
            update tblsupertitleresult 
            <trim prefix="set" suffixOverrides=",">
            <trim prefix="checkState =case" suffix="end,">
                <foreach collection="list" item="i"  index="index">
                        <if test="i.checkState!=null">
                         when (userHhCode=#{i.userHhCode} and titleId=#{i.titleId}) then #{i.checkState}
                        </if>
                </foreach>
             </trim>
             <trim prefix=" correctDate =case"  suffix="end,">
                <foreach collection="list" item="i"  index="index">
                        <if test="i.correctDate!=null">
                         when (userHhCode=#{i.userHhCode} and titleId=#{i.titleId}) then #{i.correctDate}
                        </if>
                </foreach>
             </trim> 
             <trim prefix="result =case"  suffix="end,"  >
                <foreach collection="list"item="i" index="index"> 
                        <if test="i.result!=null">
                         when (userHhCode=#{i.userHhCode} and titleId=#{i.titleId}) then #{i.result}
                        </if>
                </foreach>
             </trim> 
             </trim> 
            where 
            <foreach collection="list" separator="or"item="i" index="index" >
             (userHhCode =#{i.userHhCode} andtitleId=#{i.titleId})
         </foreach>
</update>
 
 接下来就是dao：
 
 
 
 
 
 
  
 
   

    [java] 
     view plain
    copy
    print
    ?
   
 
  
 
  
public interface DatacenterDAO{  
   
// batch update super title_result_view   
   
       public intbatchUpdate(List<WrongTitle> list );  
   
Test类  
   
public classTestBatch {  
    /** 
  
    * @param args 
  
    */  
   
    public static voidmain(String[] args) {  
   
       ApplicationContext  context = newClassPathXmlApplicationContext("applicationContext.xml");  
   
       DatacenterDAO dao = context.getBean(DatacenterDAO.class);  
   
       ArrayList<WrongTitle> list = newArrayList<WrongTitle>();  
   
       WrongTitle t1=new WrongTitle();  
   
       WrongTitle t2=new WrongTitle();  
   
       WrongTitle t3=new WrongTitle();  
   
       WrongTitle t4=new WrongTitle();  
   
       t1.setTitleId(3+"");  
   
       t2.setTitleId(4+"");  
   
       t3.setTitleId(5+"");  
   
       t4.setTitleId(6+"");  
   
       t1.setUserHhCode(2001+"");  
   
       t2.setUserHhCode(2001+"");  
   
       t3.setUserHhCode(2001+"");  
   
       t4.setUserHhCode(2001+"");  
   
       t1.setCheckState(5+"");  
   
       t2.setCheckState(6+"");  
   
       t3.setCheckState(7+"");  
   
       t4.setCheckState(8+"");  
   
       t1.setResult(10+"");  
   
       t2.setResult(12+"");  
   
       t3.setResult(14+"");  
   
       t4.setResult(16+"");  
   
       list.add(t1);  
   
       list.add(t2);  
   
       list.add(t3);  
   
       list.add(t4);  
   
       int i=dao.batchUpdate(list);  
   
       System.out.println("操作了"+i+"行数据");  
   
}  
 
 
 
 
public interface DatacenterDAO{
 
// batch update super title_result_view
 
       public intbatchUpdate(List<WrongTitle> list );
 
Test类
 
public classTestBatch {
    /**
 
    * @param args
 
    */
 
    public static voidmain(String[] args) {
 
       ApplicationContext  context = newClassPathXmlApplicationContext("applicationContext.xml");
 
       DatacenterDAO dao = context.getBean(DatacenterDAO.class);
 
       ArrayList<WrongTitle> list = newArrayList<WrongTitle>();
 
       WrongTitle t1=new WrongTitle();
 
       WrongTitle t2=new WrongTitle();
 
       WrongTitle t3=new WrongTitle();
 
       WrongTitle t4=new WrongTitle();
 
       t1.setTitleId(3+"");
 
       t2.setTitleId(4+"");
 
       t3.setTitleId(5+"");
 
       t4.setTitleId(6+"");
 
       t1.setUserHhCode(2001+"");
 
       t2.setUserHhCode(2001+"");
 
       t3.setUserHhCode(2001+"");
 
       t4.setUserHhCode(2001+"");
 
       t1.setCheckState(5+"");
 
       t2.setCheckState(6+"");
 
       t3.setCheckState(7+"");
 
       t4.setCheckState(8+"");
 
       t1.setResult(10+"");
 
       t2.setResult(12+"");
 
       t3.setResult(14+"");
 
       t4.setResult(16+"");
 
       list.add(t1);
 
       list.add(t2);
 
       list.add(t3);
 
       list.add(t4);
 
       int i=dao.batchUpdate(list);
 
       System.out.println("操作了"+i+"行数据");
 
}
 
 
 
 
 

mybatis批量更新踩坑
 
说一下遇到的大坑，mybatis批量更新update语句，我们知道mysql是支持批量插入和批量删除的，因此它也是支持批量更新的，但是批量更新的方法跟批量插入删除略有不同，先简单说一下mybatis批量更新的方法吧，我说知道的有两种，一种是通过case when的方法实现批量更新，另外一种就比较简单了，直接使用mybatis提供的foreach标签实现批量更新。第一种方法不再具体介绍因为我使用的是第二种方法，再次详细介绍下第二种方法。
 　　　
 通过使用foreach标签，我们可以实现批量更新。
 foreach标签有几个属性
 1.collection：必选属性，代表要遍历的集合数据，就是你传入的参数集合
 2.item属性：集合中的元素名字
 3.open：在前面添加的sql片段
 4.close：在结尾处添加的sql片段
 5.separator：指定遍历的元素之间使用的分隔符
 
    //批量删除
	<insert id="insertCarForeach" parameterType="com.crude.oilfield.domain.QueryVo">
		insert into sentcar (batch,carnum,date,netweight,status) values
		<foreach collection="sentcarlist" item="sentcar" index="index" separator=",">
			(#{sentcar.batch},#{sentcar.carnum},#{sentcar.date},#{sentcar.netweight},#{sentcar.status})
		</foreach>
	</insert>
	//批量删除
	<update id="updateStatusForeach" parameterType="com.crude.oilfield.domain.QueryVo">
			<foreach collection="sentcarlist" item="sendcar" index="index" separator=";">
				update sentcar  set status=#{sendcar.status} where batch=#{sendcar.batch} and carnum=#{sendcar.carnum}
			</foreach>
	</update>
 
接下来说一下遇到的坑吧，先上图
 
 这个错误很明显，是sql语句的语法错误废了半天劲，我试过很多方法，将整个sql语句写到foeeach标签里边，也还是这个异常，最后的结果让我很无语，原因仅仅是因为我在等号前多加了个空格。
 
 随后我将空格删除之后就不在报这个异常了，就在我以为程序可以继续运行时，又出了新异常。废话不说直接上图。
 这依然是个sql异常，意思很好理解，未知系统变量‘status’，status是我数据表中的字段。为什么会报这个异常，我也不是很了解。百度查，网上说是因为安装的数据库版本和项目的mysql驱动版本不匹配导致的，要么就是其中一个版本太高了，我这里服务器安装的mysql5.7版本，我也试着更换了其他版本的mysql驱动，但是还是报这个异常。如果百度的话网上很多的做法都是更改mysql驱动版本或者更新数据库版本。但是在我这里不知道为什么没有用。后来我观察了报异常的位置。
 
 在我途中黑色圈住的区域，我不知道为什么会出现这么长的空白，如果是sql语句正常解析的话是不会出现空白的。于是我觉得我的sql语句依然还是有问题的。我又尝试修改sql语句。这里先放一张修改之前的图
 
 注意在我途中鼠标选中的区域也就是之前黑色圆圈圈住的区域，下面是我修改后的sql语句
 
 我将update sentcar 移入到了foreach标签中。因为我觉得如果不放在一起连贯起来的，可能会出现刚才的解析出大段空白。其实也可以使用sql片段抽取。不过我个人不太喜欢mybatis的这种做法，因为这样会使sql语句变得断断续续，在后期检查代码时，看起来会很吃力。个人建议sql语句在书写过程中要写的尽量完整，方便自己阅读，也方便其他人阅读。
 
在修改了sql语句之后，程序终于运行成功！！困扰了一整天的大bug终于给弄好了，其实像Unkown system variable ‘xxx’的错误真的很让人头疼，因为也不是代码逻辑的错误，所以写代码还是要细心。
 
最后总结一下这两个错误：
 1.第一个是sql语句语法错误，就是 ‘=’前多打了个空格的问题，这里建议书写sql语句时一定要严谨，不要随随便便多打也不能漏打。
 2.第二个错误就是位置系统变量的错误。解决办法：
 （1）. 更新数据库版本或者mysql驱动版本，这种解决办法网上有很多，不过对我的这个错误好像，没有太大作用。不过还是可以试一下的。------网上的解决办法
 （2）. 检查sql语句是否书写正确，而且尽量将sql语句都写在foreach循环中。避免报错。------我的解决办法。