0

我有 6 个表来从 4 个数据库中的每一个中提取数据。我必须在单个数据库的 6 个表中复制所有这些数据。目标表只有一个额外的列“instance_id”,它表明我们正在从哪个数据库获取数据。现在我为每个数据库有一个提取过程,在目标数据库中有 4 个复制过程。我想在使用 OGG 复制在目标表中输入行后自动更新“instance_id”列。我知道有 SQLEXEC 语句可以在 OGG 中运行 SQL 查询。我不知道在哪里以及如何使用它来解决我的问题。

4

1 回答 1

1

If you have 4 sources, you have 4 sets of trail files and 4 replicats. In the replicats include your instance_id in the column MAP. Also - if getting data from the 4 sources is going to cause primary key collisions, you will have to include instance_id in your PK definition. Would look something like:
MAP schema.table, TARGET schema.table,
COLMAP(USEDEFAULTS, instance_id = 1),
KEYCOLS(pkcol, instance_id);

于 2018-09-18T22:48:16.040 回答