SELECT ... FOR UPDATE来自多个线程中的一个表

Question

我需要一些帮助SELECT FOR UPDATE(相应的LOCK IN SHARE MODE).

我有一个大约有40万条记录的表,我需要在每一行上运行两个不同的处理函数.

表结构恰如其分:

data (
    `id`,
    `mtime`,  -- When was data1 set last
    `data1`,
    `data2` DEFAULT NULL,
    `priority1`,
    `priority2`,
    PRIMARY KEY `id`,
    INDEX (`mtime`),
    FOREIGN KEY ON `data2`
)

功能有点不同:

• 第一个函数 - 必须在所有记录上循环运行(非常快),应该选择基于的记录priority1; 集data1和mtime
• 第二个功能 - 每个记录只需运行一次(非常慢),应根据记录选择记录priority2; 集data1和mtime

它们不应该同时修改同一行,但是select可能会在它们中返回一行(priority1并且priority2具有不同的值)并且如果是这样的话,事务可以等待(并且我希望这会是它阻止的唯一情况.

我正在根据以下查询选择数据:

-- For the first function - not processed first, then the oldest,
-- the same age goes based on priority
SELECT id FROM data ORDER BY mtime IS NULL DESC, mtime, priority1 LIMIT 250 FOR UPDATE;

-- For the second function - only processed not processed order by priority
SELECT if FROM data ORDER BY priority2 WHERE data2 IS NULL LIMIT 50 FOR UPDATE;

但我所经历的是,每次只有一个查询返回.

所以我的问题是:

• 是否可以在单独的一堆行(在同一个表中)中的两个单独的事务中获取两个单独的锁？
• 我在第一次和第二次查询之间有多次冲突(我有麻烦调试,任何关于如何调试的提示SELECT ... FROM (SELECT ...) WHERE ... IN (SELECT)都会受到赞赏)？
• 能ORDER BY ... LIMIT ...造成任何问题？
• 索引和密钥可以导致任何问题吗？

Answer 1

在进一步深入之前需要检查的关键事项：

• 确保表引擎是InnoDB，否则“更新”不会锁定该行，因为不会有事务。
• 确保您正确使用“更新”功能。如果您选择更新某些内容，它将被锁定到该事务。虽然其他事务可能能够读取该行，但在原始锁定事务释放锁之前，任何其他事务都无法选择该行进行更新、更新或删除。
• 为了保持干净，请尝试使用“START TRANSACTION”显式启动事务，运行您的选择“for update”，对返回的记录执行您要执行的任何操作，然后通过显式执行“COMMIT”来完成结束交易。

据我所知，顺序和限制不会对您遇到的问题产生任何影响，选择返回的任何内容都将是被锁定的行。

回答您的问题：

1. 是否可以在两个单独的事务中对不同的行（在同一个表中）上获取两个单独的锁？
   是的，但不在同一行。锁一次只能存在于一个事务的行级别。
2. 我在第一个和第二个查询之间是否有那么多冲突（我在调试时遇到麻烦，任何有关如何调试 SELECT ... FROM (SELECT ...) WHERE ... IN (SELECT) 的提示将不胜感激）？
   可能会在很短的时间内计算行锁，这将延迟第二个查询，但是除非您一次运行数百个这样的选择更新，否则它不会导致任何重大或明显的延迟。
3. ORDER BY ... LIMIT ... 会导致任何问题吗？ 以我的经验来看并非如此。它们应该像在普通 select 语句中一样工作。
4. 索引和键会导致任何问题吗？
   索引应一如既往地存在，以确保足够的性能，但它们不应导致获取锁时出现任何问题。