ETL利器KETTLE实战应用解析之KETTLE应用场景和实战DEMO.docxVIP

1、应用场景 这里简单概括一下几种具体的应用场景，按网络环境划分主要包括： 表视图模式：这种情况我们经常遇到，就是在同一网络环境下，我们对各种数据源的表数据进行抽取、过滤、清洗等，例如历史数据同步、异构系统数据交互、数据对称发布或备份等都归属于这个模式；传统的实现方式一般都要进行研发（一小部分例如两个相同表结构的表之间的数据同步，如果sqlserver数据库可以通过发布/订阅实现），涉及到一些复杂的一些业务逻辑如果我们研发出来还容易出各种bug； 前置机模式：这是一种典型的数据交换应用场景，数据交换的双方A和B网络不通，但是A和B都可以和前置机C连接，一般的情况是双方约定好前置机的数据结构，这个结构跟A和B的数据结构基本上是不一致的，这样我们就需要把应用上的数据按照数据标准推送到前置机上，这个研发工作量还是比较大的； 文件模式: 数据???互的双方A和B是完全的物理隔离，这样就只能通过以文件的方式来进行数据交互了，例如XML格式，在应用A中我们开发一个接口用来生成标准格式的XML，然后用优盘或者别的介质在某一时间把XML数据拷贝之后，然后接入到应用B上，应用B上在按照标准接口解析相应的文件把数据接收过来； 综上3种模式如果我们都用传统的模式无疑工作量是巨大的，那么怎么做才能更高效更节省时间又不容易出错呢？答案是我们可以用一下Kettle-_-！ 2、DEMO实战 2、1 实例1：数据库TestA中的UserA表到数据库TestB的UserB表 1）为方便演示，我这边把Sql脚本贴出来，大家直接复制在sqlserver中运行即可,sql脚本如下： INCLUDEPICTURE \d /OutliningIndicators/ContractedBlock.gif \* MERGEFORMATINET 简单表之间交换 ? 2）Kettle实现方式 功能简述：数据库TestA中的UserA表到数据库TestB的UserB表； 实现流程：建立一个转换和一个作业Job； A:建立一个转换：打开Kettle.exe，选择没有资源库，进入主界面，新建一个转换，转换的后缀名为ktr，转换建立的步骤如下： 步骤1：创建DB连接，选择新建DB连接，如下图，我们输入相应的Sqlserver配置信息之后点击Test按钮测试是否配置正确！ INCLUDEPICTURE \d /blog/418758/201301573f1f91f44640d58ae628c6a76a2482.png \* MERGEFORMATINET  我们需要建立两个DB连接，分别为TestA和TestB； 步骤2：建立步骤和步骤关系，点击核心对象，我们从步骤树中选择【表输入】，如下图，这样拖拽一个表输入之后，我们双击表输入之后，我们自己可以随意写一个sql语句，这个语句表示可以在这个库中随意组合，只要sql语句没有错误即可，我这里只是最简单的把TestA中的所有数据查出来，语句为select * from usersA。 INCLUDEPICTURE \d /blog/418758/2013016fff35c8fa5d42a790539823d4b5e37e.png \* MERGEFORMATINET  接下来我们创建另外一个步骤【插入/ 更新】，然后在【表输入】上同时按住shift键和鼠标左键滑向【插入/ 更新】，这样建立两个步骤之间的连接，【插入/ 更新】执行的逻辑是如果UserA表中的记录在UserB中不存在那么就插入，如果存在就更新，如下图，在插入更新中我们可以做一些关键条件和字段映射，这里我们是最简单的！点击保存，把我们建立的转换保存一下。 INCLUDEPICTURE \d /blog/418758/2013011f82813ebcae4b6ca0bb15b39758bd1d.png \* MERGEFORMATINET  建立好转换之后，我们可以直接运行这个转换，检查一下是否有错，如图，有错误都会在下面的控制台上输出。 INCLUDEPICTURE \d /blog/418758/201301339571e5fe6f4c69a634daac6d584e6a.png \* MERGEFORMATINET  B:如果我们需要让这个转换定时执行怎么办呢，那么我们需要建立一个作业job，见下图，在简单表同步这个转换中，我们把在A步骤中建立的ktl配置上，注意路径的正确性； INCLUDEPICTURE \d /blog/418758/2013015751f4a4bed1430391ac5d00b2ad18da.png \* MERGEFOR