我在工作区 A 和工作区 B 中有一个数据库。 在线有这个数据库的副本,它总是从两个工作区更新。 此外,每当另一个工作区进行任何更改时,两个工作区都可能需要更新其数据库。
一切正常,但我的问题是:例如有 2 个表 Stock
和 Orders
,在 Orders
中有一列这是 stock_id
。
如果工作区 A 创建一个新的“Stock X”并自动增加“stock_id”=23,而工作区 B 创建一个新的“Stock Y”并自动增加“stock_id”= 23,则工作区 B 将添加工作区 A 的“Stock” X”和工作区 B 将添加工作区 B 的“Stock Y”,但每个在每个数据库中都有不同的 ID。
当工作区 A 在 stock_id=23(即“Stock X”)上下订单时出现问题,当此查询发送到中央数据库,然后发送到工作区 B 时,它将插入订单,但 stock_id = 23 将引用“股票Y”。
非常感谢您对此的帮助,谢谢 :)
最佳答案
编辑:
您的原始设计使用 AUTO INCREMENT
列作为主键。这样做的问题是,正如您所看到的,当您将数据同时输入到最终将被合并的单独数据库时,您最终会创建重复键。
一种替代方法是在每个不同的数据库中使用一个序列。不幸的是,序列在 mysql 中不是本地可用的(许多其他数据库,如 Oracle、db2 确实有它们——它们允许这种类型的分布式数据库插入而不会发生冲突)。 AUTO INCREMENT
列不允许您想要的那种复制。
因此,您有两个选择。
1) 添加设置 location_id 的主键的额外部分(根据第一个答案)。
2) 或者使用您自己的序列手动为您的插入生成您的 ID,而不是使用 AUTO INCREMENT
列。
最好将序列实现为存储过程/函数,当它获取序列中的下一个值时,它会自行提交——这可能会导致值未被使用。这很好——如果您要等到整个插入提交后才提交序列号,这比争用要好。
最主要的是,当您进行第一次插入时,您使用存储过程中的序列#。当您有效地将数据复制到第二个数据库时,您可以在原始数据库的行中使用生成的序列#。并且序列将在具有不同起点的每个单独的数据库中维护,以防止冲突。
例如,在每个数据库中,您需要两部分:
1) 一个表,其中包含每个命名序列的下一个可用序列号。 (每个获得从序列中提取的主键的表都会获得一个条目)。 2) 访问和更新带有下一个序列号的表的函数。
一个示例实现是:
序列表:
CREATE TABLE sequences (
name varchar(30) NOT NULL,
value int(10) unsigned,
PRIMARY KEY (name)
) ENGINE=InnoDB
序列函数:
delimiter //
create function get_next_value(p_name varchar(30)) returns int
deterministic
sql security invoker
begin
declare current_val integer;
UPDATE sequences
SET value = (@current_val:=value) + 1
WHERE name = p_name;
return @current_val;
end //
delimiter ;
主要问题是存储的函数需要是单个语句,这样它才能完成并立即提交(否则,您将锁定它,这将导致您的交易作为订单相互堆叠进来。如果您的吞吐量不是很高,这不是什么大问题。
这个函数不是我写的——我是从这里随意复制的:http://www.bigdbahead.com/?p=185我会推荐你去哪里了解更多细节。 (如果那个用户在这里找到我,我会很乐意让他写一个答案并在这里给他适当的信用)。
现在,对于每个数据库,您使用不同的数字初始化值以避免冲突。因此,对于位置 A 中的 orders
表,您可以使用以下方法对其进行初始化:
insert into sequences ('orders', 1);
在位置 B 中,您将使用以下方法对其进行初始化:
insert into sequences ('orders', 1000000);
然后在两个数据库中,在插入到 orders
时,您需要:
insert into orders (order_id, . . .)
select mysql.get_next_value('user_id'), . . . <hardcoded-values>
--
我还没有对这个解决方案进行路试——把它作为我在回答中关于序列的建议的概述。你应该跟进上面的博客条目链接,它提供了更多细节,特别是关于它如何在事务控制下工作,请参阅评论(我从评论中获取了函数的形式,而不是原始函数) ,当然,还要在负载下对其进行测试。
关于php - 使用外键合并两个数据库时的 SQL 问题,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/10154953/