如何使用 Java 和 PostgreSQL 处理竞争条件（怎样使

public void validateAndDecreaseSolution(long ProductId, int 数量 {

可选<stockentity> stockByProductId = 内容来自samhan

stockRepository.findStockByProductId(productId);

内容来自zvvq

int stock = stockByProductId.orElseThrow().getStock();

int possibleStock = 库存 - 数量；

内容来自samhan

if (股票

内容来自samhan666

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

zvvq.cn

<h3>

copyright zvvq

第一个解决方案 - 用于更新 zvvq

</h3>

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

<blockquote> 内容来自samhan

FOR UPDATE 会导致 SELECT 语句检索到的行被锁定，就像要进行更新一样。这可以防止它们被其他交易修改或删除，直到当前交易结束。

</blockquote>

内容来自zvvq

<pre class="brush:php;toolbar:false">@Query(value = "从股票 s 中选择 WHERE s.product_id = ?1 FOR UPDATE", nativeQuery = true) copyright zvvq

可选<stockentity> findStockByProductIdWithLock(Long ProductId); 内容来自zvvq

</stockentity> zvvq好，好zvvq

public void validateAndDecreaseSolution1(long ProductId, int amount) { 内容来自zvvq

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

// ... 证实 内容来自samhan666

stockRepository.decreaseStock(productId, 数量); zvvq.cn

} 本文来自zvvq

</stockentity> zvvq

public void acquireLockAndDecreaseSolution2(long ProductId, int amount) {

查询nativeQuery =entityManager.createNativeQuery("选择pg_advisory_xact_lock(:lockId)"); 内容来自samhan666

nativeQuery.setParameter("lockId",productId);

nativeQuery.getSingleResult();

内容来自zvvq，别采集哟

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

// 检查库存并在必要时抛出异常 本文来自zvvq

stockRepository.decreaseStock(productId, 数量); zvvq好，好zvvq

}

内容来自samhan

</stockentity> 内容来自samhan666

@交易 zvvq.cn

@修改 内容来自samhan666

@Query(nativeQuery = true, value = "更新库存 SET stock = stock - :quantity WHERE Product_id = :productId AND stock &gt; 0")

zvvq好，好zvvq

int reduceStockWhereQuantityGreaterThanZero(@Param("productId") Long ProductId, @Param("quantity") int amount);

内容来自samhan666