【Java】已解决：org.springframework.dao.OptimisticLockingFailureException

屿小夏

发布于 2024-08-29 08:16:26

4820

已解决：org.springframework.dao.OptimisticLockingFailureException

一、分析问题背景

在开发Java企业级应用时，数据一致性和并发控制是两个重要的挑战。Spring框架提供了乐观锁（Optimistic Locking）机制，以帮助开发者管理并发更新。在使用Spring Data JPA进行数据库操作时，开发者有时会遇到org.springframework.dao.OptimisticLockingFailureException报错。这种情况通常发生在多个事务同时尝试更新同一条记录时。

以下是一个典型的场景：

@Entity
public class Product {
    @Id
    @GeneratedValue(strategy = GenerationType.IDENTITY)
    private Long id;

    private String name;
    private int quantity;

    @Version
    private int version;

    // getters and setters
}

在这个例子中，Product实体使用了@Version注解来启用乐观锁。

二、可能出错的原因

导致OptimisticLockingFailureException报错的原因主要有以下几点：

并发更新冲突：多个事务同时尝试更新同一条记录，导致版本号不一致。
版本号未正确管理：在更新操作中，版本号没有正确递增或比较，导致冲突无法被正确检测。
数据传输对象（DTO）未包含版本号：在传输数据时，DTO对象未包含版本号，导致更新时版本号校验失败。

三、错误代码示例

以下是一个可能导致该报错的代码示例，并解释其错误之处：

// Service层方法
@Transactional
public void updateProductQuantity(Long productId, int quantity) {
    Product product = productRepository.findById(productId).orElseThrow(() -> new EntityNotFoundException("Product not found"));
    product.setQuantity(quantity);
    productRepository.save(product);
}

错误分析：

并发更新冲突：当多个事务同时执行updateProductQuantity方法时，如果在事务提交时版本号不一致，就会抛出OptimisticLockingFailureException。
版本号未正确管理：在更新操作中，版本号未被正确传递和校验。

四、正确代码示例

为了正确解决该报错问题，我们需要确保版本号在更新操作中的正确传递和校验。以下是正确的代码示例：

// Service层方法
@Transactional
public void updateProductQuantity(Long productId, int quantity, int version) {
    Product product = productRepository.findById(productId).orElseThrow(() -> new EntityNotFoundException("Product not found"));
    if (product.getVersion() != version) {
        throw new OptimisticLockingFailureException("Product version mismatch");
    }
    product.setQuantity(quantity);
    productRepository.save(product);
}

// Controller层方法
@PostMapping("/updateProductQuantity")
public ResponseEntity<Void> updateProductQuantity(@RequestBody ProductDTO productDTO) {
    productService.updateProductQuantity(productDTO.getId(), productDTO.getQuantity(), productDTO.getVersion());
    return ResponseEntity.ok().build();
}

在这个例子中，我们确保在更新操作中传递并校验版本号，以防止并发更新冲突。