背景

经常的我们需要利用MyBatis批量保存或插入数据到数据库,解释一下,这里的保存或插入指的是如果数据库根据主键或唯一索引找不到这条记录,则将这条记录插入数据库,如果可以找到,就更新这条记录

其实MyBatisPlus可以实现,但对于复杂的业务也不容易写代码,今天就来讲讲MyBatis的方式如何实现这一业务

方案

先处理处理数据

首先在要插入数据库的数据量比较大时,我们使用org.apachemons.collections4的ListUtils的partition方法将list进行拆分成多个subList,分批插入数据库

List<List<StaCharRealTimeDevDto>> listList = 
ListUtils.partition(collect, Constant.DB_BATCH_INSERT_SIZE);

然后利用list的forEach方法遍历list分批插入数据

List<List<StaCharRealTimeDevDto>> listList = 
ListUtils.partition(collect, Constant.DB_BATCH_INSERT_SIZE);

if (CollectionUtils.isNotEmpty(listList)) {
    listList.forEach(tempList -> {
        staCharRealTimeDevMapper.saveOrUpdateBatch(tempList);
    });
}

再利用MyBatis保存或更新

方案1

<insert id="saveOrUpdateBatch" parameterType="list">
	replace into t_realtime_dev_status (id,dev_id,...) values 
	<foreach collection="tempList" item="item" open="" close="" separator=",">
		(#{item.id},#{item.devId},...)
	</foreach>
</insert>

方案2

<insert id="saveOrUpdateBatch" parameterType="list">
    insert into t_sta_char_highway_day (id,rec_date,...) values
    <foreach collection="entityList" item="item" index="index" separator=",">
        (#{item.id},#{item.recDate},...)
    </foreach>
    ON DUPLICATE KEY UPDATE
    id = values(id), rec_date = values(rec_date),...
</insert>

更多推荐

Mybatis批量保存或更新数据