ArgoDB输入

ArgoDB组件SQL语句变量值通过上游参数替换。

主要步骤如下：

• 模型
• 开发步骤
  • 生成记录
  • 基础配置
  • 运行结果

模型

开发步骤

准备数据

drop table depts;

CREATE TABLE `depts` (
`deptno` STRING,
`deptname` STRING,
`loc` STRING)
ROW FORMAT DELIMITED FIELDS TERMINATED BY ','
STORED AS HOLODESK;

INSERT INTO depts(deptno, deptname, loc )VALUES ('1', 'a1', 'loc1');
INSERT INTO depts(deptno, deptname, loc )VALUES ('2', 'a2', 'loc2');
INSERT INTO depts(deptno, deptname, loc )VALUES ('3', 'a3', 'loc3');

《生成记录》

从输入分组拖出生成记录组件进行数据配置。

《基础配置》

在关系型数据库输入组件中选择刚才创建的表。 将sql语句进行编辑，按图勾选并选择步骤，用问号按照上游字段顺序进行值替换，替换后的sql格式：

SELECT deptno, deptname, loc FROM db_test.depts where deptno=1。

《运行结果》

点击 保存-提交-运行，会将输出信息通过日志组件打印到下方。