资源描述
,中国大唐集团公司 数据共享平台项目建设 视频培训会,第八课 编写简单的程序,本课内容,编写简单的程序,上周回顾,FEPO启动,Fiorano提供工具FEPO编写程序、查看程序的状态和对程序进行启停管理。 从上到下分别输入 服务器连接地址 用户名 密码,FEPO登陆后的页面,查询程序,左侧的程序浏览窗口分为两部分。 正在运行的程序：Running Event Processes 所有程序：Event Process Repository 点击Running Event Processes可以查询目前正在运行的程序。 双击Running Event Processeshe和Event Process Repository下面的任何程序，可以调出程序的页面。,程序的状态,程序有两种状态，黑色的表示不在运行，红色或是绿色的表示正在运行。 组件则有三种状态。,程序的导入导出,通过菜单中的File和快捷按钮中可以把fiorano程序导出成文件，或是把程序导入到系统中。,指定组件运行的节点,新编和新导入的程序需要先指定运行的节点，才能运行。 方法是先选择组件，然后通过左边的属性页面中的Node Name属性进行修改。,程序的启停管理,Fiorano中的程序可以通过菜单中的Actions或是快捷按钮启动和停止程序。 通过三角形的按钮（Launch），可以将程序运行起来。 新编程序在运行前可能需要检查节点（Connectivity）。,组件的启停管理,程序启动后，FES向相关的FPS发出程序的启动命令，组件开始在FPS运行。 FPEO可以停止单个组件或是所有组件的运行，也可以向单个没有启动成功的组件，发出启动命令。 启停单个组件时需要先选中组件。,编写简单的程序,新建程序,当我们调出一个程序后，在FEPO的主面板中就会显示该程序的内容。 编程前需要调出一个空白的面板或者说新建一个空白的程序。 通过菜单中的file和快捷按钮可以实现这一功能。 其实新建程序只不过是清理出一个空白的主面板，供编程使用。,设计程序,在编写程序前首先需要设计程序。 确定需要使用哪几种组件。 每一种组件需要多少个。 每一个组件需要实现的功能。,第一例 数据传输,第一例 数据传输,程序设计,数据的简单传输,首先看一下最简单的一个例子：在相同的数据库，相同的表结构间的数据的传输。 程序设计如下： 使用的组件：DB DB组件使用的个数：2个 第一个DB组件作用：从源数据库取数据；第二个组件的作用：是把数据保存到目的数据库。,取得需要的组件,直接从组件面板中将DB组件拖到主面板中。 DB组件的位置，组件面板-DB-DB,主面板中就有了两个DB组件。,配置组件DB1,假定DB1的作用是取数据。 双击DB1组件，提示正在打开配置页面，可以通过cancel取消刚才的操作。,第一例 数据传输,配置数据库连接,配置组件DB1,打开后的配置页面。 第一页数据库连接配置。,配置组件DB1,需要配置的参数： Database：选择数据库类型 Driver：数据库驱动程序 URL：该驱动下的连接参数 User name：数据库用户名 Password：数据库密码,选择数据库类型,选择类型为Oracle,配置URL,驱动程序使用默认。 不同驱动的url格式不同。 默认的URL如下 jdbc:oracle:thin:HostName:1521:orcl HostName数据库服务器主机名或是IP 1521：oracle端口，默认为1521 orcl：oracle的Sid 连接10.81.12.99上的数据库 将HostName改为10.81.12.99 Sid为datang jdbc:oracle:thin: 10.81.12.99 :1521:datang,配置URL,指定用户名和密码,数据库用户名/密码 datang/datang,测试数据库连接,使用右下角的Test测试数据库连接。,测试数据库连接,测试显示数据库连接成功。,完成连接配置,按NEXT到下一页,第一例 数据传输,编写sql语句,SQL配置,配置组件执行的sql 点击 SQL configuration 调出SQL配置页面,SQL配置,该页面下包含sql配置和高级属性两个分页面。,添加sql语句,添加sql语句,选择Select后调出右边写sql语句的窗口。,命名执行的操作,一个DB组件可以执行多个sql语句，每个sql语句都需要命名以加以区分。,选择执行的表,选择执行的表,点击前面图中的加号按钮后会出现右边的页面。 在这个页面中列出了该DB所连接的数据库中，连接用户可见的所有表和视图。 选择TEST_A按ok，确定并退出。,配置sql语句,不作修改时，默认的sql语句为 Select * from Test_a,配置sql语句,不作修改时，默认的sql语句为 Select * from Test_a 中间的小窗口显示，该表有三个字段，字段名分别是A、B、C。,选中所有的三个字段，如上面的右图 选中后的sql语句变成 Select A，B，C from Test_a,配置sql语句,在选定sql所取得字段后，配置页面中sql语句和相应的其他配置信息发生了变化。,配置sql语句,当前配置下执行的sql语句,4个分页分别是所选字段别名和排序、where字句、分组、havine字句。 通过这些简单的页面就可以写出简单的sql语句。,Select语句完成,假定不需要做其他的修改，点击OK，确认并退出。,选择执行方式,几乎所有的组件都有两种执行方式。 Publish results Scheduler 分别对应于一般的方式和按一定的计划执行。 选择Scheduler按照计划执行。 点击Next进入下一页面。,退出sql配置页面,按Finish退出sql配置页面,第一例 数据传输,配置执行方式,退出sql配置页面,完成sql配置后，按next进入配置执行方式的页面。,配置执行方式,只有在前面选择执行方式时选择Scheduler才能配置这个页面。,选择执行时间间隔,每10秒钟执行一次。,选择执行次数,只执行1次。 去掉Infinite times前面的勾，否则表示执行无数次。,确定执行次数,在Number of polls中写入需要执行的次数。,完成执行方式配置,按Next进入异常处理页面。,异常处理,异常处理，使用默认方式。 按Finish完成DB组件的配置。,第一例 数据传输,配置第二个DB组件,配置数据库连接,为了范例的方便，连接的数据库还是10.81.12.99。,配置sql语句,配置sql语句,写入数据使用Insert语句。,配置sql语句,选择写入数据的表格 Test_b,配置sql语句,默认为写入所有字段。 表Test_b下面共有4个字段。 其中Sdate有默认值sysdate即数据库当前时间。,配置sql语句,在insert中去掉Sdate字段。 按照这样的sql语句执行组件，组件将不会对Sdate提供数值，数据库将给sdate字段附以默认值。,选择默认的执行方式,默认的执行方式，即Publish Results 当组件接收到数据时将会执行相关的操作。,执行方式页面不可用,异常处理,异常处理，使用默认方式。 按Finish完成DB组件的配置。,第一例 数据传输,配置数据库间的连接,配置组件连接,配置好两个组件后的主页面：,通常情况下可以通过鼠标选择某个组件或是连接。 需要建立组件间的连接时，首先需要改变鼠标的操作方式。,在启停程序的快捷按钮的左侧有两个按钮，分别表示鼠标为拾取实体或是建立组件间的连接。 点击右边的按钮后，就可以在组件间拖线，来建立联系。,配置组件连接,鼠标放到DB1组件的出口OUT_PORT处按住鼠标左键不放,此时拖动鼠标将会出现一条线。 将这条线拖到DB2的入口处，放开鼠标左键。 此时就在DB1和DB2间建立了连接。,配置组件连接,在通过上面的快捷按钮将鼠标换成拾取实体的方式。,上图线的颜色表示连接还没有配置。需要配置连接。 直接双击连接线，就可以配置连接。 注意：并不是所有的组件间的连接都需要配置。,配置组件连接,双击连接线。,提示是否使用Mapper配置连接。 按是调出工具Mapper。,配置组件连接,按是调出工具Mapper 在工具Mapper的左边是DB1组件的出口，即sql语句select_data的三个结果集属性。右侧为DB2的入口，即sql语句insert的三个写入数据的列。,配置组件连接,将select_data得到的数据传递给insert。 在select_data处按鼠标左键，直接拖到ZERO MANY。,配置组件连接,将select_data得到的结果集属性A、B、C分别传递给insert的列A、B、C。,配置组件连接,上面的操作将DB1组件中sqlselect_data得到的纪录送到了DB2组件的sql insert，并且select_data得到的结果集的属性A、B、C分别传递给insert需要的列A、B、C。 Mapper工具有一个按钮可以用来确认刚才的操作是否正确。,确认所作的操作是否正确。 确认后消息框中提示正确。,配置组件连接,保存所作的操作。,或者是退出时提示保存。,配置组件连接,保存后退出Mapper，组件间的数据传输将按照刚才的配置传输数据。 下图为配置好连接的程序。,注意：将某个sql的结果集拖线给目标集是，并不是直接将线拖到对应的目标集，而是对应的ZERO MANY。 这条线并非必须，如果没有这条线表示一批数据假如有100条纪录只有第一条纪录可以传输给目标集。如果有这条线那么所有的纪录都将被传输到目标集中。,第一例 数据传输,程序运行,选择运行的节点,DB1和DB2均选择节点fps99。,命名组件和连接,为了方便命名组件和连接。,命名组件和连接,命名后的组件和连接 DB1：取数据 DB2：存数据 连接：数据传输,运行程序,运行,查看运行的结果,数据已经写入test_b中。,练习,在本地的服务器上安装一个oracle数据库，实在没有的可以利用12.99上的数据库。 在数据库中建表PERSON_B（培训人员），建表语句如下 create table PERSON_B( POWERPLANT VARCHAR2(50), POWERPLANT_SHORT VARCHAR2(20), COMPANY VARCHAR2(20), PERSON VARCHAR2(20), TELEPHONE VARCHAR2(20) - Add comments to the columns comment on column PERSON_B.POWERPLANT is 电厂名;comment on column PERSON_B.POWERPLANT_SHORT is 电厂简称;comment on column PERSON_B.COMPANY is 所属分公司;comment on column PERSON_B.PERSON is 培训人员姓名;comment on column PERSON_B.TELEPHONE is 联系电话;,练习,在本地数据库的PERSON_B中写入的培训人员的相关纪录，其中每个字段的含义同字段的注释。 利用12.99上的fiorano2006编写程序将本地数据库PERSON_B中的数据传输到12.99上面的表PERSON中。 注：没有本地oracle数据库的电厂，可以利用12.99上面的数据库操作。,
展开阅读全文