1. 首页 > 故事语录 > 创业指导

kettle java代码组件(java新手代码大全)

概述

Row normaliser(行转列)此步骤将输入流的行转换为列。可以使用此步骤对列的重复组进行规范化。

选项

Kettle(PDI)转换中转换之行转列详解

行转列

Row normaliser(行转列))步骤有以下选项:

Step name(步骤名称):在画布上指定Row normaliser(行转列)步骤的唯一名称。您可以自定义名称或将其保留为默认名称。

Type field(Type字段):指定输出数据中的新列的名称。

字段

Fieldname(字段名称):要规范化的字段的名称。

Type(Key值):指定用于对字段进行分类的字符串。

new field(Value字段):指定要在其中传输新值的字段。

Get Fields(获取字段):检索流中传入的所有字段的列表。

示例

示例采用一个栏目的每月访问量统计数据为基础演示数据,把栏目每月访问量一行数据转换以月为列的多行数据。

/*栏目每月访问量统计表*/

DROP TABLE IF EXISTS `catalog_traffic`;
CREATE TABLE `catalog_traffic` (
  `catalogid` VARCHAR(10) NOT NULL COMMENT '栏目编号',
  `catalogname` VARCHAR(20) DEFAULT NULL COMMENT '栏目名称',
  `month1` BIGINT DEFAULT 0 NOT NULL COMMENT '1月访问量',
  `month2` BIGINT DEFAULT 0 NOT NULL COMMENT '2月访问量',
  `month3` BIGINT DEFAULT 0 NOT NULL COMMENT '3月访问量',
  `month4` BIGINT DEFAULT 0 NOT NULL COMMENT '4月访问量',
  `month5` BIGINT DEFAULT 0 NOT NULL COMMENT '5月访问量',
  `month6` BIGINT DEFAULT 0 NOT NULL COMMENT '6月访问量',
  `month7` BIGINT DEFAULT 0 NOT NULL COMMENT '7月访问量',
  `month8` BIGINT DEFAULT 0 NOT NULL COMMENT '8月访问量',
  `month9` BIGINT DEFAULT 0 NOT NULL COMMENT '9月访问量',
  `month10` BIGINT DEFAULT 0 NOT NULL COMMENT '10月访问量',
  `month11` BIGINT DEFAULT 0 NOT NULL COMMENT '11月访问量',
  `month12` BIGINT DEFAULT 0 NOT NULL COMMENT '12月访问量',
  PRIMARY KEY (`catalogid`)
) ENGINE=INNODB DEFAULT CHARSET=utf8;
insert  into `catalog_traffic`(`catalogid`,`catalogname`,`month1`,`month2`,`month3`,`month4`,`month5`,`month6`,`month7`,`month8`,`month9`,`month10`,`month11`,`month12`) values ('1','栏目1',166,676,8009,445,9900,909,909,345687,78734,7676,34434,3434);
insert  into `catalog_traffic`(`catalogid`,`catalogname`,`month1`,`month2`,`month3`,`month4`,`month5`,`month6`,`month7`,`month8`,`month9`,`month10`,`month11`,`month12`) values ('2','栏目2',767,676,545,454,9009,334,557,9033,343,56565,2323,34443);

1.建立数据库连接对象

示例采用mysql数据库作为示例,首先下载mysql驱动
https://mvnrepository.com/artifact/mysql/mysql-connector-java/5.1.47,然后放在在文件夹data-integrationlib下。然后重启Spoon。如果已经添加过mysql驱动,则可由忽略此步骤。

切换至主对象树,双击DB连接。Kettle(PDI)转换中转换之行转列详解

添加DB连接

然后选项连接类型为mysql,并维护相关的链接信息。Kettle(PDI)转换中转换之行转列详解

维护数据库连接

连接信息维护完之后,点击测试,测试连接是否成功。

2.获取栏目每个月访问量统计表catalog_traffic数据作为数据输入源。

添加一个表输入步骤,数据库连接上面创建的DB连接名称demo,然后从获取SQL查询语句中选择表catalog_traffic,即可。

Kettle(PDI)转换中转换之行转列详解

最后点击预览,预览结果数据。Kettle(PDI)转换中转换之行转列详解

预览数据

3.添加转换中的行转列步骤,并配置行转列选项

添加一个转换中的行转列。并建立从表输入到行转列的一个节点连接。Kettle(PDI)转换中转换之行转列详解

建立节点连接

在行转列配置key字段为month,然后获取点击获取字段,保留month1…month12,作为行专列字段,然后对应的key值为1…12,为对应月份的值。Value的值设置为:count。

Kettle(PDI)转换中转换之行转列详解

最后保存并点击运行。

Kettle(PDI)转换中转换之行转列详解
Kettle(PDI)转换中转换之行转列详解

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌抄袭侵权/违法违规的内容,请发送邮件至 PTU@FOXMAIL.COM 举报,一经查实,立刻删除。

联系我们

在线咨询:点击这里给我发消息

微信号:暂无

E-mail:ptu@foxmail.com

工作日:9:30-18:30