Kettle使用_26 根据增删改标识处理数据

需求:已知数据的状态标签(insert、update、delete)利用kettle对其进行相应的操作。

解决方法:主要通过过滤记录组件来解决如上问题。

Previous work:

数据库(以mysql为例)里准备源数据,表结构与数据见下:

DROP TABLE tb_user;
CREATE TABLE tb_user(
id integer,
name varchar(12)
);TRUNCATE TABLE tb_user;
INSERT INTO tb_user VALUES(1,'上海');
INSERT INTO tb_user VALUES(2,'北京');
INSERT INTO tb_user VALUES(3,'深圳');

Step1:新建个转换

Step2:拖个自定义常量组件,并定义结构和数据。

元数据:

数据:

Step3:拖个过滤记录组件,命名为“是否新增”,通过SHIFT使得自定义数据常量与该组件关联,并配置过滤记录如下:

配置过滤记录(这里的删除标记字段和是否删除分别对应下文的组件),该组件命名为“是否新增“:

Step4:拖个字段选择组件,命名为删除标记字段,并配置选择字段组件。再拖个文本文件输出组件,并配置。

SHIFT连接是否新增与删除标记字段组件,注意这里是为TRUE时选择。

在移除里配置字段名

配置文本文件输出路径和字段。

Step5:同理拖个过滤记录,其名称为“是否删除”,

Step6:拖个删除组件,该组件位于转换的输出分类下,SHIFT连接“是否删除组件”与删除组件。

Step7:同理拖个过滤记录,其名称为“是否更新”,SHIFT连接“是否删除“与该组件,并配置如下:

Step8:拖个更新组件,该组件位于转换的输出分类下,SHIFT连接“是否更新”与更新组件。配置更新组件见下:

Step9:保存、运行、验证该转换。

完整的流程示意见下:

Kettle使用_26 根据增删改标识处理数据相关推荐

  1. Zookeeper 客户端API调用示例(基本使用,增删改查znode数据,监听znode,其它案例,其它网络参考资料)

    9.1 基本使用 org.apache.zookeeper.Zookeeper是客户端入口主类,负责建立与server的会话 它提供以下几类主要方法  : 功能 描述 create 在本地目录树中创建 ...

  2. 谈tabulator动态增删改、填充数据以及清空数据

    tabulator动态增删改.填充数据以及清空数据 tabulator动态增删改.填充数据以及清空数据 闲话不多话,直接上干货! 1.关于操作列表设置: //创建并设置table属性var _curR ...

  3. Mysql数据库和表的增删改查以及数据备份恢复

    数据库 查看所有数据库 show databases; 使用数据库 use 数据库名; 查看当前使用的数据库 select database(); 创建数据库 create database 数据库名 ...

  4. Web SQL介绍,web sql中增删改查、数据存储位置、运行脚本、建表建库

    Web SQL: Web SQL是一种简单的存在服务器中的数据库,运行在javascript脚本中,其数据储存在计算机Application中Web SQL中. web sql提供了三个核心方法: 1 ...

  5. 处理增删改_实现数据的增删改查

    一,程序要求 对后台的数据(以一个文件为例)实现简单的增删改查功能,语句的语法为提示信息的示例 二,代码部分 #! /usr/bin/env python# -*- coding: utf-8 -*- ...

  6. 【Python数据处理篇——DataFrame数据准备】DataFrame的创建、增删改查、数据导入等

    欢迎访问我搞事情的[知乎账号]:Coffee 以及我的[B站漫威剪辑账号]:VideosMan 若我的笔记对你有帮助,请用小小的手指,点一个大大的赞哦. 关于DataFrame的相关知识,我还进行了汇 ...

  7. mysql导入sql脚本、增删改数据库、数据表,超详细图解

    为方便查看,建议使用右侧目录 一.导入sql脚本 source 二.数据库操作 create 增 use 使用 三.数据表操作 表结构(DDL) create 新建 drop 删 alter 增.改 ...

  8. 【学亮IT手记】SpringMVC增删改查+map数据返回Controller层代码示例

    @RestController @RequestMapping("/brand") public class BrandController {@Referenceprivate ...

  9. 跟燕十八学习PHP-第十五天-php增删改查表数据

    /** 燕十八 公益PHP培训 课堂地址:YY频道88354001 学习社区:www.zixue.it **/ <!DOCTYPE html PUBLIC "-//W3C//DTD X ...

最新文章

  1. 卧槽!又一 SQL 神器面世!!
  2. 人工智能推动全球业务的数据中心管理
  3. 职业技术学校计算机专业部教师,江安职校计算机专业部召开第二次全体教师大会...
  4. java中使用json以及所导入的包
  5. java 入侵 mysql_Java访问数据库Mysql
  6. mac java jni_Mac OS上编译JNI的动态库
  7. css 背景图片虚化
  8. android provided without an @Inject constructor or an @Provides-annotated method.报错原因
  9. JDE910笔记2--OMW项目建立及简单使用[转]
  10. Java小知识点合集-面向对象
  11. 企业测试环境部署(一)
  12. 数学建模:回归分析——regress 函数
  13. autocad显卡驱动文件hdi_AUTOCAD启动提示显示驱动文件丢失怎么办?hdi是什么文件?...
  14. 迷你世界箱子里物品无限取
  15. YTU 3795 GCD 和 LCM
  16. 遇到 ORACLE 错误 1455
  17. 【以终为始】接到需求任务,你要先做哪件事?
  18. 矩阵计算 Armadillo Eigen Matcom
  19. 什么是钩子,钩子的原理
  20. 通过API获取ip地址以及城市和运营商

热门文章

  1. wxWidgets:创建其他框架
  2. wxWidgets:命令行参数
  3. wxWidgets:拖放概述
  4. boost::regex模块在 cpp 文件中搜索类定义,使用绑定成员函数回调测试程序
  5. boost::regex模块部分正则表达式相关的测试程序
  6. boost::process::cmd相关的测试程序
  7. boost::function2用法的测试程序
  8. VTK:PolyData之ThresholdPoints
  9. VTK:模型之Delaunay3DDemo
  10. OpenCV演示FloodFill()函数的实例(附完整代码)