PHP/MySQL 同步 innoDB 查询作为异步工作

Question

我需要使用不同的 PHP 脚本同时更新和读取一张表中的数据。 我创建 $sess 作为脚本会话标识符（同时工作大约 20 个脚本），并在表行中设置了 100 行的会话标识符。之后，它将通过会话标识符选择为此脚本保留的行。在 while 循环中，脚本将对数据进行一些处理并更新保留的行。

但是脚本不能同时工作，第一个脚本工作正常，但其他脚本在第一个脚本运行时不做第一个查询。我在我的数据库管理应用中看到它。

$sess = intval(str_replace(".", "", microtime(TRUE)));
sql_query("UPDATE locations SET sess='$sess' WHERE sess='0' LIMIT 100");
$r = sql_query("SELECT * FROM locations WHERE sess='$sess'");
while ($q = sql_row($r))
{

创建表语法

CREATE TABLE `locations` (
  `id` int(11) unsigned NOT NULL AUTO_INCREMENT,
  `country_id` int(11) unsigned DEFAULT NULL,
  `area_id` int(11) unsigned DEFAULT NULL,
  `timeZone` int(2) DEFAULT NULL,
  `lat` double DEFAULT NULL,
  `lon` double DEFAULT NULL,
  `locationKey` int(11) unsigned DEFAULT NULL,
  `cityId` int(11) unsigned DEFAULT NULL,
  `sess` bigint(100) unsigned DEFAULT '0',
  PRIMARY KEY (`id`),
  KEY `lat` (`lat`),
  KEY `lon` (`lon`),
  KEY `country_id` (`country_id`),
  KEY `cityId` (`cityId`),
  KEY `area_id` (`area_id`),
  KEY `sess` (`sess`)
) ENGINE=InnoDB AUTO_INCREMENT=3369269 DEFAULT CHARSET=utf8;

Answer 1

您是否在事务中 (BEGIN...COMMIT)？如果是这样，您已经锁定了这 100 行。 autocommit=0 同上。

相反，请确保 UPDATE（用于将“队列”中的 100 个项目分配给您的进程）本身处于事务中。

然后，假设其他线程不能在同一微秒内调用microtime（一个可疑的假设），这 100 个项目将安全地分配给您。然后您可以启动另一个事务（如果需要）并处理它们。

但是，这 100 行 SELECT 将不必要地对这些行设置读锁。

所以...

START TRANSACTION;
UPDATE ... LIMIT 100;
SELECT ...
COMMIT;

foreach ...
    START TRANSACTION;
    work on one item
    COMMIT;
end-for

不清楚第二个 START-COMMIT 应该在 for 循环内还是在外。内部会慢一些，但可能是“正确的”，这取决于您正在做什么“工作”以及可能需要多长时间。 （你不想ROLLBACK 99 个成功的“作品”，因为第 100 个花了太长时间。）

你以后在做DELETE ... WHERE sess = $sess吗？如果您要像这样批量删除，请在 for 循环之后的单独事务中执行。

目标：将排队事务与应用事务分离。

请注意，隔离将使错误/死锁/等的编码变得更容易。 （你正在检查，对吗？）