詳解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ě)著更專(zhuān)業(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)類(lèi)
/** * 用于更新時(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)整查詢(xún)數(shù)據(jù)為查詢(xún)十條
<!-- 這次用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è)試類(lèi)
@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("查詢(xún)出來(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)文章
重新認(rèn)識(shí)Java中的ThreadLocal
ThreadLocal是JDK包提供的,它提供線(xiàn)程本地變量,如果創(chuàng)建一個(gè)ThreadLocal變量,那么訪(fǎng)問(wèn)這個(gè)變量的每個(gè)線(xiàn)程都會(huì)有這個(gè)變量的一個(gè)副本,在實(shí)際多線(xiàn)程操作的時(shí)候,操作的是自己本地內(nèi)存中的變量,從而規(guī)避了線(xiàn)程安全問(wèn)題2021-05-05SpringBoot+SpringSecurity實(shí)現(xiàn)認(rèn)證的流程詳解
這篇文章主要介紹了SpringBoot+SpringSecurity實(shí)現(xiàn)認(rèn)證的流程,文中通過(guò)代碼示例和圖文結(jié)合的方式講解的非常詳細(xì),對(duì)大家的學(xué)習(xí)或工作有一定的幫助,需要的朋友可以參考下2024-05-05MyBatis?Plus?導(dǎo)入IdType失敗的解決
這篇文章主要介紹了MyBatis?Plus?導(dǎo)入IdType失敗的解決方案,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方,望不吝賜教2021-12-12java性能優(yōu)化四種常見(jiàn)垃圾收集器匯總
這篇文章主要介紹了java性能優(yōu)化四種常見(jiàn)垃圾收集器匯總,每種垃圾收集器都有其不同的算法實(shí)現(xiàn)和步驟,下面我們簡(jiǎn)單描述下我們常見(jiàn)的四種垃圾收集器的算法過(guò)程,感興趣的同學(xué)們最好先看下以下的兩篇文章去增加理解2022-07-07