第二个事务会覆盖第一个事务的更改
Posted
tags:
篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了第二个事务会覆盖第一个事务的更改相关的知识,希望对你有一定的参考价值。
我在一个项目中工作,我们使用Spring Data Rest with HATEOAS,Spring JPA和Hibernate,目前我们遇到了一个奇怪的问题,我们无法修复:
- Angular前端将两个HTTP请求发送到后端。两个请求都希望在同一行的不同列中添加关系(因为HATEOAS必须在两个请求中完成)。
- 创建了两个事务(A和B),Hibernate在每个事务中执行select以获取有问题的行。
- Hibernate获取将在每个事务中链接的实体。
- Hibernate在事务A中更新所选行一次。事务B不久后更新该行,并将事务A中设置的值重置为在事务开始时执行的初始选择的值。所以我们正在丢失交易A的所有信息。
问题是这似乎不是确定性的。它有时会发生,然后十次正常工作。
我们无法通过添加锁定来解决这个问题(乐观锁定只会导致事务B中的ObjectOptimisticLockingFailureException
)并且悲观锁定也没有效果。我们正在为实体使用DynamicUpdate。我们尝试在事务上设置传播,但这并没有改变任何东西。现在我们没有想法,谷歌搜索没有产生任何结果。
应更新的实体如下所示:
@AllArgsConstructor
@RequiredArgsConstructor
@NoArgsConstructor
@Data
@JsonIgnoreProperties(value = { "history" }, allowGetters = true)
@DynamicUpdate
@SelectBeforeUpdate
@Entity
@Table(name = "parameters")
public class Parameter
{
@Id
@GeneratedValue(strategy = GenerationType.IDENTITY)
@Column(name = "parameter_id", unique = true)
private Long id;
@NonNull
@Column(name = "name", nullable = false, unique = true)
private String key;
@ManyToOne(fetch = FetchType.EAGER,
cascade = {
CascadeType.REFRESH,
CascadeType.MERGE,
CascadeType.PERSIST,
CascadeType.DETACH
}
)
private Component component;
@OneToOne(fetch = FetchType.EAGER,
cascade = {
CascadeType.REFRESH,
CascadeType.MERGE,
CascadeType.PERSIST,
CascadeType.DETACH
}
)
private ParameterTypes type;
@OneToMany(
mappedBy = "parameter",
fetch = FetchType.LAZY,
cascade = CascadeType.ALL,
orphanRemoval = true
)
@OrderBy("history_creation_timestamp DESC")
private List<History> history = new LinkedList<>();
@CreationTimestamp
@Column(name = "parameter_creation_timestamp")
private LocalDateTime creationTimestamp;
@UpdateTimestamp
@Column(name = "parameter_update_timestamp")
private LocalDateTime updateTimestamp;
}
应更新字段component
和type
。
如果我们能够确保两个请求都正确地更新行或者事务B等待事务A完成并重新选择处于更新状态的行,那将是很好的。
我们非常感谢任何帮助,因为我们在过去三天内找不到合适的解决方案。我们很乐意提供任何其他信息。谢谢大家。
前端
我们正在使用带有Angular 7的angular4-hal与Spring后端进行通信。这个电话很简单,看起来如下:
saveParameter(): void {
this.editMode = false;
const saveObservs: Observable<any>[] = [];
if (this.componentControl.dirty) {
saveObservs.push(this.parameter.addRelation('component', this.componentControl.value));
}
if (this.typeControl.dirty) {
saveObservs.push(this.parameter.addRelation('type', this.typeControl.value));
}
forkJoin(
saveObservs
).pipe(
catchError(err => of(err))
).subscribe(val => console.log(val));
}
componentControl
和typeControl
都是FormControl
实例。
addRelation
函数如下所示:
Resource.prototype.addRelation = function (relation, resource) {
if (this.existRelationLink(relation)) {
var header = ResourceHelper.headers.append('Content-Type', 'text/uri-list');
return ResourceHelper.getHttp().put(ResourceHelper.getProxy(this.getRelationLinkHref(relation)), resource._links.self.href, { headers: header });
}
else {
return observableThrowError('no relation found');
}
};
并且函数的上下文可以找到here
不幸的是我不知道Angular 7,但我有一种感觉,saveObservs.push
异步工作。这意味着有时第二个请求在第一个请求完成之前到达API,从DB加载未修改的记录,然后将其写回,仅修改第二个引用。
所以第二次推进应该等待第一次的结果。
但是,如果您尝试同时从两个客户端修改同一对象,则无法解决此问题。
您应该将version
属性添加到实体,如果您尝试使用过时版本修改对象,Spring Data Rest将自动响应错误。
@Version
private Long version;
以上是关于第二个事务会覆盖第一个事务的更改的主要内容,如果未能解决你的问题,请参考以下文章