Mybatis——实现批量更新

标签：VARCHAR 批量 CREATE t2 更新 item jdbcType Mybatis ID

一、概述

mybatis中实现批量插入是很简单的，相比大家都知道，这里就不赘述，本文主要讲述如何实现批量更新。

下面介绍本文要讲的几种方式主要是在xml中实现，不包含需要改动代码逻辑的方法，这里，除了网上说的普通情况，还有适合mysql和oracle的批量更新方式：

1. case when
1. foreach成多条sql
1. ON DUPLICATE KEY UPDATE （mysql）
1. replace into （mysql）
5.MERGE INTO（oracle）
6.INSERT ALL（oracle）

二、case when

这种方式实现的批量更新操作效率很低，而且，当更新的字段很多时，SQL语句会特别长。

<update id="updateBatch">
    update t_calendar_extend
    <trim prefix="set" suffixOverrides=",">
        <trim prefix="modify_time = case index" suffix="end,">
            <foreach collection="list" item="item">
                when #{item.index} then #{item.modifyTime}
            </foreach>
        </trim>
        <trim prefix="user_type = case index" suffix="end">
            <foreach collection="list" item="item">
                when #{item.index} then #{item.type}
            </foreach>
        </trim>
    </trim>
    <where>
        index in (
        <foreach collection="list" separator="," item="item">
            #{item.index}
        </foreach>
        )
    </where>
</update>

这里，根据index值来更新modify_time 和user_type的值，有几个字段，就要遍历几遍，效率很低。

三、foreach成多条sql

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

<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>

四、ON DUPLICATE KEY UPDATE

MYSQL中的ON DUPLICATE KEY UPDATE，是基于主键（PRIMARY KEY）或唯一索引（UNIQUE INDEX）使用的。

如果已存在该唯一标示或主键就更新，如果不存在该唯一标示或主键则作为新行插入。

<update id="updateBatch">
    insert into t_output_calendar (
		index, cal_date, user_type, create_time,  modify_time, delete_flag
    ) values
    <foreach collection="list" item="item" index="index" separator=",">
		(
			#{item.index,jdbcType=INTEGER}, 
			#{item.calDate,jdbcType=TIMESTAMP}, 
			#{item.type,jdbcType=TINYINT}, 
			#{item.createTime,jdbcType=TIMESTAMP}, 
			#{item.modifyTime,jdbcType=TIMESTAMP}, 
			#{item.deleteFlag,jdbcType=TINYINT}
        )
    </foreach>
    ON DUPLICATE KEY UPDATE 
		modify_time = VALUES(modify_time), 
		user_type = VALUES(user_type)
</update>

五、replace into

msql的replace into跟insert into的用法完全一样，但是它带有更新功能：

如果发现表中已经有此行数据（根据主键或者唯一索引判断）则先删除此行数据，然后插入新的数据。否则，直接插入新数据。

注意，它是先删除数据，然后再插入，这是和ON DUPLICATE KEY UPDATE不同的地方，如果当前的数据库用户没有删除权限，是不能使用replace into的。

示例：

<insert id="updateBatch" parameterType="java.util.List">
    replace into t_output_calendar (
		index, cal_date, user_type, create_time, modify_time, delete_flag
    ) values
    <foreach collection="list" item="item" index="index" separator=",">
        (
			#{item.index,jdbcType=INTEGER}, 
			#{item.calDate,jdbcType=TIMESTAMP}, 
			#{item.type,jdbcType=TINYINT}, 
			#{item.createTime,jdbcType=TIMESTAMP}, 
			#{item.modifyTime,jdbcType=TIMESTAMP}, 
			#{item.deleteFlag,jdbcType=TINYINT}
        )
    </foreach>
</insert>

五、MERGE INTO

判断需要插入的数据是否存在，如果不存在就更新

语法：

<insert id="saveBatch" parameterType="java.util.List" >  
    MERGE INTO 表名 T1 
    USING ( 
        <foreach collection="list" item="item" index="index" separator="union" >
            SELECT 
                SYS_GUID() AS CODE,
                #{item.createDate,jdbcType=VARCHAR} AS CREATE_DATE,
                #{item.createBy,jdbcType=VARCHAR} AS CREATE_BY,
                #{item.flagDel,jdbcType=CHAR} AS FLAG_DEL,
                #{item.flagDisplay,jdbcType=CHAR} AS FLAG_DISPLAY,
                #{item.sort,jdbcType=DECIMAL} AS SORT 
            FROM DUAL
        </foreach>) T2  
    /*判断是更新还是新记录的条件*/
    ON (
         T1./*判断数据是否重复的字段*/ = T2./*判断数据是否重复的字段*/ 
         AND T1./*判断数据是否重复的字段*/ = T2./*判断数据是否重复的字段*/
       )
    /*数据存在则更新*/
    WHEN MATCHED THEN
        UPDATE SET T./*需要更新的字段*/=T1/*需要更新的字段*/ 
    /*数据不存在则插入新记录*/
    WHEN NOT MATCHED THEN
        INSERT
            (CODE,CREATE_DATE,CREATE_BY,FLAG_DEL,FLAG_DISPLAY,SORT)
        VALUES
            (T2.CODE,T2.CREATE_DATE,T2.CREATE_BY,T2.FLAG_DEL,T2.FLAG_DISPLAY,T2.SORT) 
