如何在使用spring提交更新后锁定select并释放锁？

Question

我从过去几个月开始使用spring，我有一个关于交易的问题。我在我的spring批处理作业中有一个java方法，它首先执行一个select操作以获取前100行，状态为“未完成”，并对所选行进行更新以将状态更改为“进行中”。由于我正在处理大约1000万条记录，我想运行批处理作业的多个实例，每个实例都有多个线程。对于单个实例，为了确保两个线程不会获取同一组记录，我将方法设置为同步。但是，如果我运行批处理作业的多个实例（多个JVM），即使我使用“乐观”或“悲观锁定”或“选择更新”，因为我们无法在选择期间锁定记录，这两个实例也很可能会获取相同的记录集。下面是所示的示例。事务1获取了100条记录，同时事务2也获取了100个记录，但如果我启用了锁定，事务2将等待事务1更新并提交。但事务2再次执行相同的更新。

Spring有没有办法让事务2的选择操作等待事务1的选择完成？

Transaction1        Transaction2
fetch 100 records   
                    fetch 100 records
update 100 records



 commit         
                    update 100 records
                    commit



@Transactional
public synchronized List<Student> processStudentRecords(){
List<Student> students = getNotCompletedRecords();
if(null != students && students.size() > 0){
    updateStatusToInProgress(students);
}
return student;
}

注意:我不能先执行更新，然后选择。如果有任何替代方法建议，我将不胜感激。

Answer 1

事务同步应该留给数据库服务器，而不是在应用程序级别进行管理。从数据库服务器的角度来看，无论您有多少JVM（线程），它们都是请求读/写操作的并发数据库客户端。你不应该为这种担心而烦恼。

不过，您应该做的是在解决方案的设计中尽量减少争用，例如，通过使用（远程）分区技术。

如果我运行批处理作业的多个实例（多个JVM），即使我使用“乐观”或“悲观锁定”或“选择更新”，也很有可能两个实例都会获取相同的记录集，因为我们无法在选择期间锁定记录

对数据进行分区将从设计上消除所有这些问题。如果您给每个实例一组数据来处理，那么一个工人就不可能选择另一个工人的相同记录。迈克尔在这个回答中举了一个详细的例子:https://stackoverflow.com/a/54889092/5019386.

(逻辑)分区并不能解决争用问题，因为所有的工作线程都将从同一个表中读取数据或向同一个表中写入数据，但这就是您试图解决的问题的本质。我要说的是，在你的设计中，你不需要开始锁定/解锁表，把这个留给数据库。一些数据库服务器，比如Oracle，可以将同一个表的数据写入磁盘上的不同分区，以优化并发访问(如果您使用分区，这可能会有所帮助)，但这仍然是Oracle的事情，而不是Spring(或任何其他框架)的事情。

不是每个人都买得起Oracle，所以我会在概念层面寻找解决方案。我已经成功地使用了以下解决方案(“伪”物理分区)来解决与您类似的问题:

• 步骤1（串行）：将未处理的数据复制/分区到临时表（串行）
• 步骤2（并行）：在这些表上运行多个工作程序，而不是在具有数百万行的源表上运行
• 步骤3（串行）：将处理后的数据复制/更新回原始表

步骤2解决了争用问题。通常，与步骤2相比,(步骤1和步骤3)的成本可以忽略不计(如果步骤2是连续进行的，则成本更可忽略不计)。如果处理是瓶颈，这种方法很有效。

希望这有帮助。