第二个事务会覆盖第一个事务的更改

问题描述 投票:0回答:1

我在一个项目中工作,我们使用Spring Data Rest with HATEOAS,Spring JPA和Hibernate,目前我们遇到了一个奇怪的问题,我们无法修复:

  1. Angular前端将两个HTTP请求发送到后端。两个请求都希望在同一行的不同列中添加关系(因为HATEOAS必须在两个请求中完成)。
  2. 创建了两个事务(A和B),Hibernate在每个事务中执行select以获取有问题的行。
  3. Hibernate获取将在每个事务中链接的实体。
  4. 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;
}

应更新字段componenttype

如果我们能够确保两个请求都正确地更新行或者事务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));
}

componentControltypeControl都是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

hibernate spring-data-jpa spring-data spring-data-rest spring-transactions
1个回答
1
投票

不幸的是我不知道Angular 7,但我有一种感觉,saveObservs.push异步工作。这意味着有时第二个请求在第一个请求完成之前到达API,从DB加载未修改的记录,然后将其写回,仅修改第二个引用。

所以第二次推进应该等待第一次的结果。

但是,如果您尝试同时从两个客户端修改同一对象,则无法解决此问题。

您应该将version属性添加到实体,如果您尝试使用过时版本修改对象,Spring Data Rest将自动响应错误。

  @Version
  private Long version;
© www.soinside.com 2019 - 2024. All rights reserved.