解决spring-data-jpa 事物中修改属性自动更新update问题
更新时间：2021年08月06日 10:04:32 作者：南风nanfeng
这篇文章主要介绍了解决spring-data-jpa 事物中修改属性自动更新update问题，具有很好的参考价值，希望对大家
问题还原
项目orm层用的是spring-data-jpa，服务端接口实现的是树节点间的拖拽功能，测试环境联调发现异常问题，其中拖拽到目标目录后节点名称总会重名，重名规则是originName转化为originName(n)
@Transactional(rollbackFor = Exception.class)
public void move(MoveWorkSpaceDto moveWorkSpaceDto) {
/***
* 个人空间节点移动
* 1、源节点移动到空目录，那么目标父节点必传，前置和后置节点都为空
* 2、源节点移动到非空目录：
* 2.1、移动到目标目录的第一个节点，那么后置节点必传，前置节点为空
* 2.2、移动到目标目录的最后个节点，那么前置节点毕传，后置节点为空
* 2.3、移动到目标目录的中间节点，那么前置节点和后置节点都要传入
* 3、节点拖动到目录中，此时不知道目录是否非空，前置后置节点都不传，服务器追加到目录的最后个节点
*/
log.info(">>>MoveParams: [{}]", JSONObject.toJSONString(moveWorkSpaceDto));
WorkSpaceEntity sourceEntity = workSpaceRepository.findById(moveWorkSpaceDto.getSourceWorkId()).orElse(null);
if (sourceEntity == null) {
throw new PublicsException("源工作空间节点不存在！");
}
WorkSpaceEntity parentEntity = workSpaceRepository.findById(moveWorkSpaceDto.getDestParentId()).orElse(null);
if (parentEntity == null) {
throw new PublicsException("目标父工作空间节点不存在！");
}
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);
}
排查后发现代码逻辑正常，于是加日志定位，果然在更新项目前多了update操作，具体位置如下：
说明entity实体更新属性后，jpa自动执行了update属性，导致count判重始终大于0。
问题原因
jpa在hibernate上更进一步，我把单表的查询逻辑定义在Repository层的方法上，不用谢SQL，简单明了，不曾想，忽略的hibernate的entity在session的3种状态。
- 临时态，刚创建new的对象，还没有持久化，session缓存中也没有。
- 游离态，已经持久化，但不在session缓存中。
- 持久态，已经持久化，也在session缓存中。
问题原因明确，sourceEntity在持久态，修改属性自然会更新到数据库，判重查询已经更新了，查的还是自己，所以总是误认为有重复节点。
解决办法--隔离entity
避开session中缓存的sourceEntity的修改，创建新entity，修改临时态的entity，设置好属性后再调用save更新数据
@Transactional(rollbackFor = Exception.class)
public void move(MoveWorkSpaceDto moveWorkSpaceDto) {
/***
* 个人空间节点移动
* 1、源节点移动到空目录，那么目标父节点必传，前置和后置节点都为空
* 2、源节点移动到非空目录：
* 2.1、移动到目标目录的第一个节点，那么后置节点必传，前置节点为空
* 2.2、移动到目标目录的最后个节点，那么前置节点毕传，后置节点为空
* 2.3、移动到目标目录的中间节点，那么前置节点和后置节点都要传入
* 3、节点拖动到目录中，此时不知道目录是否非空，前置后置节点都不传，服务器追加到目录的最后个节点
*/
log.info(">>>MoveParams: [{}]", JSONObject.toJSONString(moveWorkSpaceDto));
WorkSpaceEntity sourceEntity = workSpaceRepository.findById(moveWorkSpaceDto.getSourceWorkId()).orElse(null);
if (sourceEntity == null) {
throw new PublicsException("源工作空间节点不存在！");
}
WorkSpaceEntity parentEntity = workSpaceRepository.findById(moveWorkSpaceDto.getDestParentId()).orElse(null);
if (parentEntity == null) {
throw new PublicsException("目标父工作空间节点不存在！");
}
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);
}
场景复现
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，因此避免误操作，建议创建临时态的entity修改属性。
以上为个人经验，希望能给大家一个参考，也希望大家多多支持脚本之家。
相关文章
如果有⼀个操作，多次执⾏与⼀次执⾏所产⽣的影响是相同的，我们就称这个操作是幂等的。当出现消费者对某条消息重复消费的情况时，重复消费的结果与消费⼀次的结果是相同的，并且多次消费并未对业务系统产⽣任何负⾯影响，那么这整个过程就可实现消息幂等2023-02-02
Spring Native打包本地镜像的操作方法(无需通过Graal的maven插件buildtools)
这篇文章主要介绍了Spring Native打包本地镜像，无需通过Graal的maven插件buildtools,本文探索一下，如果不通过这个插件来生成镜像，结合实例代码给大家介绍的非常详细，需要的朋友可以参考下2023-02-02
这篇文章主要介绍了Java中线程安全问题,本文给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下2021-05-05
这篇文章主要介绍了在java上使用亚马逊云储存方法,首先写一个配置类,写一个controller接口调用方法存储文件,本文结合示例代码给大家介绍的非常详细,需要的朋友参考下吧2024-01-01
这篇文章主要介绍了基于springboot 长轮询的实现操作，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧2021-01-01
这篇文章主要介绍了Java 7菱形语法与泛型构造器,结合实例形式分析了Java菱形语法与泛型构造器相关原理与使用技巧,需要的朋友可以参考下2019-07-07
这篇文章主要为大家详细介绍了Java简易聊天室之使用Socket实现通信功能，文中的示例代码讲解详细，具有一定的借鉴价值，需要的可以了解一下2022-10-10
Map映射LinkedHashSet与LinkedHashMap应用解析
这篇文章主要为大家介绍了Map映射LinkedHashSet与LinkedHashMap的应用解析，有需要的朋友可以借鉴参考下，希望能够有所帮助祝大家多多进步2022-03-03
这篇文章主要介绍了Java的动态绑定与双分派，小编觉得挺不错的，现在分享给大家，也给大家做个参考。一起跟随小编过来看看吧2017-08-08
这篇文章主要介绍了mybatis一对多方式实现批量插入,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教2023-11-11
最新评论