Spring JPA。更新数据库值的正确方法

Question

我正在学习 Spring JPA 和 Hibernate。所以我遇到了问题。

我有这个方法

@Transactional(isolation = Isolation.REPEATABLE_READ)
public void sendMoney(Long from, Long to, Double amount) {
    WalletEntity fromWallet = walletServiceImpl.getWallet(from);
    WalletEntity toWallet = walletServiceImpl.getWallet(to);
    fromWallet.setAmount(fromWallet.getAmount() - amount);
    toWallet.setAmount(toWallet.getAmount() + amount);

    TransactionEntity transaction = new TransactionEntity();
    transaction.setAmount(amount);
    transaction.setToWallet(toWallet);
    transaction.setFromWallet(fromWallet);

    transactionRepository.saveAndFlush(transaction);
}

我想测试它并创建了这个：

@GetMapping("/send")
public void sendMoney() {
    ExecutorService executorService = Executors.newFixedThreadPool(20);
    for (int i = 0; i < 100; i++) {
        executorService.execute(() -> {
            accountServiceImpl.sendMoney(1L, 2L, 10D);
        });
    }
}

所以当我读取 wallet 时，我得到了旧值，但我得到了 Isolation.REPEATABLE_READ。数据库中的值当然是错误的。你能解释一下哪里出了问题吗？谢谢！

Answer 1

隔离级别 REPTEABLE_READ 按预期工作。

你可以在这里得到很好的解释：

Spring @Transactional - isolation, propagation

但为了澄清，事情是这样的：

                      Tx1      Tx2
                       |        |
Tx1 Read Wallet 1     100       |
Tx2 Read Wallet 1      |       100
Tx1 Discounts 10     100-10     |
Tx2 Discounts 10       |      100-10
Tx1 Commits            |        |
Tx2 Commits            |        |
Tx1 Read Wallet 1      90       |
Tx2 Read Wallet 2      |        90

因此，为了控制这种行为，您有两个选择：

使用阻塞操作的可序列化事务级别，以便逐个处理（这会降低性能）
实现乐观锁（第二笔交易同时修改同一个账户会抛出异常）

您可以在此处开始回顾乐观锁定：

Spring JPA。更新数据库值的正确方法

Spring JPA. The right way to update database values

java

database

spring

isolation-level

spring-data-jpa