主页 / user-46197

mtn.biker's questions

Martin Hope
mtn.biker
Asked: 2014-08-27 08:10:20 +0800 CST
  • 0

我正在使用 SymmetricDS 在两个 MySQL 数据库之间同步记录，但需要保持主键 (fieldname = "id") 字段的唯一性。Symmetric 似乎不想遵守“查找”transform_type - 它似乎总是将源表 ID“复制”到目标表 ID 字段（以及目标表中的“masterId”字段）。

两个表都有一个 id 字段是 AUTO-INCREMENT（但两个表中的记录数不同）。

我希望将“内部”帐户表记录复制到“外部”帐户表，并将“内部”ID 复制到“外部”masterId 字段。然后，我希望“外部”帐户 ID 字段由“外部”ID AUTO-INCREMENT 值自动填充。我已将此 sym_transform_table.column_policy 定义为“IMPLIED”，这意味着复制所有字段，除非定义了特定的 sym_transform_column 转换。我已经为“id”字段定义了一个转换（I/U/D 的不同转换）。

但结果总是“内部”id 被复制到“外部”id 字段以及“外部”masterId 字段。

如何使用它自己的 AUTO-INCREMENT 值而不是源表 ID 值来填充“外部”ID？

以下是相关的转换定义：

-- Transform Tables:
INSERT INTO sym_transform_table (transform_id, source_node_group_id, target_node_group_id, transform_point, source_table_name, target_table_name, update_first, delete_action, transform_order, column_policy, create_time, last_update_time )
VALUES
('int2ext_accounts_trans', 'crminternal', 'crmexternal', 'EXTRACT', 'x2_accounts', 'x2_accounts', 1, 'DEL_ROW', 1, 'IMPLIED', current_timestamp, current_timestamp),
('ext2int_accounts_trans', 'crmexternal', 'crminternal', 'EXTRACT', 'x2_accounts', 'x2_accounts', 1, 'DEL_ROW', 2, 'IMPLIED', current_timestamp, current_timestamp);

-- Transform Columns:    
INSERT INTO sym_transform_column(transform_id, include_on, target_column_name, source_column_name, pk, transform_type, transform_expression, transform_order, create_time, last_update_time)
VALUES
('int2ext_accounts_trans', 'I', 'id', null, 0, 'lookup', 'SELECT MAX(id) + 1 FROM mwstage_x2ext.x2_accounts;', 1, current_timestamp, current_timestamp),
('int2ext_accounts_trans', 'U', 'id', 'id', 0, 'copy', null, 1, current_timestamp, current_timestamp),
('int2ext_accounts_trans', 'D', 'id', 'id', 0, 'copy', null, 1, current_timestamp, current_timestamp),
('int2ext_accounts_trans', '*', 'masterId', 'id', 0, 'copy', null, 2, current_timestamp, current_timestamp),
('int2ext_accounts_trans', '*', 'nameId', 'nameId', 1, 'copy', null, 3, current_timestamp, current_timestamp),
('ext2int_accounts_trans', 'I', 'id', null, 0, 'remove', null, 1, current_timestamp, current_timestamp),
('ext2int_accounts_trans', 'U', 'id', 'masterId', 0, 'copy', null, 1, current_timestamp, current_timestamp),
('ext2int_accounts_trans', 'D', 'id', 'masterId', 0, 'copy', null, 1, current_timestamp, current_timestamp),
('ext2int_accounts_trans', '*', 'nameId', 'nameId', 1, 'copy', null, 2, current_timestamp, current_timestamp);

SymmetricDS 变换表： 

CREATE TABLE `sym_transform_table` (
  `transform_id` varchar(50) NOT NULL,
  `source_node_group_id` varchar(50) NOT NULL,
  `target_node_group_id` varchar(50) NOT NULL,
  `transform_point` varchar(10) NOT NULL,
  `source_catalog_name` varchar(255) DEFAULT NULL,
  `source_schema_name` varchar(255) DEFAULT NULL,
  `source_table_name` varchar(255) NOT NULL,
  `target_catalog_name` varchar(255) DEFAULT NULL,
  `target_schema_name` varchar(255) DEFAULT NULL,
  `target_table_name` varchar(255) DEFAULT NULL,
  `update_first` smallint(6) DEFAULT '0',
  `delete_action` varchar(10) NOT NULL,
  `transform_order` int(11) NOT NULL DEFAULT '1',
  `column_policy` varchar(10) NOT NULL DEFAULT 'SPECIFIED',
  `create_time` datetime DEFAULT NULL,
  `last_update_by` varchar(50) DEFAULT NULL,
  `last_update_time` datetime DEFAULT NULL,
  PRIMARY KEY (`transform_id`,`source_node_group_id`,`target_node_group_id`),
  KEY `sym_fk_tt_2_grp_lnk` (`source_node_group_id`,`target_node_group_id`),
  CONSTRAINT `sym_fk_tt_2_grp_lnk` FOREIGN KEY (`source_node_group_id`, `target_node_group_id`) REFERENCES `sym_node_group_link` (`source_node_group_id`, `target_node_group_id`)
) ENGINE=InnoDB DEFAULT CHARSET=latin1

SymmetricDS 变换表：

CREATE TABLE `sym_transform_column` (
  `transform_id` varchar(50) NOT NULL,
  `include_on` char(1) NOT NULL DEFAULT ''*'',
  `target_column_name` varchar(128) NOT NULL,
  `source_column_name` varchar(128) DEFAULT NULL,
  `pk` smallint(6) DEFAULT ''0'',
  `transform_type` varchar(50) DEFAULT ''copy'',
  `transform_expression` mediumtext,
  `transform_order` int(11) NOT NULL DEFAULT ''1'',
  `create_time` datetime DEFAULT NULL,
  `last_update_by` varchar(50) DEFAULT NULL,
  `last_update_time` datetime DEFAULT NULL,
  PRIMARY KEY (`transform_id`,`include_on`,`target_column_name`)
) ENGINE=InnoDB DEFAULT CHARSET=latin1
mysql data-synchronization