快捷導(dǎo)航

MyBatis中批量插入和批量更新的實(shí)現(xiàn)方法詳解

更新時(shí)間：2023年05月17日 10:09:06 作者：shenzhenNBA

這篇文章主要介紹了MyBatis中批量插入和批量更新的實(shí)現(xiàn)方法，在日常開發(fā)中有時(shí)候需要從A數(shù)據(jù)庫(kù)提取大量數(shù)據(jù)同步到B系統(tǒng)，這種情況自然是需要批量操作才行，感興趣想要詳細(xì)了解可以參考下文

在編程中應(yīng)用程序和DB操作的第一步就是需要進(jìn)行網(wǎng)絡(luò)連接，這就是我們?cè)诔绦蛐枰O(shè)置數(shù)據(jù)源配置的原因，網(wǎng)絡(luò)連接即網(wǎng)絡(luò)通信是有一定耗時(shí)的，少量的DB操作問題不大，但是如果有大批量數(shù)據(jù)同時(shí)需要頻繁地進(jìn)行DB操作，這個(gè)時(shí)候網(wǎng)絡(luò)通信耗時(shí)對(duì)應(yīng)用運(yùn)行的影響就顯示出來(lái)了，如果一個(gè)一個(gè)的進(jìn)行DB操作肯定比較耗時(shí)，這個(gè)時(shí)候就需要考慮批量操作，也就是一次執(zhí)行多個(gè)DB操作，分多批次進(jìn)行，這樣就減少和DB鏈接的網(wǎng)絡(luò)通信時(shí)間，那怎么進(jìn)行批量操作呢？下面簡(jiǎn)單介紹在Java中使用MyBatis進(jìn)行DB批量操作，步驟如下：

1，假設(shè)有MySQL庫(kù)的用戶信息表結(jié)構(gòu)如下：

create table user (
	id bigint auto_increment comment '記錄唯一ID',
	user_code varchar(50) COLLATE utf8mb4_unicode_ci default '' not null comment '用戶編碼',
	user_name varchar(50) COLLATE utf8mb4_unicode_ci default '' not null comment '用戶姓名',
	age int(12) default 18 null comment '年齡',
	salary int(12) default 0 null comment '工資',
	email varchar(100) default '' null comment '郵箱',
	primary key (id),
	unique key 'uk_user_code' (user_code)
) ENGINE=InnoDB auto_increment=1 CHARSET=utf8 COMMENT='用戶信息表';

2，用戶信息對(duì)應(yīng)的Java Bean定義

public class User {
	private Long id;
	private String userCode;
	private String userName;
	private Integer age;
	private String email;
	private Integer salary;
	//...getter/setter省略...
}

3，批量操作需要知道原理，底層是以SQL語(yǔ)句為基礎(chǔ)的，原始SQL批量插入語(yǔ)句，例如：

insert into user (user_code, user_name, age)
values 
('zhangsan','張三',18),('lisi','李四',20),
('wangwu','王五',30),('laoliu','老六',36)

4，批量操作需要知道原理，底層是以SQL語(yǔ)句為基礎(chǔ)的，原始SQL批量更新語(yǔ)句，例如：

按要求批量更新，zhangsan, lisi, wangwu 這三個(gè)員工，

郵箱：zhangsan=zhangsan01@163.com，lisi=lisi03@163.com，wangwu=wangwu06@163.com

工資：21歲以下姓李的員工工資加200，21歲以上姓王的員工工資加400，

對(duì)應(yīng)批量更新SQL如下：

update user set 
	email = 
	case
		when user_code = 'zhangsan' then 'zhangsan01@163.com'
		when user_code = 'lisi' then 'lisi03@163.com'
		when user_code = 'wangwu' then 'wangwu06@163.com'
	end,
	salary = 
	case
		when age < 21 and user_name like '李%' then salary+200
		when age > 21 and user_name like '王%' then salary+400
	end
where user_code in ('zhangsan','lisi','wangwu')

5，mapper定義操作DB持久化的接口

@Mapper
public interface UserMapper {
	/**批量插入用戶數(shù)據(jù)*/
	int batchInsertUser(@Param("userList") List<User> userList)
	/**批量更新用戶數(shù)據(jù)*/
	int batchUpdateUser(@Param("userList") List<User> userList)
}

6，mybatis中xml配置文件對(duì)應(yīng)的定義

<!-- 其它省略 -->
<!-- 批量插入數(shù)據(jù) -->
<insert id="batchInsertUser" parameterType="java.util.List">
	insert into user (user_code, user_name, age)
	values 
	<foreach collection="userList" item="user" index="index" separator=",">
		(#{user.userCode},
		#{user.userName},
		#{user.age})
	</foreach>
</insert>
<!-- 批量更新數(shù)據(jù) -->
<update id="batchUpdateUser">
	upate user 
	<trim prefix="set" suffixOverrides=",">
		<trim prefix="email = case" suffix="end,">
			<foreach collection="userList" item="user" index="index">
				when user_code = #{user.userCode} then #{user.email}
			</foreach>
		</trim>
		<trim prefix="salary = case" suffix="end,">
			<![CDATA[ when age < 21 and user_name like '李%' then salary+200 ]]>
			<![CDATA[ when age > 21 and user_name like '王%' then salary+400 ]]>
		</trim>	
	</trim>
	where user_code in (
		<foreach collection="userList" item="user" index="index" separator=",">
			#{user.userCode}
		</foreach>
	)
</update>

7，業(yè)務(wù)接口UserServicve定義

public interface UserServicve {
	/**批量數(shù)據(jù)插入*/
	int batchInsertUser(List<User> userList);
	/**批量數(shù)據(jù)更新*/
	int batchUpdateUser(List<User> userList);
}

8，業(yè)務(wù)接口UserServicve實(shí)現(xiàn)

public class UserServicveImpl implements UserServicve {
	@Autowired
	private UserMapper userMapper;
	/**批量數(shù)據(jù)插入*/
	@Overwrite
	public int batchInsertUser(List<User> userList) {
		if (CollectionUtil.isEmpty(userList)) {
			return 0;
		}
		return userMapper.batchInsertUser(userList);
	}
	/**批量數(shù)據(jù)插入*/
	@Overwrite
	public int batchUpdateUser(List<User> userList) {
		if (CollectionUtil.isEmpty(userList)) {
			return 0;
		}
		return userMapper.batchUpdateUser(userList);
	}
}

批量在需要頻繁的大數(shù)據(jù)量操作DB的地方經(jīng)常用到，批量對(duì)DB進(jìn)行操作可以減少應(yīng)用和DB的網(wǎng)絡(luò)連接耗時(shí)，可以很大提高應(yīng)用的響應(yīng)效率

到此這篇關(guān)于MyBatis中批量插入和批量更新的實(shí)現(xiàn)方法詳解的文章就介紹到這了,更多相關(guān)MyBatis批量插入和批量更新內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: