Fiorano培训材料_第13课：文件的处理.ppt

第十三课：文件的处理（2） 本课内容 第四个例子：保定电厂的数据采集 上周回顾 范例说明 程序设计 配置FileReader组件 配置Text2XML 编写转换文件 编写转换文件 转换后的数据 数据库中的数据 总结 程序设计 重新设计 重新设计 重新设计 重新设计 重新设计 重新设计 重新设计 重新设计 程序设计 配置DB1组件 配置DB1 配置DB1 配置DB1 配置DB1 配置DB1 配置DB1 配置DB1 配置DB1 配置DB1 配置DB1 配置连接线 配置连接线 配置连接线 配置连接线 配置连接线 测试运行 运行说明 测试运行 测试运行 测试运行 测试运行 维护编码对应表 维护编码表 维护编码表 维护编码表 配置DB2、DB3组件 配置DB2组件 配置DB2组件 配置DB2组件 配置DB2组件 配置DB2组件 配置DB2组件 配置DB3组件 配置连接线 配置连接线 配置连接线 配置连接线 发布运行 发布运行 发布运行 发布运行 程序修改 程序修改 程序修改 程序修改 程序修改 完成后的程序 程序总结 拦截到的数据。对应于源文件的第二行和第五行。 将拦截到的数据放到DB3，写入数据库，查看数据库中的数据。 UPSERT按钮产生的影响，自动产生一个同名的INSERT语句，这个INSERT语句是作为异常处理，附属UPDATE语句，即UPDATE执行失败时才会将这部分数据传递给INSERT语句执行。 选择提交方式,逐条提交。 配置完成后的程序。 未配置前的状态。 左边提供的是经Text2XML组件转换后的数据。 右边需要的DB1组件写入表TRAN_DATA_TEMP需要的列的值。 DATA_DATA：指标值，由value提供。 DATA_DATE：数据时间，由Fiorano的时间函数DateTime提供。 DATE_NO：数据所在行号，由Fiorano的函数Position提供 完成后的连接线，数据全部放到后面的组件，记录并没有过滤。 配置完成后的程序。 将组件发布后运行。 在Text2XML组件和DB1组件将设置断点，查看拦截的数据的情况。 DB1组件的主要的SQL语句是UPDATE语句，由于临时表中并没有数据，接受到的数据无法写入到数据库中。 这部分数据先被传送到异常处理部分，由于在写UPDATE语句时选择了UPSERT按钮，那么异常处理的语句是一个INSERT语句。 由于作为异常处理的INSERT语句存在，那么第一次执行时临时表中没有相关数据，数据经过UPDATE语句，将作为异常数据传递改异常处理的INSERT语句，由INSERT语句写入数据库。 以后执行时凡是表中存在对应数据的，将执行UPDATE，没有对应记录的将执行INSERT语句。 设置断点后运行。 右边是拦截到的数据。 如果下拉滚动条可以看到一共有512条记录。 将数据放到后面的DB1组件，写入临时表中。 表中的数据，一共512条记录。 下图为源文件数据。 再次执行程序后，由于表中已有数据，将执行UPDATE语句。 注意时间的变化。 为了测试的需要先假定DATA_NO为2即源文件中第二行的数据为＃1机组有功。DATA_NO为5时的数据为＃2机组有功。 向编码对应表中维护两条记录，分别是＃1、＃2机组的对应关系。 有了这两条记录后就可以通过SQL语句来转换。 通过查询临时数据表和编码对应表就可以实现数据的转换。 select t2.powerplant_code, t2.machine_no, t2.item_code, t1.data_data, 1 as value_type, t1.data_date from tran_data_temp t1, tran_data_code t2 where t1.data_no = t2.data_no 在数据库中执行的结果。 有结果来看数据符合集团公司存放实时数据的表的格式需求。 DB2组件将整合数据库中的数据取出来，传往集团公司数据库。 教学时使用的数据库是10.81.12.99上面的数据库。 使用SELECT语句。 SQL语句的具体写法，使用前面用PL/SQL写的SQL语句。 SQL语句的具体写法，使用前面用PL/SQL写的SQL语句。 在SQL配置页面中选择运行方式为Scheduler。 这样可以配置执行方式页面。 配置执行方式页面。 只执行一次。 配置完DB2后的程序。 DB3组件还是应用范例2中的DB2组件。 配置完DB3后的程序。 未配置的连接线。 左边是DB2组件的出口，右边是DB3组件的入口。 由于主要的转换由SQL语句完成，本例中的连接线配置非常简单。 下面是配置完成的连接线。 配置完成后的程序。 在DB2于DB3组件间设置