最新国产好看的视频,伊人天堂AV在线,国产Aaaaaa视频,蜜臀视频在线观看一区,人妻av色图,密臀久久久精品影片,青青视频免费观看毛片,久草在线观看视,国产三级精品色情在线

使用SpringBoot和JPA實(shí)現(xiàn)批量處理新增、修改

 更新時(shí)間:2023年06月26日 10:37:09   作者:procedure?rabbit  
最近項(xiàng)目需要在JPA中使用ID進(jìn)行批量更新,所以下面這篇文章主要給大家介紹了關(guān)于使用SpringBoot和JPA實(shí)現(xiàn)批量處理新增、修改的相關(guān)資料,文中通過(guò)實(shí)例代碼介紹的非常詳細(xì),需要的朋友可以參考下

jpa的sava與saveAll

save()方法

 @Transactional
    public <S extends T> S save(S entity) {
        if (this.entityInformation.isNew(entity)) {
            this.em.persist(entity);
            return entity;
        } else {
            return this.em.merge(entity);
        }
    }

根據(jù)源碼我們可以看出來(lái),save是先通過(guò)判斷這個(gè)對(duì)象是不是新的,新的便會(huì)新增,否則就是執(zhí)行的修改。整個(gè)是有分兩步進(jìn)行的,先查詢?cè)傩略?/p>

saveAll()方法

  @Transactional
    public <S extends T> List<S> saveAll(Iterable<S> entities) {
        Assert.notNull(entities, "The given Iterable of entities not be null!");
        List<S> result = new ArrayList();
        Iterator var3 = entities.iterator();
        while(var3.hasNext()) {
            S entity = var3.next();
            result.add(this.save(entity));
        }
        return result;
    }

saveAll()方法是一種更新多條的一種方式,里面?zhèn)鞯拇鎸?duì)象的集合。分析源碼我們可以看出saveAll()底層還是調(diào)用的save()方法,也就是每次需要先查詢?cè)僮鲂薷摹T谑褂蒙戏奖?,但是因每次涉及到查詢、新增,事?wù)的關(guān)系,導(dǎo)致修改或者新增耗時(shí)得非常的久。

那么下面我們將結(jié)合EntityManager對(duì)批量新增,修改做出優(yōu)化。

jpa結(jié)合Batch

配置文件

spring:
  #配置 Jpa
  jpa:
    properties:
      hibernate:
        generate_statistics: false
        order_insert: true    //配置批量新增
        order_update: true    //配置批量修改
        dialect: org.hibernate.dialect.MySQL5InnoDBDialect
        jdbc:
          batch_size: 1000    //容器內(nèi)批量的大小
    open-in-view: true

EntityManager

EntityManager其實(shí)就是一個(gè)容器,通過(guò)注解引入EntityManager對(duì)象 使用EntityManager對(duì)新增,修改進(jìn)行批量處理

/**
 * @author 程序員panda
 * @date 
 * @desc 批量處理
 */
@Service
@Transactional
public class BatchService {
    @PersistenceContext
    private EntityManager entityManager;
	//配置文件中每次批量提交的數(shù)量
    @Value("${spring.jpa.properties.hibernate.jdbc.batch_size}")
    private long batchSize;
    /**
     * 批量插入
     *
     * @param list 實(shí)體類集合
     * @param <T>  表對(duì)應(yīng)的實(shí)體類
     */
    public <T> void batchInsert(List<T> list) {
        if (!ObjectUtils.isEmpty(list)){
            for (int i = 0; i < list.size(); i++) {
                entityManager.persist(list.get(i));
                if (i % batchSize == 0) {
                    entityManager.flush();
                    entityManager.clear();
                }
            }
            entityManager.flush();
            entityManager.clear();
        }
    }
    /**
     * 批量更新
     *
     * @param list 實(shí)體類集合
     * @param <T>  表對(duì)應(yīng)的實(shí)體類
     */
    public <T> void batchUpdate(List<T> list) {
        if (!ObjectUtils.isEmpty(list)){
            for (int i = 0; i < list.size(); i++) {
                entityManager.merge(list.get(i));
                if (i % batchSize == 0) {
                    entityManager.flush();
                    entityManager.clear();
                }
            }
            entityManager.flush();
            entityManager.clear();
        }
    }
}

實(shí)際運(yùn)用

選擇一個(gè)需要新增的table,將原有的saveAll(),改為調(diào)用自定義的batchInsert()方法

 public JSONObject sumbitPhone(MultipartFile phoneFile) {
        long timeIdStart = System.currentTimeMillis();
        JSONObject result=new JSONObject();
        List<CheckPhone> phoneList=getPhoneListEn(phoneFile);
        batchService.batchInsert(phoneList);
        result.put("code",200);
        result.put("msg","提交成功");
        logger.info("提交預(yù)校驗(yàn)數(shù)據(jù)用時(shí):"+(System.currentTimeMillis() - timeIdStart) / 1000.0+"秒");
        return result;
    }

注意

使用batch批量新增的時(shí)候,表的主鍵不能使用自增的形式,需要使用uuid來(lái)才能使用批量的新增

運(yùn)行時(shí)間對(duì)比

使用saveall()方法耗時(shí)(提交1000個(gè)號(hào)碼文件) 從sql監(jiān)控中可以看到,新增1000個(gè)號(hào)碼,執(zhí)行了7.962秒,執(zhí)行了1000次的事務(wù),都是一個(gè)個(gè)提交的

使用batch批量新增(同為1000個(gè)號(hào)碼)此時(shí)執(zhí)行,提交了兩次,執(zhí)行了兩次事務(wù)。因?yàn)槲以O(shè)置了batch_size為1000。此時(shí)用是196毫秒。看一看出他是按999條數(shù)據(jù),然后統(tǒng)一提交的

