在spring jpa中锁定10行进行处理然后删除

Question

我有一个 mysql 表，它被两个进程附加，两个单独的进程正在从表中读取以处理记录。写入后的记录不会更新。

每个读取进程每小时唤醒一次以检查是否存在任何记录并处理记录。处理完成后，需要删除记录，以免再次处理记录。

我正在使用带有 mysql 的 spring JPA。现在我正在考虑使用 PESSIMISTIC_WRITE 锁一次查询和锁定 10 条记录，然后删除它们。我可以在使用 PESSIMISTIC_WRITE 锁的同时使用 Pageable 来查询记录吗？而且，Pageable 会只锁定一页记录吗？

我想对这种方法的想法以及其他人是否尝试过。如有任何反馈，我将不胜感激。

问候， 灰

Answer 1

我最终使用 LIMIT 每次获取 10 行。在我的 SQL 中，我还添加了“FOR UPDATE”来锁定它们。然后我处理了这些行并删除了同一个事务中的 10 行。