解决spring

网友投稿 576 2022-12-21

解决spring

解决spring

问题还原

项目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(">>>MovmgLcGeParams: [{}]", 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 children = workSpaceRepository.findByParentIdOrderBySortIndexDesc(

moveWorkSpaceDto.getDestParentId());

if (CollectionUtils.isEmpty(children)) {

sourceEntity.setSortIndex(souhttp://rceEntity.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 = http://Exception.class)

public void move(MoveWorkSpaceDto moveWorkSpaceDto) {

/***

* 个人空间节点移动

* 1、源节点移动到空目录,那么目标父节点必传,前置和后置节点都为空

* 2、源节点移动到非空目录:

* 2.1、移动到目标目录的第一个mgLcG节点,那么后置节点必传,前置节点为空

* 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 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 = cronTaskRhttp://epository.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修改属性。

版权声明:本文内容由网络用户投稿,版权归原作者所有,本站不拥有其著作权,亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容,请联系我们jiasou666@gmail.com 处理,核实后本网站将在24小时内删除侵权内容。

上一篇:一体化政务服务平台 培训(政务服务中心一体化平台)
下一篇:扬州车载物联网卡推荐(车载 物联网卡)
相关文章

 发表评论

暂时没有评论,来抢沙发吧~