普元数据开发平台 普元数据开发平台
产品介绍
安装部署
快速入门
操作指南
应用集成
运维指南
  • 关系型数据库输入-通用配置进行变量设置
  • 模型
  • 开发步骤

# 关系型数据库输入-通用配置进行变量设置

在通用配置进行变量设置,然后在组件中进行变量替换。

主要步骤如下:

  • 模型
  • 开发步骤
    • 参数配置
    • 基础配置
    • 运行结果

# 模型

input

# 开发步骤

准备数据

drop table employee;

CREATE TABLE `employee` (
`employee_id` int(11),
`name` varchar(100),
`id_number` varchar(18),
`phone_number` varchar(11),
`email` varchar(100),
`address` varchar(255),
`department_id` int(11),
PRIMARY KEY (`employee_id`)
);

INSERT INTO employee (  employee_id,name,id_number,phone_number,email,address,department_id ) VALUES(1,'zhangsan','123456789','13812345678','zhangsan@163.com','beijing',1);
INSERT INTO employee (  employee_id,name,id_number,phone_number,email,address,department_id ) VALUES(2,'lisi','123456789','13812345678','lisi@163.com','beijing',1);
INSERT INTO employee (  employee_id,name,id_number,phone_number,email,address,department_id ) VALUES(3,'wanger','123456789','13812345678','wanger@163.com','beijing',1);

# 步骤1:参数配置

点击右侧通用配置,在命名参数栏进行参数添加。

input

# 步骤2:基础配置

打开关系型数据库输入组件,使用${name},(name为配置的参数)进行变量替换,替换后的sql格式:

SELECT employee_id, name, id_number, phone_number, email, address, department_id FROM damp_test.employee。

input

# 最后一步:运行结果

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

input

← 关系型数据库输入-上游数据入参 Kafka输入-基本配置使用 →