我需要一点SELECT FOR UPDATE
(resp. 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)的提示将不胜感激?
>可以订购……限制……导致任何问题?
>索引和密钥可以导致任何问题吗?
>确保表引擎是InnoDB,否则“for update”不会锁定行,因为没有事务.
>确保正确使用“更新”功能.如果您选择要更新的内容,则会锁定该事务.虽然其他事务可能能够读取该行,但是在原始锁定事务释放锁之前,不能选择任何其他事务进行更新,更新或删除.
>为了保持清洁,尝试使用“START TRANSACTION”显式启动事务,运行select“for update”,对要返回的记录执行任何操作,并通过显式执行“COMMIT”来完成关闭交易.
就我所知,订单和限制对您遇到的问题没有任何影响,Select将返回的是将被锁定的行.
回答你的问题:
>是否可以在单独的一堆行(在同一个表中)中的两个单独的事务中获取两个单独的锁?
是的,但不是在同一行.锁只能一次存在于一个事务中的行级别.
>我在第一次和第二次查询之间有多次碰撞(我有麻烦调试,任何关于如何调试SELECT … FROM(SELECT …)WHERE … IN(SELECT)的提示将不胜感激?
计算行锁定的时间可能很短,这将延迟第二个查询,但是除非您一次运行数百个这样的选择更新,否则不会导致任何重大或明显的延迟.
>可以订购……限制……导致任何问题?
不是我的经验.它们应该像在正常的select语句中一样工作.
>索引和密钥可以导致任何问题吗?
索引应始终存在以确保足够的性能,但它们不应导致获得锁定的任何问题.