使用EntityManager批量保存數據

@PersistenceContext

EntityManager em;

從別的系統中按期同步某張表的數據，因爲數據量較大，採用批量保存

JPA EntityManager的四個主要方法

① public void persist(Object entity)

persist 方法能夠將實例轉換爲 managed( 託管 ) 狀態。在調用 flush() 方法或提交事物後，實例將會被插入到數據庫中。

     ② public void merge(Object entity)

merge 方法的主要做用是將用戶對一個 detached 狀態實體的修改進行歸檔，歸檔後將產生一個新的managed 狀態對象。

 

若是Entity是新建立的，則這個方法相似於persist()這個方法。

若是Entity已經存在的，則只做爲更新操做。

③ public void refresh(Object entity)

 refresh 方法能夠保證當前的實例與數據庫中的實例的內容一致。

④ public void remove(Object entity)

 remove 方法能夠將實體轉換爲 removed 狀態，而且在調用 flush() 方法或提交事物後刪除數據庫中的數據。
⑤ public void flush()

將PersistenceContext的信息同步到數據庫中。

 

  當觸發Flush這個動做的時候，全部的實體都將會被insert/update/remove到數據庫中。

  數據庫不會觸發Commit的操做。

⑥  public void refresh (Object entity)

Refresh的做用是從數據庫中將Entity的狀態進行更新操做。若是Entity和數據庫中的數據不一致，將更新數據庫中的數據到Entity中。

⑦ public void clear()

分離全部當前正在被管理的實體 —— clear()
在處理大量實體的時候，若是你不把已經處理過的實體從EntityManager中分離出來，將會消耗你大量的內存。調用 EntityManager 的clear()方法後，全部正在被管理的實體將會從持久化內容中分離出來。有一點須要說明下，在事務沒有 提交前（事務默認在調用堆棧的最後提交，如：方法的返回），若是調用clear()方法，以前對實體所做的任何改變將會掉 失，因此建議你在調用clear()方法以前先調用flush()方法保存更改。

 

 

public void eamMaterialCodeDatabase(){
    String updateTimeStr = eamMaterialCodeService.getUpdateTimeStr();
    SQLBuilder sb = new SQLBuilder("IFSAPP.INVENTORY_PART");
    sb.addField("DESCRIPTION name");
    sb.addField("PART_NO code");
    sb.addField("TYPE_DESIGNATION type");
    sb.addWhereClause(" CONTRACT = 'RS'");
    sb.setWithSemicolon(false);
    String sql = sb.createQuery();
    List objects = eamJT.queryForList(sql);

    List<EamMaterialCode> wantToSaved = new ArrayList<EamMaterialCode>();

    for (Object obj : objects) {
        Map objs = (Map) obj;
        EamMaterialCode eamMaterialCode = new EamMaterialCode();
        eamMaterialCode.setName((String)(objs.get("name") == null ? "" : objs.get("name")));
        eamMaterialCode.setType((String)(objs.get("type") == null ? "" : objs.get("type")));
        eamMaterialCode.setCode((String)(objs.get("code") == null ? "" : objs.get("code")));
        eamMaterialCode.setVersion(1);

        EamMaterialCode eamMaterialCode2 = eamMaterialCodeService.findByCode(eamMaterialCode.getCode());
        if (eamMaterialCode2 == null) {
            wantToSaved.add(eamMaterialCode);
        } else {
            int version = eamMaterialCode2.getVersion() + 1;
            eamMaterialCode.setId(eamMaterialCode2.getId());
            BeanUtils.copyProperties(eamMaterialCode, eamMaterialCode2);
            eamMaterialCode2.setVersion(version);
            wantToSaved.add(eamMaterialCode2);
        }
    }

    eamMaterialCodeService.batchInsertAndUpdate(wantToSaved);
}

 

 

@Transactional(readOnly = false)
    public void batchInsertAndUpdate(List list) {
            int size =  list.size();
        for (int i = 0; i < size; i++) {
            BaseEntity dd = (BaseEntity) list.get(i);
            if (dd.isNew()) {
                 em.persist(dd);
            } else {
                em.persist(em.merge(dd));
            }
            if (i % 1000 == 0 || i==(size-1)) { // 每1000條數據執行一次，或者最後不足1000條時執行
                em.flush();
                em.clear();
            }
        }
    }