解決spring-data-jpa 事物中修改屬性自動更新update問題
更新時間：2021年08月06日 10:04:32 作者：南風nanfeng
這篇文章主要介紹了解決spring-data-jpa 事物中修改屬性自動更新update問題，具有很好的參考價值，希望對大家
問題還原
項目orm層用的是spring-data-jpa，服務(wù)端接口實現(xiàn)的是樹節(jié)點間的拖拽功能，測試環(huán)境聯(lián)調(diào)發(fā)現(xiàn)異常問題，其中拖拽到目標目錄后節(jié)點名稱總會重名，重名規(guī)則是originName轉(zhuǎn)化為originName(n)
@Transactional(rollbackFor = Exception.class)
public void move(MoveWorkSpaceDto moveWorkSpaceDto) {
/***
* 個人空間節(jié)點移動
* 1、源節(jié)點移動到空目錄，那么目標父節(jié)點必傳，前置和后置節(jié)點都為空
* 2、源節(jié)點移動到非空目錄：
* 2.1、移動到目標目錄的第一個節(jié)點，那么后置節(jié)點必傳，前置節(jié)點為空
* 2.2、移動到目標目錄的最后個節(jié)點，那么前置節(jié)點畢傳，后置節(jié)點為空
* 2.3、移動到目標目錄的中間節(jié)點，那么前置節(jié)點和后置節(jié)點都要傳入
* 3、節(jié)點拖動到目錄中，此時不知道目錄是否非空，前置后置節(jié)點都不傳，服務(wù)器追加到目錄的最后個節(jié)點
*/
log.info(">>>MoveParams: [{}]", JSONObject.toJSONString(moveWorkSpaceDto));
WorkSpaceEntity sourceEntity = workSpaceRepository.findById(moveWorkSpaceDto.getSourceWorkId()).orElse(null);
if (sourceEntity == null) {
throw new PublicsException("源工作空間節(jié)點不存在！");
}
WorkSpaceEntity parentEntity = workSpaceRepository.findById(moveWorkSpaceDto.getDestParentId()).orElse(null);
if (parentEntity == null) {
throw new PublicsException("目標父工作空間節(jié)點不存在！");
}
log.info(">>>>Noooooooo<<<<<");
sourceEntity.setParentId(parentEntity.getId());
log.info(">>>>UpdateNow<<<<<");
Long cnt = workSpaceRepository.countAllByParentIdAndSpaceName(parentEntity.getId(), sourceEntity.getSpaceName());
log.info("destParentId: [{}], spaceName: [{}], destCount: [{}]", parentEntity.getId(), sourceEntity.getSpaceName(), cnt);
if (cnt > 0L) {
String newName = RenameUtil.rename(sourceEntity.getSpaceName(), sourceEntity.getRunType(), cnt);
sourceEntity.setSpaceName(newName);
}
if (moveWorkSpaceDto.getFrontWorkId() == null && moveWorkSpaceDto.getPostWorkId() == null) {
List<WorkSpaceEntity> children = workSpaceRepository.findByParentIdOrderBySortIndexDesc(
moveWorkSpaceDto.getDestParentId());
if (CollectionUtils.isEmpty(children)) {
sourceEntity.setSortIndex(sourceEntity.getId() * SORT_INDEX_STEP);
} else {
sourceEntity.setSortIndex(children.get(0).getSortIndex() + SORT_INDEX_STEP);
}
} else if (moveWorkSpaceDto.getFrontWorkId() != null && moveWorkSpaceDto.getPostWorkId() == null) {
WorkSpaceEntity frontEntity = getFrontEntity(moveWorkSpaceDto);
sourceEntity.setSortIndex(frontEntity.getSortIndex() + SORT_INDEX_STEP);
} else if (moveWorkSpaceDto.getFrontWorkId() == null && moveWorkSpaceDto.getPostWorkId() != null) {
WorkSpaceEntity postEntity = getPostEntity(moveWorkSpaceDto);
sourceEntity.setSortIndex(postEntity.getSortIndex() - SORT_INDEX_STEP);
} else {
WorkSpaceEntity frontEntity = getFrontEntity(moveWorkSpaceDto);
WorkSpaceEntity postEntity = getPostEntity(moveWorkSpaceDto);
sourceEntity.setSortIndex((frontEntity.getSortIndex() + postEntity.getSortIndex()) / 2);
}
workSpaceRepository.save(sourceEntity);
}
排查后發(fā)現(xiàn)代碼邏輯正常，于是加日志定位，果然在更新項目前多了update操作，具體位置如下：
說明entity實體更新屬性后，jpa自動執(zhí)行了update屬性，導致count判重始終大于0。
問題原因
jpa在hibernate上更進一步，我把單表的查詢邏輯定義在Repository層的方法上，不用謝SQL，簡單明了，不曾想，忽略的hibernate的entity在session的3種狀態(tài)。
- 臨時態(tài)，剛創(chuàng)建new的對象，還沒有持久化，session緩存中也沒有。
- 游離態(tài)，已經(jīng)持久化，但不在session緩存中。
- 持久態(tài)，已經(jīng)持久化，也在session緩存中。
問題原因明確，sourceEntity在持久態(tài)，修改屬性自然會更新到數(shù)據(jù)庫，判重查詢已經(jīng)更新了，查的還是自己，所以總是誤認為有重復節(jié)點。
解決辦法--隔離entity
避開session中緩存的sourceEntity的修改，創(chuàng)建新entity，修改臨時態(tài)的entity，設(shè)置好屬性后再調(diào)用save更新數(shù)據(jù)
@Transactional(rollbackFor = Exception.class)
public void move(MoveWorkSpaceDto moveWorkSpaceDto) {
/***
* 個人空間節(jié)點移動
* 1、源節(jié)點移動到空目錄，那么目標父節(jié)點必傳，前置和后置節(jié)點都為空
* 2、源節(jié)點移動到非空目錄：
* 2.1、移動到目標目錄的第一個節(jié)點，那么后置節(jié)點必傳，前置節(jié)點為空
* 2.2、移動到目標目錄的最后個節(jié)點，那么前置節(jié)點畢傳，后置節(jié)點為空
* 2.3、移動到目標目錄的中間節(jié)點，那么前置節(jié)點和后置節(jié)點都要傳入
* 3、節(jié)點拖動到目錄中，此時不知道目錄是否非空，前置后置節(jié)點都不傳，服務(wù)器追加到目錄的最后個節(jié)點
*/
log.info(">>>MoveParams: [{}]", JSONObject.toJSONString(moveWorkSpaceDto));
WorkSpaceEntity sourceEntity = workSpaceRepository.findById(moveWorkSpaceDto.getSourceWorkId()).orElse(null);
if (sourceEntity == null) {
throw new PublicsException("源工作空間節(jié)點不存在！");
}
WorkSpaceEntity parentEntity = workSpaceRepository.findById(moveWorkSpaceDto.getDestParentId()).orElse(null);
if (parentEntity == null) {
throw new PublicsException("目標父工作空間節(jié)點不存在！");
}
WorkSpaceEntity updateEntity = new WorkSpaceEntity();
BeanUtils.copyProperties(sourceEntity, updateEntity);
Long cnt = workSpaceRepository.countByParentIdAndSpaceName(parentEntity.getId(), updateEntity.getSpaceName());
log.info("destParentId: [{}], spaceName: [{}], destCount: [{}]", parentEntity.getId(), updateEntity.getSpaceName(), cnt);
if (cnt > 0L) {
String newName = RenameUtil.rename(updateEntity.getSpaceName(), updateEntity.getRunType(), cnt);
updateEntity.setSpaceName(newName);
}
if (moveWorkSpaceDto.getFrontWorkId() == null && moveWorkSpaceDto.getPostWorkId() == null) {
List<WorkSpaceEntity> children = workSpaceRepository.findByParentIdOrderBySortIndexDesc(
moveWorkSpaceDto.getDestParentId());
if (CollectionUtils.isEmpty(children)) {
updateEntity.setSortIndex(updateEntity.getId() * SORT_INDEX_STEP);
} else {
updateEntity.setSortIndex(children.get(0).getSortIndex() + SORT_INDEX_STEP);
}
} else if (moveWorkSpaceDto.getFrontWorkId() != null && moveWorkSpaceDto.getPostWorkId() == null) {
WorkSpaceEntity frontEntity = getFrontEntity(moveWorkSpaceDto);
updateEntity.setSortIndex(frontEntity.getSortIndex() + SORT_INDEX_STEP);
} else if (moveWorkSpaceDto.getFrontWorkId() == null && moveWorkSpaceDto.getPostWorkId() != null) {
WorkSpaceEntity postEntity = getPostEntity(moveWorkSpaceDto);
updateEntity.setSortIndex(postEntity.getSortIndex() - SORT_INDEX_STEP);
} else {
WorkSpaceEntity frontEntity = getFrontEntity(moveWorkSpaceDto);
WorkSpaceEntity postEntity = getPostEntity(moveWorkSpaceDto);
updateEntity.setSortIndex((frontEntity.getSortIndex() + postEntity.getSortIndex()) / 2);
}
updateEntity.setParentId(parentEntity.getId());
workSpaceRepository.save(updateEntity);
}
場景復現(xiàn)
1、無事物的service中修改
public void test() {
CronTaskEntity cronTaskEntity = cronTaskRepository.findById(18L).orElse(null);
// 更新記錄
cronTaskEntity.setUsername("魯班七號");
CronTaskEntity newEntity = cronTaskRepository.findById(18L).orElse(null);
Assert.isTrue(cronTaskEntity.getUsername().equals(newEntity.getUsername()), "查詢‘魯班七號'沒有更新啊");
}
運行后：
Caused by: java.lang.IllegalArgumentException: 查詢‘魯班七號'沒有更新啊
2、有事物中的service修改
@Transactional
public void test() {
CronTaskEntity cronTaskEntity = cronTaskRepository.findById(18L).orElse(null);
// 更新記錄
cronTaskEntity.setUsername("魯班七號");
CronTaskEntity newEntity = cronTaskRepository.findById(18L).orElse(null);
Assert.isTrue(cronTaskEntity.getUsername().equals(newEntity.getUsername()), "查詢‘魯班七號'沒有更新啊");
}
運行后：
Hibernate: update `cron_task` set `createtime`=?, `updatetime`=?, `is_deleted`=?, `cron_expression`=?, `remark`=?, `staff_id`=?, `tag_id`=?, `username`=? where `id`=?
通過
由此可見，事物中會保存entity的緩存，修改entity屬性引起jpa自動update，因此避免誤操作，建議創(chuàng)建臨時態(tài)的entity修改屬性。
以上為個人經(jīng)驗，希望能給大家一個參考，也希望大家多多支持腳本之家。
相關(guān)文章
這篇文章主要介紹了Java 實現(xiàn)滑動時間窗口限流算法的代碼,本文通過實例代碼給大家介紹的非常詳細，對大家的學習或工作具有一定的參考借鑒價值，需要的朋友可以參考下2020-11-11
這篇文章主要介紹了全局記錄Feign的請求和響應(yīng)日志方式，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2022-06-06
本文主要介紹Java 多線程的知識，這里整理了詳細的資料及簡單示例代碼有需要的小伙伴可以參考下2016-09-09
這篇文章主要介紹了Java擴展Nginx之共享內(nèi)存的相關(guān)資料,需要的朋友可以參考下2023-07-07
這篇文章主要介紹了Spring Data JPA整合MySQL和配置,小編覺得挺不錯的，現(xiàn)在分享給大家，也給大家做個參考。一起跟隨小編過來看看吧2018-04-04
這篇文章主要介紹了eclipse自動提示和自動補全的相關(guān)內(nèi)容，文中向大家分享了二者的實現(xiàn)方法代碼，需要的朋友可以了解下。2017-09-09
這篇文章主要介紹了Mybatis-Plus的使用詳解,文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧2020-10-10
這篇文章主要介紹了spring @Transactional 無效的解決方案,文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧2019-03-03
這篇文章主要介紹了java實現(xiàn)兩個對象之間傳值及簡單的封裝，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2021-11-11
在java中，任何對象都要有生命周期，線程也不例外，它也有自己的生命周期。線程的整個生命周期可以分為5個階段，分別是新建狀態(tài)、就緒狀態(tài)、運行狀態(tài)、阻塞狀態(tài)和死亡狀態(tài)2022-04-04