【问题标题】:How to make multiple connections with Talend Job?如何与 Talend Job 建立多个连接?
【发布时间】:2019-08-05 10:07:16
【问题描述】:

我正在编写一个 talend 作业来将 mysql 数据库从客户端复制到服务器 我正在使用“tmysqlconnection”和 tmysql_row“组件 现在这里的困难是我将上下文参数传递给我的工作,比如

USE "+context.destination_database+";

SET SQL_SAFE_UPDATES = 0;
SET FOREIGN_KEY_CHECKS = 0;



SELECT GROUP_CONCAT(concat('main.', column_name)) 
    INTO @fields_name
    FROM  information_schema.columns 
    WHERE table_schema=DATABASE() AND table_name='"+context.mysql_source_table+"';

SELECT @fields_name;


SELECT id FROM "+context.mysql_source_database+"."+context.mysql_source_table_mac+" order by id asc limit 2,1  INTO @mac_id;

SELECT @mac_id;

它是 myquery 的一小部分,其中我的服务器数据库中的目标数据库位于其他机器上,源数据库是客户端机器 真正的问题来了,因为我的 talend 工作使用特定的数据库,即客户端或服务器来查找导致工作失败的两个数据库 如何连接到我的两个 mysql 数据库并在我的查询中使用上下文参数,以便我的工作知道我可以从哪个数据库获得数据

【问题讨论】:

    标签: talend


    【解决方案1】:

    使用 tMySqlrow 从源数据库中进行选择,并创建另一个组件 tMysqlOutput 以在新数据库中创建表。

    【讨论】:

      猜你喜欢
      • 1970-01-01
      • 1970-01-01
      • 2021-02-25
      • 2022-09-30
      • 2016-12-13
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      相关资源
      最近更新 更多