如何使用 Spring boot JPA/hibernate 将 pessimistic_write 锁与 Spanner 一起使用

Question

我正在使用带有 Spring boot 和 JPA 的 Spanner 数据库。 我有一个要求，每当从员工表中读取员工信息时，在事务完成之前没有人可以读取/更新/删除同一行信息。

我知道出于这种目的，JPA 中使用了“PESSIMISTIC_WRITE”锁。 （参考了这个链接 具有多个实例的应用程序上的 JPA PESSIMISTIC_WRITE）

我尝试使用通过使用下面的代码，但它没有持有锁。 当我尝试从其他实例执行相同的查询时，它会给出结果。理想情况下，它应该等到第一个事务完成但仍然给出结果。

您能给我建议任何解决方案吗？

我正在使用下面的代码来实现相同的目的。

@Repository
public interface EmployeeRepository extends JpaRepository<EmployeeEntity, Integer> {

    @lock(LockModeType.PESSIMISTIC_WRITE)
    @query("SELECT c FROM Employee c WHERE c.empId = :empId)
    public EmployeeEnity getEmployee(@param("empId") Integer empId);
}

@Service
public class EmpService implement IEmpService {

@Autowired
EmployeeRepository  empRepository;

@Transactional
@Override
    public EmployeeEntity getEmployee(Integer empId) {

        return empRepository.getClientId(clientId);
        
    }
}

Answer 1

你是说你需要一把锁

在事务完成之前没有人可以读取/更新/删除同一行信息

这对我来说听起来像是排他锁。 Cloud Spanner 中不提供此功能。

问题是在这种情况下这是否是您真正需要的。 Cloud Spanner 中的读/写事务具有外部一致性。总结一下，对于您的具体问题，可以归结为以下内容：

1. 事务 A 读取行 R1。
2. 交易 A 改变了 R1 的值。
3. 事务 A 提交。

Cloud Spanner 保证在事务 A 提交时，R1 的值仍与其在步骤 1 中读取的值相同。如果您还有一个事务 B 几乎同时执行以下操作：

1. 事务 B 读取行 R1。
2. 交易 B 改变了 R1 的值。
3. 事务 B 提交。

（因此两个事务都读取并修改同一行）

那么可以保证这样做的效果将是事务 A 先执行，然后事务 B。或者先执行事务 B，然后事务 A。（即；在所有情况下，两个事务都保证它们在步骤 1 中看到的值在提交时仍然未被其他任何人修改。