詳解mybatis 批量更新數(shù)據(jù)兩種方法效率對(duì)比
上節(jié)探討了批量新增數(shù)據(jù)，這節(jié)探討批量更新數(shù)據(jù)兩種寫(xiě)法的效率問(wèn)題。
實(shí)現(xiàn)方式有兩種，
一種用for循環(huán)通過(guò)循環(huán)傳過(guò)來(lái)的參數(shù)集合，循環(huán)出N條sql，
另一種 用mysql的case when 條件判斷變相的進(jìn)行批量更新
下面進(jìn)行實(shí)現(xiàn)。
注意第一種方法要想成功，需要在db鏈接url后面帶一個(gè)參數(shù) &allowMultiQueries=true
即： jdbc:mysql://localhost:3306/mysqlTest?characterEncoding=utf-8&allowMultiQueries=true
其實(shí)這種東西寫(xiě)過(guò)來(lái)寫(xiě)過(guò)去就是差不多一樣的代碼，不做重復(fù)的贅述，直接上代碼。
<!-- 這次用resultmap接收輸出結(jié)果 -->
<select id="findByName" parameterType="string" resultMap="customerMap">
select * from t_customer where c_name like concat('%', #{name},'%') order by c_ceroNo limit 0,100
</select>
<!-- 批量更新第一種方法，通過(guò)接收傳進(jìn)來(lái)的參數(shù)list進(jìn)行循環(huán)著組裝sql -->
<update id="batchUpdate" parameterType="java.util.Map">
<!-- 接收l(shuí)ist參數(shù)，循環(huán)著組裝sql語(yǔ)句，注意for循環(huán)的寫(xiě)法
separator=";" 代表著每次循環(huán)完，在sql后面放一個(gè)分號(hào)
item="cus" 循環(huán)List的每條的結(jié)果集
collection="list" list 即為 map傳過(guò)來(lái)的參數(shù)key -->
<foreach collection="list" separator=";" item="cus">
update t_customer set
c_name = #{cus.name},
c_age = #{cus.age},
c_sex = #{cus.sex},
c_ceroNo = #{cus.ceroNo},
c_ceroType = #{cus.ceroType}
where id = #{cus.id}
</foreach>
</update>
<!-- 批量更新第二種方法，通過(guò) case when語(yǔ)句變相的進(jìn)行批量更新 -->
<update id="batchUpdateCaseWhen" parameterType="java.util.Map">
update t_customer
<trim prefix="set" suffixOverrides=",">
<!-- 拼接case when 這是一種寫(xiě)法 -->
<!--<foreach collection="list" separator="" item="cus" open="c_age = case id" close="end, ">-->
<!--when #{cus.id} then #{cus.age}-->
<!--</foreach>-->
<!-- 拼接case when 這是另一種寫(xiě)法，這種寫(xiě)著更專業(yè)的感覺(jué) -->
<trim prefix="c_name =case" suffix="end,">
<foreach collection="list" item="cus">
<if test="cus.name!=null">
when id=#{cus.id} then #{cus.name}
</if>
</foreach>
</trim>
<trim prefix="c_age =case" suffix="end,">
<foreach collection="list" item="cus">
<if test="cus.age!=null">
when id=#{cus.id} then #{cus.age}
</if>
</foreach>
</trim>
<trim prefix="c_sex =case" suffix="end,">
<foreach collection="list" item="cus">
<if test="cus.sex!=null">
when id=#{cus.id} then #{cus.sex}
</if>
</foreach>
</trim>
<trim prefix="c_ceroNo =case" suffix="end,">
<foreach collection="list" item="cus">
<if test="cus.ceroNo!=null">
when id=#{cus.id} then #{cus.ceroNo}
</if>
</foreach>
</trim>
<trim prefix="c_ceroType =case" suffix="end,">
<foreach collection="list" item="cus">
<if test="cus.ceroType!=null">
when id=#{cus.id} then #{cus.ceroType}
</if>
</foreach>
</trim>
</trim>
<where>
<foreach collection="list" separator="or" item="cus">
id = #{cus.id}
</foreach>
</where>
</update>
接口
List<Customer> findByName(String name); int batchUpdate(Map<String,Object> param); int batchUpdateCaseWhen(Map<String,Object> param);
實(shí)現(xiàn)類
/**
* 用于更新時(shí)，獲取更新數(shù)據(jù)
* @param name
* @return
*/
public List<Customer> findByName(String name) {
SqlSession sqlSession = null;
try {
sqlSession = SqlsessionUtil.getSqlSession();
return sqlSession.selectList("customer.findByName", name);
} catch (Exception e) {
e.printStackTrace();
} finally {
SqlsessionUtil.closeSession(sqlSession);
}
return new ArrayList<Customer>();
}
/**
* 批量更新第一種方式
* @param param
* @return
*/
public int batchUpdate(Map<String,Object> param) {
return bathUpdate("customer.batchUpdate",param);
}
/**
* 批量更新第二種方式
* @param param
* @return
*/
public int batchUpdateCaseWhen(Map<String,Object> param) {
return bathUpdate("customer.batchUpdateCaseWhen",param);
}
/**
* 公共部分提出
* @param statementId
* @param param
* @return
*/
private int bathUpdate(String statementId,Map param){
SqlSession sqlSession = null;
try {
sqlSession = SqlsessionUtil.getSqlSession();
int key = sqlSession.update(statementId, param);
// commit
sqlSession.commit();
return key;
} catch (Exception e) {
sqlSession.rollback();
e.printStackTrace();
} finally {
SqlsessionUtil.closeSession(sqlSession);
}
return 0;
}
測(cè)試前準(zhǔn)備 首先用上節(jié)的 mybatis學(xué)習(xí)之路----批量更新數(shù)據(jù) 批量插入，插入10000條數(shù)據(jù)以備下面的批量更新用。
@Test
public void batchInsert() throws Exception {
Map<String,Object> param = new HashMap<String,Object>();
List<Customer> list = new ArrayList<Customer>();
for(int i=0;i<10000;i++){
Customer customer = new Customer();
customer.setName("準(zhǔn)備數(shù)據(jù)" + i);
customer.setAge(15);
customer.setCeroNo("111111111111"+i);
customer.setCeroType(2);
customer.setSex(1);
list.add(customer);
}
param.put("list",list);
Long start = System.currentTimeMillis();
int result = customerDao.batchInsert(param);
System.out.println("耗時(shí) ： "+(System.currentTimeMillis() - start));
}
開(kāi)始進(jìn)行測(cè)試效率問(wèn)題。
首先進(jìn)行的是測(cè)試十條數(shù)據(jù)。調(diào)整查詢數(shù)據(jù)為查詢十條
<!-- 這次用resultmap接收輸出結(jié)果 -->
<select id="findByName" parameterType="string" resultMap="customerMap">
select * from t_customer where c_name like concat('%', #{name},'%') order by c_ceroNo limit 0,10
</select>
測(cè)試類
@Test
public void batchudpate() throws Exception {
Map<String,Object> param = new HashMap<String,Object>();
param.put("list",getFindByName("準(zhǔn)備數(shù)據(jù)","批量更新01"));
Long start = System.currentTimeMillis();
customerDao.batchUpdate(param);
System.out.println("耗時(shí) ： "+(System.currentTimeMillis() - start));
}
@Test
public void batchudpateCaseWhen() throws Exception {
Map<String,Object> param = new HashMap<String,Object>();
param.put("list",getFindByName("批量更新01","準(zhǔn)備數(shù)據(jù)"));
Long start = System.currentTimeMillis();
customerDao.batchUpdateCaseWhen(param);
System.out.println("耗時(shí) ： "+(System.currentTimeMillis() - start));
}
private List<Customer> getFindByName(String name, String change){
List<Customer> list = customerDao.findByName(name);
System.out.println("查詢出來(lái)的條數(shù) ： " + list.size());
if(null != change && !"".equals(change)){
for(Customer customer : list){
customer.setName(change);
}
}
return list;
}
第一種拼完整sql的方式耗時(shí)：
第二種case when 耗時(shí)情況:
結(jié)果可以看出，其實(shí)case when 耗時(shí)比較多。
下面來(lái)加大數(shù)據(jù)量到100條；
第一種拼完整sql的方式耗時(shí)：
第二種case when 耗時(shí)情況:
結(jié)果可以看出，其實(shí)case when 耗時(shí)仍然比第一種多。
繼續(xù)加大數(shù)據(jù)量到1000條
第一種拼完整sql的方式耗時(shí)：
第二種case when 耗時(shí)情況:
結(jié)果可以看出，其實(shí)case when 耗時(shí)仍然比第一種多。
繼續(xù)加大數(shù)據(jù)量到10000條
第一種拼完整sql的方式耗時(shí)：
第二種case when 耗時(shí)情況:
結(jié)果可以看出，兩種方式進(jìn)行批量更新，效率已經(jīng)不在一個(gè)數(shù)量級(jí)了。case when明顯的慢的多。
看網(wǎng)上有人說(shuō)第一種的效率跟用代碼循環(huán)著一條一條的循環(huán)著插入的效率差不多，通過(guò)測(cè)試我就有疑問(wèn)了，他是怎么做到的。難道我的代碼有問(wèn)題？明明第一種的效率很高嘛。
第一種效率其實(shí)相當(dāng)高的，因?yàn)樗鼉H僅有一個(gè)循環(huán)體，只不過(guò)最后update語(yǔ)句比較多，量大了就有可能造成sql阻塞。
第二種雖然最后只會(huì)有一條更新語(yǔ)句，但是xml中的循環(huán)體有點(diǎn)多，每一個(gè)case when 都要循環(huán)一遍list集合，所以大批量拼sql的時(shí)候會(huì)比較慢，所以效率問(wèn)題嚴(yán)重。使用的時(shí)候建議分批插入。
根據(jù)效率，安全方面綜合考慮，選擇適合的很重要。
以上就是本文的全部?jī)?nèi)容，希望對(duì)大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。
相關(guān)文章
這篇文章主要為大家詳細(xì)介紹了Java集合框架之Map，文中示例代碼介紹的非常詳細(xì)，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下，希望能夠給你帶來(lái)幫助2022-03-03
重新認(rèn)識(shí)Java中的ThreadLocal
ThreadLocal是JDK包提供的，它提供線程本地變量，如果創(chuàng)建一個(gè)ThreadLocal變量，那么訪問(wèn)這個(gè)變量的每個(gè)線程都會(huì)有這個(gè)變量的一個(gè)副本，在實(shí)際多線程操作的時(shí)候，操作的是自己本地內(nèi)存中的變量，從而規(guī)避了線程安全問(wèn)題2021-05-05
這篇文章主要介紹了128進(jìn)制加密數(shù)據(jù)示例，這里使用JAVA實(shí)現(xiàn),需要的朋友可以參考下2014-03-03
這篇文章主要通過(guò)實(shí)現(xiàn)Comarable接口來(lái)比較（如"a20"和"a9"這種）字符串的大小，希望能給大家做一個(gè)參考。2016-06-06
這篇文章主要介紹了教你如何更改IDEA項(xiàng)目的路徑,本文通過(guò)實(shí)例代碼給大家介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值，需要的朋友可以參考下2023-01-01
SpringBoot+SpringSecurity實(shí)現(xiàn)認(rèn)證的流程詳解
這篇文章主要介紹了SpringBoot+SpringSecurity實(shí)現(xiàn)認(rèn)證的流程,文中通過(guò)代碼示例和圖文結(jié)合的方式講解的非常詳細(xì),對(duì)大家的學(xué)習(xí)或工作有一定的幫助,需要的朋友可以參考下2024-05-05
MyBatis?Plus?導(dǎo)入IdType失敗的解決
這篇文章主要介紹了MyBatis?Plus?導(dǎo)入IdType失敗的解決方案，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教2021-12-12
java性能優(yōu)化四種常見(jiàn)垃圾收集器匯總
這篇文章主要介紹了java性能優(yōu)化四種常見(jiàn)垃圾收集器匯總，每種垃圾收集器都有其不同的算法實(shí)現(xiàn)和步驟，下面我們簡(jiǎn)單描述下我們常見(jiàn)的四種垃圾收集器的算法過(guò)程，感興趣的同學(xué)們最好先看下以下的兩篇文章去增加理解2022-07-07
這篇文章主要介紹了Java集合Set的簡(jiǎn)單使用解析,Set接口是Collection的子接口,Set接口相較于Collection接口沒(méi)有提供額外的方法,Set 集合不允許包含相同的元素,如果試把兩個(gè)相同的元素加入同一個(gè) Set 集合中,則添加操作失敗,需要的朋友可以參考下2023-11-11
想知道如何用Java讀取圖片的拍攝時(shí)間嗎？在這篇指南中,我將向你展示如何利用Java編程語(yǔ)言輕松獲取圖像的拍攝時(shí)間信息,不要錯(cuò)過(guò)這個(gè)簡(jiǎn)單而有用的技巧！2023-12-12