【发布时间】: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