java - SymmetricDS:我应该使用哪种方法来同步特定表？

Question

我正在测试 SymmetricDS，我对应该使用哪种方法来同步某些特定的表有一些疑问。我有两个应用程序，第一个是 ERP，第二个是 PDV。有些表可以同步到所有 PDV 数据库，但是，在某些表中，行应该同步到特定的 PDV 实例:

在此图中，红色矩形显示哪个表需要同步，绿色箭头显示我们可以识别哪个 SymmetricDS 实例将同步的列。我的问题是:我应该使用哪种方法(bsh、subselect、lookuptable 等)以及如何做？

Answer 1

您需要一个子选择路由器(实际上您需要三个)。我只给你看Funcionario的SQL，然后你就可以自己搞清楚Cadastro和Funcionario_funcao的配置了:

insert into SYM_ROUTER 
  (router_id, source_node_group_id, target_node_group_id, router_type, 
    router_expression, create_time, last_update_time)
values
  ('erp_to_pdv__funcionario', 'erp', 'pdv', 'subselect', 
    'c.external_id in (
        select empresa.CNPJ
          from cadastro join empresa
            on cadastro.id_empresa = empresa.id_empresa
          where cadastro.CPFCGC=:ID_CADASTRO
     )', 
    current_timestamp, current_timestamp);

当来自 Funcionario 表的记录被路由时，该路由器选择所有 external_id 等于链接到的 Empresa.CNPJ 的节点给定的 Funcionario(我假设 Funcionario.id_cadastro 是对 Cadastro.CPFCGC 的引用)

请注意，我使用了 c.external_id，但您可能想要使用 c.node_id(取决于您放入 Empresa.CNPJ 中的内容)。