本文主要是介绍kettle 调用 webservice 服务抽取结果到目标库，同时更新源数据库标志位，对大家解决编程问题具有一定的参考价值，需要的程序猿们随着小编来一起学习吧！

kettle 调用 webservice 服务抽取结果到目标库，同时更新源数据库标志位

一、基本配置

1. 文件 -- 新建 -- 转换 建立项目
2. 主对象树 DB 连接，一个源数据库 centeradapter 参数库、一个目标数据库 ehrview 参数库

假如输入库中某张表为：

create table TEST20190917(

  ID       NUMBER,

  SHENG    VARCHAR2(20),

  FLAGTYPE VARCHAR2(4)

);，

输出库中某张表为：

create table TEST20190917(

  SHENG   VARCHAR2(20),

  XMLDATA  VARCHAR2(2000)

);

二、创建步骤

建立整体步骤如下所示

 1、核心对象 -- 输入 -- 表输入，连接输入库，读取基础参数表

2、核心对象 -- 转换 -- 字段选择

点击基础参数表输入框，按住 shift 键，鼠标自前者到字段选择框移动，会进行两个按钮连接，同样方法进行其他步骤直接的连接

3、核心对象 -- 查询 --WEB 服务查询，以天气预报服务接口

http://www.webxml.com.cn/WebServices/WeatherWebService.asmx?wsdl 为例，进行配置

 4、核心对象 -- 输入 --XML 文件输入，XML 源定义在一个字段里打对号，选择源字段名，

 根据 webservice 服务接口返回 xml 数据配置循环读取路径

 ody></soap:Envelope>，则循环读取路径为 /soap:Envelope/soap:Body/getSupportCityResponse

 5、核心对象 -- 转换 -- 字段选择

 6、核心对象 -- 输出 -- 表输出

 7、核心对象 -- 转换 -- 增加常量

 8、核心对象 -- 输出 -- 更新

三、运行

点击运行按钮，运行成功会在各个步骤中显示绿色的对号按钮，否则出错会显示红色叉号按钮

四、查看数据

目标库中查找相关表查询出已经插入数据

 五、核心对象 -- 通用，编写 job 脚本，实现定时器任务

这篇关于kettle 调用 webservice 服务抽取结果到目标库，同时更新源数据库标志位的文章就介绍到这儿，希望我们推荐的文章对大家有所帮助，也希望大家多多支持为之网！