当前位置 : 主页 > 编程语言 > java >

Mybatis——实现批量更新

来源:互联网 收集:自由互联 发布时间:2023-02-04
一、概述 mybatis中实现批量插入是很简单的,相比大家都知道,这里就不赘述,本文主要讲述如何实现批量更新。   下面介绍本文要讲的几种方式主要是在xml中实现,不包含需要改动代

一、概述

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

 

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

  • case when
  • foreach成多条sql
  • ON DUPLICATE KEY UPDATE (mysql)
  • 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

上一篇:Shell 命令奇淫技巧,就是有点短
下一篇:没有了
网友评论