跨oracle实例比较和同步数据

Question

我有三个oracle环境。如果我对DEV环境中的数据进行更改，我希望能够接受这些更改并将它们转移到我的其他环境中。

挑战在于，其他环境中的数据将不具有相同的主键。因此，比较必须查看表中的其他列。如果表引用了另一个表，那么它也必须包含该表中的列。

因此，例如，表A可能有4列，这些列都是其他表的ID，因此操作表A需要引用这些其他表。有人能推荐一种产品吗？

更新的要求：目前的系统不能更改。ID永远不会同步。同步必须仅在需要时进行（在我们每两个月更新一次之后）。同步不能通过DB链路完成（尽管DEV系统可以通过DB链路读取数据）。我绝对可以编写SQL来完成这一切，这正是那种容易出错（和拼写错误）的事情，如果有第三方应用程序可以为我解决这一问题，我宁愿把钱花在这上面。

根据要求更新：所有系统都是11g Enterprise。数据量很小，带宽不是问题。同步每隔几个月进行一次。基本上，我们有一些规则来告诉UI如何操作。这些规则存储在各种表中。我们不时地改变这些规则。这可能是数千条记录，但不是数万条。我们不希望从"实时"数据中进行那种同步。我需要做的是指定两个数据库实例和有问题的表，然后生成一个SQL脚本，有效地将更改从数据库a移动到数据库B。鉴于数据的性质，我一直在考虑简单地截断目标表，并将数据SQL加载到其他环境中。这并不像听起来那么简单，因为有一个"活动"表引用了这些记录，可能需要一些特定的更新（我也在积极研究这种可能性，只是没有听起来那么简单）。

下面的代码将提供我的意思的示例。您会注意到ID，而这些ID在不同环境中并不一致，这就是为什么这很棘手。

drop table mydata;
drop table MYTOWN;
drop table MYJOB;
drop table MYEMPLOYER;
drop table mystate;
create table MYJOB
(MYJOBID varchar2(1000)  NOT NULL PRIMARY KEY,
MYJOB varchar2(1000));
create table MYEMPLOYER
(MYEMPLOYERID  varchar2(1000)  NOT NULL PRIMARY KEY,
MYEMPLOYER  varchar2(1000));

create table MYSTATE
(MYSTATEID  varchar2(1000)  NOT NULL PRIMARY KEY,
MYSTATE varchar2(1000));
create table MYTOWN
(MYTOWNID varchar2(1000)  NOT NULL PRIMARY KEY,
MYTOWN varchar2(1000),
MYSTATEID varchar2(1000),
CONSTRAINT MYSTATE_FK FOREIGN KEY (MYSTATEID) REFERENCES MYSTATE (MYSTATEID) ENABLE);

create table MYDATA
(MYDATAID varchar2(1000)  NOT NULL PRIMARY KEY,
MYTOWNID varchar2(1000),
MYJOBID varchar2(1000),
MYEMPLOYERID varchar2(1000),
CONSTRAINT MYTOWN_FK FOREIGN KEY (MYTOWNID) REFERENCES MYTOWN (MYTOWNID) ENABLE,
CONSTRAINT MYJOB_FK FOREIGN KEY (MYJOBID) REFERENCES MYJOB (MYJOBID) ENABLE,
CONSTRAINT MYEMPLOYER_FK FOREIGN KEY (MYEMPLOYERID) REFERENCES MYEMPLOYER (MYEMPLOYERID) ENABLE
);

create sequence mydataid_seq;
insert into myemployer values ('937436',    'Bank Of America');
insert into myemployer values  ('43',   'Google');
insert into myemployer values  ('2',    'Toms Taxi');
insert into myjob  values ('8','Programmer');
insert into myjob  values ('10','Cook');
insert into myjob  values ('5','Driver');
insert into mystate  values ('7643','MA');
insert into mystate  values ('23','CA');
insert into mystate  values ('54','NM');
insert into mytown  values ('4743','BOSTON','7643');
insert into mytown  values ('321','SANDIEGO','23');
insert into mytown  values ('92037','SANTA FE','54');
insert into mydata  values ('78','4743','8','937436');
insert into mydata  values ('23455','321','10','43');
insert into mydata  values ('901','92037','5','2');

--to select a unique row
select mt.mytown, ms.mystate, mj.myjob, me.myemployer
from mydata md, mytown mt, mystate ms, myemployer me, myjob mj
where md.mytownid=mt.mytownid
and mt.mystateid=ms.mystateid
and md.myjobid=mj.myjobid
and md.myemployerid=me.myemployerid;
--to delete a row
delete from mydata md where md.mydataid =
(select md.mydataid 
from mydata md, mytown mt, mystate ms, myemployer me, myjob mj
where md.mytownid=mt.mytownid
and mt.mystateid=ms.mystateid
and md.myjobid=mj.myjobid
and md.myemployerid=me.myemployerid
and mt.mytown='SANDIEGO'
and ms.mystate='CA'
and mj.myjob='Cook'
and me.myemployer='Google');
--to insert a row
insert into mydata (mydataid,mytownid, myjobid, myemployerid)
(select mydataid_seq.nextval, mt.mytownid, mj.myjobid, me.myemployerid
from mytown mt, mystate ms, myemployer me, myjob mj
where mt.mytown='SANTA FE'
and mj.myjob='Programmer'
and me.myemployer='Toms Taxi'
and ms.mystate='NM'
);

Answer 1

看看Oracle GoldenGate。http://www.oracle.com/technetwork/middleware/goldengate/overview/index.html也许这会像一个重炮解决方案。

最佳解决方案取决于您的具体需求（数据量？多久？必须进行多少转换？服务器之间的带宽？负载？等等…）

Oracle有许多复制选项。

更新：

关于GoldenGate的建议仍然是实际的，但这不是一个廉价的解决方案。

但是，如果你有一些编码技能和兴趣，那么可能更容易：

1. 使用数据库链接并编写带有同步逻辑的PLSQL包。然后，您可以在需要时调用它，或者将其作为作业/任务定期运行。中央数据库必须查看其他数据库，并且必须能够建立直接连接
2. 或者，您可以编写一个外部应用程序并在其中放置同步逻辑。数据库可以在单独的DMZ中

当然，您可以使用Oracle Streams（11g企业版包括它），但我不能保证在您的情况下，如果没有额外的代码，它也能工作。因此，这种方法可能会成为第一种复杂的方法。

有时，使用严肃的复制解决方案需要花费更多的时间来设置和维护它们。在你的情况下，你只需要一个同步。

你可以找到一些现成的免费解决方案。但是，在大多数情况下，它们的质量很差。所以，我不推荐他们。

PS：您可以使用两种方法来解决数据的不一致性：

1. 最简单：为每个数据库的键列使用具有不同起始值的oracle序列（不要忘记设置最大值，以防止重叠）
2. 常规解决方案：重新设计数据模型以包含有关办公室/服务器的信息