同时从两个不同的线程插入/更新实体

Question

我有以下方法将播放器添加到数据库或更新它，如果它已经存在：

@Transactional(isolation = Isolation.SERIALIZABLE)
public Player addOrUpdatePlayer(String playerId, String playerName) {
    Optional<Player> playerOptional = playerRepository.findById(playerId);
    if (playerOptional.isPresent()) {
        Player player = playerOptional.get();
        player.setName(playerName);
        return playerRepository.save(player);
    } else {
        Player newPlayer = Player.builder()
            .id(playerId)
            .name(playerName)
            .build();
        return playerRepository.save(newPlayer);
    }
}

这个方法有时由两个不同的线程调用，因此几乎同时执行两次。有时我会得到以下异常:

org . H2 . JDBC . jdbcsqlintegrityconstraintviolationexception:唯一索引或主键冲突:" PUBLIC。PUBLIC上的PRIMARY_KEY_B42。玩家(ID)值3”；

这对我来说是有意义的，因为如果播放器在数据库中，这两种方法都会在一开始检查，而不是在这两种情况下。然后两者都尝试插入，速度较慢的一个会运行到约束中。

我想在执行此方法期间锁定玩家表，因此如果多次调用它，它们必须相互等待。

我的播放器存储库如下所示：

public interface PlayerRepository extends JpaRepository<Player, String> {

    @Lock(LockModeType.PESSIMISTIC_WRITE)
    Optional<Player> findById(String var1);

    @Lock(LockModeType.PESSIMISTIC_WRITE)
    <S extends Player> S save(S var1);
}

我还尝试提高事务的隔离级别：

@Transactional(isolation = Isolation.SERIALIZABLE)

然而，我仍然得到了这个异常，因此显然插入仍在并发运行。我做错了什么？或者有没有其他方法来实现我在这里尝试的目标？

经过更多的研究，我想我明白了为什么@Lock和@Transactional（隔离=Isolation.SERIALIZABLE）都没有做任何事情。它们基本上是通过在事务期间锁定数据库表中的记录来工作的，但是由于在我的情况下没有要锁定的记录，所以它没有做任何事情。

因此，我想我必须为该事务锁定整个表。Spring JPA有可能做到吗？既然这看起来不太明智，有没有其他方法来解决这个问题呢？

Answer 1

为此，您可以使用< code>@SQLInsert来更改用于插入操作的SQL。根据您的数据库，可能会切换到一些数据库本地冲突/合并处理。请参见Hibernate事务和使用attachDirty的并发性(saveOrUpdate)