2

考虑以下 JPA 实体:

@Entity @Table(name = "product") class Product { ... }

@Entity @Table(name = "stock") class Stock {
  @JoinColumn(name = "product_id", updatable = false)
  @ManyToOne(fetch = FetchType.LAZY)
  private Product product;

  @Column(name = "quantity")
  private Long quantity;
}

@Entity @Table(name = "cart") class Cart {
  @OneToMany(cascade = CascadeType.ALL, fetch = FetchType.LAZY, mappedBy = "cart", orphanRemoval = true)
  private List<CartItem> items = new ArrayList<>();

  public void addItem(CartItem item) { items.add(item); }
  public void removeItem(CartItem item) { items.remove(item); }
}

@Entity @Table(name = "cart_item") class CartItem {
  @JoinColumn(name = "cart_id", updatable = false)
  @ManyToOne(fetch = FetchType.LAZY)
  private Cart cart;

  @JoinColumn(name = "product_id", updatable = false)
  @ManyToOne(fetch = FetchType.LAZY)
  private Product product;

  @Column(name = "quantity")
  private Long quantity;

  @JoinColumn(name = "stock_id", updatable = false)
  @ManyToOne(cascade = CascadeType.ALL, fetch = FetchType.LAZY)
  private Stock stock;

  public void setQuantity(Long quantity) {
    final Long delta = this.quantity - Math.max(0L, quantity);

    this.quantity += delta;
    this.stock.setQuantity(this.stock.getQuantity() - delta);

    if(quantity < 1) { cart.removeItem(this); }
  }
}

注意从CartItem到的关联Stock。此关联已被注释,因此更改购物车项目数量会在另一个方向影响其可用库存,也就是说,如果购物车项目数量增加,产品的可用库存数量会减少,反之亦然。

这使我可以开火cartRepository.save(cart),保存所有购物车物品并同时更新其库存(由于Cascade.ALLfrom Cartto CartItem)。只要购物车项目的数量非零,这就可以正常工作。

但是,当cartRepository.save(cart)在调用 之后调用cart.removeItem(item)时,级联也会尝试删除购物车项目的库存,这不是本意。应删除购物车项目,但应简单地更新其相关库存。有没有办法从 to 级联更新CartItemStock但级联删除CartItem作为更新Stock

4

2 回答 2

6

改变

class CartItem {
  @JoinColumn(name = "stock_id", updatable = false)
  @ManyToOne(cascade = CascadeType.ALL, fetch = FetchType.LAZY)
  private Stock stock;
}

class CartItem {
  @JoinColumn(name = "stock_id", updatable = false)
  @ManyToOne(cascade = { CascadeType.MERGE, CascadeType.PERSIST }, fetch = FetchType.LAZY)
  private Stock stock;
}

( CascadeType.ALLto { CascadeType.MERGE, CascadeType.PERSIST }) 解决了这个问题。以前在cartItem.setQuantity(0)调用时执行了以下 SQL 查询:

delete from cart_item where id=?
delete from stock where id=?

通过更改,将根据需要执行以下 SQL 查询:

update stock set quantity=? where id=?
delete from cart_item where id=?

Github上提供了示例应用程序,用于检查解决方案的正确性。

于 2016-07-07T11:53:37.440 回答
1

至少可以说,您的方法很有问题。如果多个线程修改同一产品的数量会怎样?JPA 不防范并发访问!即使你在技术上不会遇到同步问题,你也会在逻辑上遇到它们,因为(持久的)数量将被错误的值覆盖(或者你得到一个OptimisticLockException)。

您应该避免这种头痛,并将数量视为动态值,并使用 select 语句计算产品的当前数量。

如果您坚持缓存数量,您应该为此任务使用单独的服务,该服务使用适当的同步、并发映射等。

于 2015-11-12T14:56:23.533 回答