使用 INSERT INTO 选择更新

Question

我正在制作某种游戏彩票，我得到了从 MyISAM 切换到 InnoDB 并开始使用 FOR UPDATE 的建议，因此彩票（从 1 到 16 不等）无法卖出更多不止一次。

现在我想知道，FOR UPDATE 是如何工作的。

我在网上看到是这样的：

SELECT * FROM [table] WHERE [column] = [value] FOR UPDATE
UPDATE [table] SET [column] = [new_value]

我的问题是关于以下内容，它是否也适用于INSERT？

我的数据库设计：

CREATE TABLE IF NOT EXISTS `Lottery` (
  `id` varchar(50) NOT NULL,
  `preferedLotteryId` varchar(50) NOT NULL,
  `winningTicketId` int(11) NOT NULL DEFAULT '-1',
  `createdOn` datetime NOT NULL DEFAULT '1001-00-00 00:00:00',
  `startedOn` datetime NOT NULL DEFAULT '1001-00-00 00:00:00',
  `finishedOn` datetime NOT NULL DEFAULT '1001-00-00 00:00:00',
  `active` tinyint(1) NOT NULL,
  `deliveredOn` datetime NOT NULL DEFAULT '1001-00-00 00:00:00',
  `preferedDeliverMethod` int(2) NOT NULL DEFAULT '-1',
  `deliveredMethod` int(2) NOT NULL DEFAULT '-1',
  `deliveredByAccountId` varchar(50) DEFAULT NULL,
  PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=latin1;

CREATE TABLE IF NOT EXISTS `LotteryBid` (
  `bidId` varchar(50) NOT NULL,
  `accountId` varchar(50) NOT NULL,
  `auctionId` varchar(50) NOT NULL,
  `ticketId` int(50) NOT NULL,
  `datetime` datetime NOT NULL DEFAULT '1001-00-00 00:00:00',
  PRIMARY KEY (`bidId`)
) ENGINE=InnoDB DEFAULT CHARSET=latin1;

这意味着此设计需要FOR UPDATE，类似于：

SELECT * FROM Lottery WHERE id = [id] FOR UPDATE
INSERT INTO LotteryBids SET [LotteryBids.values & Lottery.id]

或

SELECT * FROM Lottery WHERE id = [id] FOR UPDATE
INSERT INTO LotteryBids, Lottery SET [LotteryBids.values] WHERE Lottery.id = [id]

但是，我不知道FOR UPDATE 这种方式是否有可能。

我对这种海量数据交互还很陌生，我不知道从哪里开始。

我希望你们中的一些人可以帮助我。

亲切的问候， 拉西1

---

我认为以下想法会转化为可能的解决方案：

想法一：

一个用户正在购买一张彩票 ID 为 5 的彩票。目前这个 彩票已售出 3 张彩票，所以我想为此锁定行数 抽签，直到我提交/完成此插入。

想法2：

一个用户正在购买一张彩票 ID 为 5 的彩票。目前这个 拍卖没有票号为 5 的票，所以我想保留一个条目 对于具有相似拍卖 ID 和票证 ID 的此次拍卖。和 在此查询完成之前阻止进一步添加。

---

使用过的查询

选择彩票（包括附加信息）：

SELECT au.*, asp.* FROM Lottery au, LotteryPrefered asp
WHERE au.preferedAuctionId = asp.id AND au.id = '" . $_auctionId . "'

OR（不包括附加信息）

SELECT au.* FROM Lottery au
WHERE au.id = '" . $_auctionId . "'

买票：

INSERT INTO LotteryBids (bidId, accountId, auctionId, ticketId, datetime)
VALUES ('" . $guid . "', '" . $_accountId . "', '" . $_auctionId . "',
  '" . $_ticketId . "', NOW())

Answer 1

您可以尝试将一种锁/MUTEX 与备用表一起使用： 见http://blog.udby.com/archives/14（实现简单的数据库信号量）

在开始处理给定类型之前，您在锁定表中使用 INSERT + DELETE 锁定“类型”。

Answer 2

SELECT ... FOR UPDATE with UPDATE

使用 InnoDB 事务（关闭自动提交），SELECT ... FOR UPDATE 允许一个会话临时锁定特定记录（或记录），以便其他会话无法更新它。然后，在同一事务中，会话实际上可以对同一记录执行UPDATE 并提交或回滚该事务。这将允许您锁定记录，以便在您执行一些其他业务逻辑时没有其他会话可以更新它。

这是通过锁定来完成的。 InnoDB 利用索引来锁定记录，因此锁定现有记录似乎很容易——只需锁定该记录的索引即可。

SELECT ... FOR UPDATE with INSERT

但是，要将SELECT ... FOR UPDATE 与INSERT 一起使用，如何为尚不存在的记录锁定索引？如果您使用REPEATABLE READ 的默认隔离级别，InnoDB 还将使用 gap 锁。只要您知道要锁定的 id（甚至是 id 范围），InnoDB 就可以锁定间隙，因此在我们完成之前不能在该间隙中插入其他记录。

如果您的 id 列是自动增量列，那么带有 INSERT INTO 的 SELECT ... FOR UPDATE 会出现问题，因为在插入之前您不会知道新的 id 是什么。但是，由于您知道要插入的id，因此SELECT ... FOR UPDATE 和INSERT 将起作用。

示例

查看ticketid5是否有拍卖12：

SELECT * FROM LotteryBids
WHERE auctionid = 12 AND ticketid = 5
FOR UPDATE

如果没有返回行，则它不存在。插入它：

INSERT INTO LotteryBids (bidId, accountId, auctionId, ticketId, datetime)
VALUES ('abcd-efgh-ijkl-mnop', 100, 12, 5, NOW())

保持简单

以这种方式处理并发问题可能很难理解，而且我经常看到人们将事情过于复杂化。我建议提出一个单独的问题，详细说明您要完成的工作，提供您提出的解决方案，并征求建议。