</insert>

例子：

<insert id="batchSave" parameterType="java.util.List">
    MERGE INTO RES_SCHOOL_CLUB t1
    USING (
      <foreach collection="list" item="item" index="index" separator="union" >
        select 
            #{item.id,jdbcType=VARCHAR} ID,
            #{item.clsSchoolId,jdbcType=VARCHAR} CLS_SCHOOL_ID,
            #{item.originSchoolId,jdbcType=VARCHAR} ORIGIN_SCHOOL_ID,
            #{item.resourceId,jdbcType=VARCHAR} RESOURCE_ID,
            #{item.clsClubId,jdbcType=VARCHAR} CLS_CLUB_ID,
            #{item.baseAreaId,jdbcType=VARCHAR} BASE_AREA_ID,
            #{item.createTime,jdbcType=TIMESTAMP} CREATE_TIME
        from dual
      </foreach>) t2
    ON (
          t1.CLS_SCHOOL_ID =  t2.CLS_SCHOOL_ID 
          AND t1.RESOURCE_ID = t2.RESOURCE_ID
       )
    WHEN MATCHED THEN
        UPDATE SET t.CREATE_TIME = t1.CREATE_TIME
    WHEN NOT MATCHED THEN
        INSERT
            (ID, CLS_SCHOOL_ID, ORIGIN_SCHOOL_ID, RESOURCE_ID, CLS_CLUB_ID, BASE_AREA_ID, CREATE_TIME)
        VALUES 
            (t2.ID, t2.CLS_SCHOOL_ID, t2.ORIGIN_SCHOOL_ID, t2.RESOURCE_ID, t2.CLS_CLUB_ID, t2.BASE_AREA_ID, t2.CREATE_TIME)
</insert>

注意：很容易造成的一个错误是：

错误：更新或者插入时候写表名都是错误的！比如：UPDATE 表名 SET... 或者 INSERT INTO 表名（...）
正确：直接UPDATE SET...和INSERT VALUES (....)括号里填相应的字段，如果没有给空值.
错误：ON 后面缺少()，ORA-00969: missing ON keyword
正确：无论 ON 后面条件多少都添加()

六、INSERT ALL

mybatis批量插入oracle时需要显式指定为 useGeneratedKeys="false"

<insert id="addList" parameterType="java.util.List" useGeneratedKeys="false">
	INSERT ALL
	<foreach item="item" index="index" collection="list">
	INTO T_APPLAUD
	(
		ID,
		USER_ID,
		BUSINESS_TYPE,
		PRODUCT_ID,
		CREATE_TIME
	) VALUES
	(
		#{item.id, jdbcType=NUMERIC},
		#{item.userId, jdbcType=VARCHAR},
		#{item.businessType, jdbcType=VARCHAR},
		#{item.productId, jdbcType=VARCHAR},
		#{item.createdTime, jdbcType=NUMERIC} 
	)
	</foreach>
	SELECT 1 FROM DUAL
</insert>

另外一种方法是 insert into table(...) (select ... from dual) union all (select ... from dual)

<insert id="addList" parameterType="java.util.List" useGeneratedKeys="false">
	INSERT INTO T_APPLAUD
	(
		ID,
		USER_ID,
		BUSINESS_TYPE,
		PRODUCT_ID,
		CREATE_TIME
	)
	<foreach item="item" index="index" collection="list" separator="union all">
	(
		SELECT 
			#{item.id},
			#{item.userId},
			#{item.businessType},
			#{item.productId},
			#{item.createdTime} 
		FROM DUAL
	)
	</foreach>
</insert>

参考： https://zhuanlan.zhihu.com/p/135839992

https://blog.51cto.com/u_14879850/5867007

标签：VARCHAR,批量,CREATE,t2,更新,item,jdbcType,Mybatis,ID
From： https://blog.51cto.com/u_14014612/6001787