4

我需要完成以下工作：

我需要在同一个表中插入两行，要么都插入，要么都不插入（原子插入两行）。

我使用 InnoDB 表上的事务来执行此操作，如下所示：

$db->beginTransaction();

# Using PDO prepared statments, execute the following queries:
INSERT INTO t1 set uid=42, foo=1
INSERT INTO t1 set uid=42, foo=2

$db->commit();

但是，如果表中没有列的值为“42”的行，我也只希望插入这些行。

所以我这样做：

$stmt = $db->prepare("SELECT id FROM t1 WHERE uid != ?");
$stmt->execute(array(42));
if($stmt->fetchColumn() < 0){
    # There is no row with uid=42, so
    # perform insertions here as per above.
    INSERT INTO t1 set uid=42, foo=1
    INSERT INTO t1 set uid=42, foo=2
}

但是这里存在竞争条件，因为可以在检查该行之后和插入新行之前立即插入 uid=42 的行。

我应该如何解决这个问题？

我可以锁定表，然后在表锁内执行 InnoDB 事务吗？

我可以在事务内部进行选择以检查 uid=42 的现有行吗？那是没有比赛条件的吗？

4

1 回答 1

4

您可以使用信号量类型的架构。例如，创建一个名为“信号量”的表或任何您想调用的表。假设表中只有一个字段，并且该字段是唯一的，称为“sem”。现在，运行“INSERT INTO semaphore SET sem = 42”；

好的，那个 INSERT 语句是原子的，并且意味着在那之后当其他人试图插入 42 时，他们会得到一个错误，说明重复键。

然后，在原始表中进行插入。在事务中完成所有这些。在 SQL 中，它看起来像这样：

BEGIN TRANSACTION;
INSERT INTO semaphore SET sem = 42;
INSERT INTO t1 set uid=42, foo=1;
INSERT INTO t1 set uid=42, foo=2;
COMMIT;
DELETE FROM semaphore WHERE sem = 42;

之后进行删除的原因有两个：

  1. 我想您不需要删除它，但是让我们去寻找干净的数据吧；）
  2. 在 COMMIT 之后删除的原因是您希望在事务完成之前保持阻塞锁定。

旁注：信号量通常在自动增量字段不起作用时使用。然后，您使用一个只有一条记录的信号量表来序列化插入并阻止主键。

希望能帮助到你 ：）

于 2012-08-10T16:42:32.193 回答