今天就跟大家聊聊有關(guān)如何在mybatis中批量更新數(shù)據(jù),可能很多人都不太了解,為了讓大家更加了解,小編給大家總結(jié)了以下內(nèi)容,希望大家根據(jù)這篇文章可以有所收獲。
站在用戶的角度思考問(wèn)題,與客戶深入溝通,找到民權(quán)網(wǎng)站設(shè)計(jì)與民權(quán)網(wǎng)站推廣的解決方案,憑借多年的經(jīng)驗(yàn),讓設(shè)計(jì)與互聯(lián)網(wǎng)技術(shù)結(jié)合,創(chuàng)造個(gè)性化、用戶體驗(yàn)好的作品,建站類型包括:成都網(wǎng)站設(shè)計(jì)、做網(wǎng)站、企業(yè)官網(wǎng)、英文網(wǎng)站、手機(jī)端網(wǎng)站、網(wǎng)站推廣、國(guó)際域名空間、虛擬主機(jī)、企業(yè)郵箱。業(yè)務(wù)覆蓋民權(quán)地區(qū)。
其實(shí)這種東西寫(xiě)過(guò)來(lái)寫(xiě)過(guò)去就是差不多一樣的代碼,不做重復(fù)的贅述,直接上代碼。
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} update t_customer when id=#{cus.id} then #{cus.name} when id=#{cus.id} then #{cus.age} when id=#{cus.id} then #{cus.sex} when id=#{cus.id} then #{cus.ceroNo} when id=#{cus.id} then #{cus.ceroType} id = #{cus.id}
接口
ListfindByName(String name); int batchUpdate(Map param); int batchUpdateCaseWhen(Map param);
實(shí)現(xiàn)類
/** * 用于更新時(shí),獲取更新數(shù)據(jù) * @param name * @return */ public ListfindByName(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 (); } /** * 批量更新第一種方式 * @param param * @return */ public int batchUpdate(Map param) { return bathUpdate("customer.batchUpdate",param); } /** * 批量更新第二種方式 * @param param * @return */ public int batchUpdateCaseWhen(Map 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 { Mapparam = new HashMap (); List list = new ArrayList (); 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ù)為查詢十條
測(cè)試類
@Test public void batchudpate() throws Exception { Mapparam = new HashMap (); 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 param = new HashMap (); 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 getFindByName(String name, String change){ List 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í)候建議分批插入。
看完上述內(nèi)容,你們對(duì)如何在mybatis中批量更新數(shù)據(jù)有進(jìn)一步的了解嗎?如果還想了解更多知識(shí)或者相關(guān)內(nèi)容,請(qǐng)關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道,感謝大家的支持。