文章详情

短信预约-IT技能 免费直播动态提醒

请输入下面的图形验证码

提交验证

短信预约提醒成功

如何解决spring-data-jpa事物中修改属性自动更新update问题

2023-06-20 20:03

关注

小编给大家分享一下如何解决spring-data-jpa事物中修改属性自动更新update问题,相信大部分人都还不怎么了解,因此分享这篇文章给大家参考一下,希望大家阅读完这篇文章后大有收获,下面让我们一起去了解一下吧!

问题还原

项目orm层用的是spring-data-jpa,服务端接口实现的是树节点间的拖拽功能,测试环境联调发现异常问题,其中拖拽到目标目录后节点名称总会重名,重名规则是originName转化为originName(n)

@Transactional(rollbackFor = Exception.class)    public void move(MoveWorkSpaceDto moveWorkSpaceDto) {                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操作,具体位置如下:

如何解决spring-data-jpa事物中修改属性自动更新update问题

说明entity实体更新属性后,jpa自动执行了update属性,导致count判重始终大于0。

问题原因

jpa在hibernate上更进一步,我把单表的查询逻辑定义在Repository层的方法上,不用谢SQL,简单明了,不曾想,忽略的hibernate的entity在session的3种状态。

问题原因明确,sourceEntity在持久态,修改属性自然会更新到数据库,判重查询已经更新了,查的还是自己,所以总是误认为有重复节点。

解决办法--隔离entity

避开session中缓存的sourceEntity的修改,创建新entity,修改临时态的entity,设置好属性后再调用save更新数据

@Transactional(rollbackFor = Exception.class)    public void move(MoveWorkSpaceDto moveWorkSpaceDto) {                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修改属性。

以上是“如何解决spring-data-jpa事物中修改属性自动更新update问题”这篇文章的所有内容,感谢各位的阅读!相信大家都有了一定的了解,希望分享的内容对大家有所帮助,如果还想学习更多知识,欢迎关注编程网行业资讯频道!

阅读原文内容投诉

免责声明:

① 本站未注明“稿件来源”的信息均来自网络整理。其文字、图片和音视频稿件的所属权归原作者所有。本站收集整理出于非商业性的教育和科研之目的,并不意味着本站赞同其观点或证实其内容的真实性。仅作为临时的测试数据,供内部测试之用。本站并未授权任何人以任何方式主动获取本站任何信息。

② 本站未注明“稿件来源”的临时测试数据将在测试完成后最终做删除处理。有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341

软考中级精品资料免费领

  • 历年真题答案解析
  • 备考技巧名师总结
  • 高频考点精准押题
  • 2024年上半年信息系统项目管理师第二批次真题及答案解析(完整版)

    难度     813人已做
    查看
  • 【考后总结】2024年5月26日信息系统项目管理师第2批次考情分析

    难度     354人已做
    查看
  • 【考后总结】2024年5月25日信息系统项目管理师第1批次考情分析

    难度     318人已做
    查看
  • 2024年上半年软考高项第一、二批次真题考点汇总(完整版)

    难度     435人已做
    查看
  • 2024年上半年系统架构设计师考试综合知识真题

    难度     224人已做
    查看

相关文章

发现更多好内容

猜你喜欢

AI推送时光机
位置:首页-资讯-后端开发
咦!没有更多了?去看看其它编程学习网 内容吧
首页课程
资料下载
问答资讯