總結(jié)

到此這篇關(guān)于使用SpringBoot和JPA實(shí)現(xiàn)批量處理新增、修改的文章就介紹到這了,更多相關(guān)SpringBoot JPA批量處理新增修改內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!

相關(guān)文章

  • 5分鐘快速學(xué)會(huì)spring boot整合Mybatis的方法

    5分鐘快速學(xué)會(huì)spring boot整合Mybatis的方法

    這篇文章主要給大家介紹了如何通過(guò)5分鐘快速學(xué)會(huì)spring boot整合Mybatis的相關(guān)資料,文中通過(guò)示例代碼介紹的非常詳細(xì),對(duì)大家學(xué)習(xí)或者使用spring boot具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面來(lái)一起學(xué)習(xí)學(xué)習(xí)吧
    2019-12-12
  • 利用SpringMVC和Ajax實(shí)現(xiàn)文件上傳功能

    利用SpringMVC和Ajax實(shí)現(xiàn)文件上傳功能

    這篇文章主要為大家詳細(xì)介紹了利用SpringMVC和Ajax實(shí)現(xiàn)文件上傳功能,具有一定的參考價(jià)值,感興趣的小伙伴們可以參考一下
    2019-08-08
  • java中關(guān)于控件JTextArea的幾個(gè)方法

    java中關(guān)于控件JTextArea的幾個(gè)方法

    這篇文章主要介紹了java中關(guān)于控件JTextArea的幾個(gè)方法,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方,望不吝賜教
    2022-08-08
  • 一篇文章帶你搞定 springsecurity基于數(shù)據(jù)庫(kù)的認(rèn)證(springsecurity整合mybatis)

    一篇文章帶你搞定 springsecurity基于數(shù)據(jù)庫(kù)的認(rèn)證(springsecurity整合mybatis)

    這篇文章主要介紹了一篇文章帶你搞定 springsecurity基于數(shù)據(jù)庫(kù)的認(rèn)證(springsecurity整合mybatis),文中通過(guò)示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧
    2020-10-10
  • java如何實(shí)現(xiàn)獲取客戶端ip地址的示例代碼

    java如何實(shí)現(xiàn)獲取客戶端ip地址的示例代碼

    本文主要介紹了java如何實(shí)現(xiàn)獲取客戶端ip地址,主要包括java獲取客戶端ip地址工具類使用實(shí)例、應(yīng)用技巧,文中通過(guò)示例代碼介紹的非常詳細(xì),感興趣的小伙伴們可以參考一下
    2022-04-04
  • Java?mybatis?開發(fā)自定義插件

    Java?mybatis?開發(fā)自定義插件

    這篇文章主要介紹了Java?mybatis開發(fā)自定義插件,MyBatis允許你在映射語(yǔ)句執(zhí)行過(guò)程中的某一點(diǎn)進(jìn)行攔截調(diào)用,文章圍繞主題展開詳細(xì)的內(nèi)容介紹,具有一定的參考價(jià)值,需要的小伙伴可以參考一下
    2022-08-08
  • 深度剖析Java中的內(nèi)存原型及工作原理

    深度剖析Java中的內(nèi)存原型及工作原理

    這篇文章主要介紹了深度剖析Java中的內(nèi)存原型及工作原理,本文講解了java虛擬機(jī)內(nèi)存原型、常量池、Java內(nèi)存分配中的棧、Java內(nèi)存分配中的堆等內(nèi)容,需要的朋友可以參考下
    2015-01-01
  • Spring?MVC啟動(dòng)之HandlerMapping作用及實(shí)現(xiàn)詳解

    Spring?MVC啟動(dòng)之HandlerMapping作用及實(shí)現(xiàn)詳解

    這篇文章主要為大家介紹了Spring?MVC啟動(dòng)之HandlerMapping作用及實(shí)現(xiàn)詳解,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步,早日升職加薪
    2023-03-03
  • springboot 如何使用jackson來(lái)處理實(shí)體類

    springboot 如何使用jackson來(lái)處理實(shí)體類

    這篇文章主要介紹了springboot使用jackson來(lái)處理實(shí)體類的操作,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方,望不吝賜教
    2021-10-10
  • Java之CMS和G1垃圾回收過(guò)程的異同說(shuō)明

    Java之CMS和G1垃圾回收過(guò)程的異同說(shuō)明

    CMS垃圾回收器主要基于并發(fā)-清理算法,目的是減少停頓時(shí)間,通過(guò)四個(gè)主要階段進(jìn)行垃圾回收:初始標(biāo)記、并發(fā)標(biāo)記、重新標(biāo)記和并發(fā)清理,G1垃圾回收器采用標(biāo)記-整理算法,是JDK9后的默認(rèn)垃圾收集器,設(shè)計(jì)為全功能全代收集器
    2024-09-09

最新評(píng)論

新巴尔虎左旗| 麻栗坡县| 尚义县| 英德市| 章丘市| 田阳县| 沧州市| 江山市| 桐城市| 鱼台县| 壶关县| 岢岚县| 金塔县| 陇川县| 博罗县| 徐水县| 河东区| 黄龙县| 无棣县| 鹿邑县| 天柱县| 宿州市| 鄂托克前旗| 吉林省| 改则县| 连城县| 绿春县| 巫溪县| 榆社县| 青铜峡市| 寿阳县| 台山市| 英超| 凯里市| 杨浦区| 双江| 隆安县| 色达县| 拜城县| 汉沽区| 绥滨县|