7

我需要一点帮助SELECT FOR UPDATE(resp. LOCK IN SHARE MODE)。

我有一个包含大约 400 000 条记录的表，我需要在每一行上运行两个不同的处理函数。

表结构适当地是这样的：

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 ...会导致任何问题吗？
  • 索引和键会导致任何问题吗？
4

2 回答 2

4

在进一步研究之前要检查的关键事项：

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

据我所知，订单和限制对您遇到的问题没有影响，选择将返回的任何内容都将是被锁定的行。

要回答您的问题：

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

接受答案中的所有点似乎都很好，除了低于 2 点：“选择将返回的任何内容都将是被锁定的行。” &“索引和键会导致任何问题吗？但它们不应该导致任何获取锁的问题。 ”

相反，在决定选择和返回哪些行期间由 DB 内部读取的所有行都将被锁定。例如下面的查询将锁定表的所有行，但可能只选择并返回几行： select * from table where non_primary_non_indexed_column = ? 更新由于没有索引，数据库将不得不读取整个表来搜索你想要的行，从而锁定整个表。

如果只想锁定一行，则需要在 where 子句中指定其主键或索引列。因此，在仅锁定适当行的情况下，索引变得非常重要。

这是一个很好的参考 - https://dev.mysql.com/doc/refman/5.7/en/innodb-locking-reads.html

于 2017-05-09T08:18:53.923 回答