public void validateAndDecreaseSolution(long ProductId, int 数量 {
    可选<stockentity> stockByProductId = 
 stockRepository.findStockByProductId(productId);

    int stock = stockByProductId.orElseThrow().getStock();
    int possibleStock = 库存 - 数量；

    if (股票 



<p>您可以使用此验证，但当我们谈论每秒几百、几千、几百万甚至几十个请求时，这种验证是不够的。当 10 该请求同时到达代码，数据库为 stockByProductId 当返回相同值时，您的代码将崩溃。当 10 该请求同时到达代码，数据库为 stockByProductId 当你回到同一个值时，你的代码就会崩溃。当我们验证时，你需要一种方法来阻止其他请求。</p>

<h3>
  
  
  第一个解决方案 - 用于更新
</h3>

<p>在 SELECT 添加锁定语句。我在这个例子中使用它 Spring Data 的 FOR UPDATE 完成此操作。正如 PostgreSQL 文档所说</p>

<blockquote>
FOR UPDATE 会导致 SELECT 语句检索到的行被锁定，就像更新一样。在当前交易结束之前，它们可以被其他交易修改或删除。

</blockquote>

<pre class="brush:php;toolbar:false">@Query(value = "从股票 s 中选择 * WHERE s.product_id = ?1 FOR UPDATE", nativeQuery = true)
可选<stockentity> findStockByProductIdWithLock(Long ProductId);
</stockentity>

public void validateandecreasesolution(long ProductId, int amount) {
    可选<stockentity> stockByProductId = stockRepository.findStockByProductIdWithLock(productId);

    // ... 证实

    stockRepository.decreaseStock(productId, 数量);
}
</stockentity>

public void acquirelockAndecreasolution(long ProductId, int amount) {
    查看nativeQuery =entityManager.createNativeQuery("选择pg_advisory_xact_lock(:lockId)");
    nativeQuery.setParameter("lockId",productId);
    nativeQuery.getSingleResult();

    可选<stockentity> stockByProductId = stockRepository.findStockByProductId(productId);

    // 必要时检查库存并抛出异常

    stockRepository.decreaseStock(productId, 数量);
}
</stockentity>

@交易
@修改
@Query(nativeQuery = true, value = "更新库存 SET stock = stock - :quantity WHERE Product_id = :productId AND stock > 0")
int reduceStockWhereQuantityGreaterThanZero(@Param("productId") Long ProductId, @Param("quantity") int amount);