如何使Hibernate @Lock注释对Oracle DB有效？

Question

我偶然发现了在Oracle DB中锁定行的问题。锁定的目的是防止一个以上的事务从DB读取数据，因为该数据会影响新数据的生成并在事务方面发生更改。

为了进行锁定，我将@Lock注释放在SpringData find方法上，该方法检索参与事务的数据。

@Lock(LockModeType.PESSIMISTIC_WRITE)
User findUserById(@Param("id") String operatorId);

实施此代码后，我得到日志消息

org.hibernate.loader.Loader - HHH000444: Encountered request for locking however dialect reports that database prefers locking be done in a separate select (follow-on locking); results will be locked after initial query executes

此外，它没有作用和原因

org.springframework.dao.DataIntegrityViolationException: could not execute batch; SQL [insert into ...]

使用实体管理器重写锁时可以解决该问题

entityManager.lock(userByIdWithLockOnReadWrite, LockModeType.PESSIMISTIC_WRITE);

要么

entityManager.unwrap(Session.class).lock(userByIdWithLockOnReadWrite, LockMode.PESSIMISTIC_WRITE);

该问题未在MariaDB（MySQL）上出现。

也许有一些使用注释的特殊规则？

Answer 1

你之前这么说：

锁定的目的是防止一个以上的事务从DB读取数据，因为该数据会影响新数据的生成并在事务方面发生更改。

Oracle使用MVCC（多版本并发控制），因此读者不会阻止Writers，而作家也不会阻止Reader。即使您使用Oracle获得了行级锁，并且在不提交的情况下修改了该行，其他事务仍可以读取上次提交的值。

与此日志消息相关：

org.hibernate.loader.Loader - HHH000444: Encountered request for locking however dialect reports that database prefers locking be done in a separate select (follow-on locking); results will be locked after initial query executes

在后续锁定机制是由于甲骨文不能够做的Oracle 11g分页时，使用应用锁DISTINCT或UNION ALL。

如果您使用的是Oracle 12i，则可以将Hibernate方言更新为，Oracle12cDialect并且分页和锁定将正常工作，因为Oracle
12使用SQL标准分页并且不再需要派生表查询。

这在MariaDB或任何其他数据库中不会发生。这只是Oracle 12之前的限制。

如果您使用的是Hibernate
5.2.1，我们添加了一个新的提示HINT_FOLLOW_ON_LOCKING来禁用此机制。

因此，您的Spring Data查询变为：

@QueryHints(value = { @QueryHint(name = "hibernate.query.followOnLocking", value = "false")}, forCounting = false)
@Lock(LockModeType.PESSIMISTIC_WRITE)
User findUserById(@Param("id") String operatorId);

您也可以手动应用它：

User user = entityManager.createQuery(
    "select u from User u where id = :id", User.class)
.setParameter("id", id);
.unwrap( Query.class )
.setLockOptions(
    new LockOptions( LockMode.PESSIMISTIC_WRITE )
        .setFollowOnLocking( false ) )
.getSingleResult();