Fiorano培训材料第08课：编写简单的程序

1、China Datang Corporation中国大唐集团公司中国大唐集团公司数据共享平台项目建设数据共享平台项目建设视频培训会视频培训会 China Datang Corporation第八课第八课 编写简单的程序编写简单的程序China Datang Corporation本课内容本课内容 编写简单的程序China Datang Corporation上周回顾上周回顾China Datang CorporationFEPO启动启动Fiorano提供工具FEPO编写程序、查看程序的状态和对程序进行启停管理。从上到下分别输入服务器连接地址用户名密码China Datang Corporati

2、onFEPO登陆后的页面登陆后的页面China Datang Corporation查询程序查询程序左侧的程序浏览窗口分为两部分。正在运行的程序：Running Event Processes所有程序：Event Process Repository 点击Running Event Processes可以查询目前正在运行的程序。双击Running Event Processeshe和Event Process Repository下面的任何程序，可以调出程序的页面。China Datang Corporation程序的状态程序的状态程序有两种状态，黑色的表示不在运行，红色或是绿色的表示正在运行

3、。组件则有三种状态。China Datang Corporation程序的导入导出程序的导入导出通过菜单中的File和快捷按钮中可以把fiorano程序导出成文件，或是把程序导入到系统中。China Datang Corporation指定组件运行的节点指定组件运行的节点新编和新导入的程序需要先指定运行的节点，才能运行。方法是先选择组件，然后通过左边的属性页面中的Node Name属性进行修改。China Datang Corporation程序的启停管理程序的启停管理Fiorano中的程序可以通过菜单中的Actions或是快捷按钮启动和停止程序。通过三角形的按钮（Launch），可以将程序运

4、行起来。新编程序在运行前可能需要检查节点（Connectivity）。China Datang Corporation组件的启停管理组件的启停管理程序启动后，FES向相关的FPS发出程序的启动命令，组件开始在FPS运行。FPEO可以停止单个组件或是所有组件的运行，也可以向单个没有启动成功的组件，发出启动命令。启停单个组件时需要先选中组件。China Datang Corporation编写简单的程序编写简单的程序China Datang Corporation新建程序新建程序当我们调出一个程序后，在FEPO的主面板中就会显示该程序的内容。编程前需要调出一个空白的面板或者说新建一个空白的程序。通

5、过菜单中的file和快捷按钮可以实现这一功能。其实新建程序只不过是清理出一个空白的主面板，供编程使用。China Datang Corporation设计程序设计程序在编写程序前首先需要设计程序。确定需要使用哪几种组件。每一种组件需要多少个。每一个组件需要实现的功能。China Datang Corporation第一例第一例 数据传输数据传输China Datang Corporation第一例第一例 数据传输数据传输程序设计China Datang Corporation数据的简单传输数据的简单传输首先看一下最简单的一个例子：在相同的数据库，相同的表结构间的数据的传输。程序设计如下：使用的

6、组件：DBDB组件使用的个数：2个第一个DB组件作用：从源数据库取数据；第二个组件的作用：是把数据保存到目的数据库。China Datang Corporation取得需要的组件取得需要的组件直接从组件面板中将DB组件拖到主面板中。DB组件的位置，组件面板-DB-DB主面板中就有了两个DB组件。China Datang Corporation配置组件配置组件DB1假定DB1的作用是取数据。双击DB1组件，提示正在打开配置页面，可以通过cancel取消刚才的操作。China Datang Corporation第一例第一例 数据传输数据传输配置数据库连接China Datang Corporat

7、ion配置组件配置组件DB1打开后的配置页面。第一页数据库连接配置。China Datang Corporation配置组件配置组件DB1需要配置的参数：Database：选择数据库类型Driver：数据库驱动程序URL：该驱动下的连接参数User name：数据库用户名Password：数据库密码China Datang Corporation选择数据库类型选择数据库类型选择类型为OracleChina Datang Corporation配置配置URL驱动程序使用默认。不同驱动的url格式不同。默认的URL如下jdbc:oracle:thin:HostName:1521:orclHostN

8、ame数据库服务器主机名或是IP1521：oracle端口，默认为1521orcl：oracle的Sid连接10.81.12.99上的数据库将HostName改为10.81.12.99Sid为datangjdbc:oracle:thin: 10.81.12.99 :1521:datangChina Datang Corporation配置配置URLChina Datang Corporation指定用户名和密码指定用户名和密码数据库用户名/密码datang/datangChina Datang Corporation测试数据库连接测试数据库连接使用右下角的Test测试数据库连接。China D

9、atang Corporation测试数据库连接测试数据库连接测试显示数据库连接成功。China Datang Corporation完成连接配置完成连接配置按NEXT到下一页China Datang Corporation第一例第一例 数据传输数据传输编写sql语句China Datang CorporationSQL配置配置配置组件执行的sql点击SQL configuration调出SQL配置页面China Datang CorporationSQL配置配置该页面下包含sql配置和高级属性两个分页面。China Datang Corporation添加添加sql语句语句China Dat

10、ang Corporation添加添加sql语句语句选择Select后调出右边写sql语句的窗口。China Datang Corporation命名执行的操作命名执行的操作一个DB组件可以执行多个sql语句，每个sql语句都需要命名以加以区分。China Datang Corporation选择执行的表选择执行的表China Datang Corporation选择执行的表选择执行的表点击前面图中的加号按钮后会出现右边的页面。在这个页面中列出了该DB所连接的数据库中，连接用户可见的所有表和视图。选择TEST_A按ok，确定并退出。China Datang Corporation配置配置sql

11、语句语句不作修改时，默认的sql语句为Select * from Test_aChina Datang Corporation配置配置sql语句语句不作修改时，默认的sql语句为Select * from Test_a中间的小窗口显示，该表有三个字段，字段名分别是A、B、C。选中所有的三个字段，如上面的右图选中后的sql语句变成Select A，B，C from Test_aChina Datang Corporation配置配置sql语句语句在选定sql所取得字段后，配置页面中sql语句和相应的其他配置信息发生了变化。China Datang Corporation配置配置sql语句语句当前

12、配置下执行的sql语句4个分页分别是所选字段别名和排序、where字句、分组、havine字句。通过这些简单的页面就可以写出简单的sql语句。China Datang CorporationSelect语句完成语句完成假定不需要做其他的修改，点击OK，确认并退出。China Datang Corporation选择执行方式选择执行方式几乎所有的组件都有两种执行方式。Publish resultsScheduler分别对应于一般的方式和按一定的计划执行。选择Scheduler按照计划执行。点击Next进入下一页面。China Datang Corporation退出退出sql配置页面配置页面按F

13、inish退出sql配置页面China Datang Corporation第一例第一例 数据传输数据传输配置执行方式China Datang Corporation退出退出sql配置页面配置页面完成sql配置后，按next进入配置执行方式的页面。China Datang Corporation配置执行方式只有在前面选择执行方式时选择Scheduler才能配置这个页面。China Datang Corporation选择执行时间间隔每10秒钟执行一次。China Datang Corporation选择执行次数只执行1次。去掉Infinite times前面的勾，否则表示执行无数次。China

14、 Datang Corporation确定执行次数在Number of polls中写入需要执行的次数。China Datang Corporation完成执行方式配置按Next进入异常处理页面。China Datang Corporation异常处理异常处理，使用默认方式。按Finish完成DB组件的配置。China Datang Corporation第一例第一例 数据传输数据传输配置第二个DB组件China Datang Corporation配置数据库连接为了范例的方便，连接的数据库还是10.81.12.99。China Datang Corporation配置sql语句China D

15、atang Corporation配置sql语句写入数据使用Insert语句。China Datang Corporation配置sql语句选择写入数据的表格Test_bChina Datang Corporation配置sql语句默认为写入所有字段。表Test_b下面共有4个字段。其中Sdate有默认值sysdate即数据库当前时间。China Datang Corporation配置sql语句在insert中去掉Sdate字段。按照这样的sql语句执行组件，组件将不会对Sdate提供数值，数据库将给sdate字段附以默认值。China Datang Corporation选择默认的执行方式

16、默认的执行方式，即Publish Results当组件接收到数据时将会执行相关的操作。China Datang Corporation执行方式页面不可用China Datang Corporation异常处理异常处理，使用默认方式。按Finish完成DB组件的配置。China Datang Corporation第一例第一例 数据传输数据传输配置数据库间的连接China Datang Corporation配置组件连接配置好两个组件后的主页面：通常情况下可以通过鼠标选择某个组件或是连接。需要建立组件间的连接时，首先需要改变鼠标的操作方式。在启停程序的快捷按钮的左侧有两个按钮，分别表示鼠标为拾取

17、实体或是建立组件间的连接。点击右边的按钮后，就可以在组件间拖线，来建立联系。China Datang Corporation配置组件连接鼠标放到DB1组件的出口OUT_PORT处按住鼠标左键不放此时拖动鼠标将会出现一条线。将这条线拖到DB2的入口处，放开鼠标左键。此时就在DB1和DB2间建立了连接。China Datang Corporation配置组件连接在通过上面的快捷按钮将鼠标换成拾取实体的方式。上图线的颜色表示连接还没有配置。需要配置连接。直接双击连接线，就可以配置连接。注意：并不是所有的组件间的连接都需要配置。China Datang Corporation配置组件连接双击连接线。提

18、示是否使用Mapper配置连接。按是调出工具Mapper。China Datang Corporation配置组件连接按是调出工具Mapper在工具Mapper的左边是DB1组件的出口，即sql语句select_data的三个结果集属性。右侧为DB2的入口，即sql语句insert的三个写入数据的列。China Datang Corporation配置组件连接将select_data得到的数据传递给insert。在select_data处按鼠标左键，直接拖到ZERO MANY。China Datang Corporation配置组件连接将select_data得到的结果集属性A、B、C分别传递

19、给insert的列A、B、C。China Datang Corporation配置组件连接上面的操作将DB1组件中sqlselect_data得到的纪录送到了DB2组件的sql insert，并且select_data得到的结果集的属性A、B、C分别传递给insert需要的列A、B、C。Mapper工具有一个按钮可以用来确认刚才的操作是否正确。确认所作的操作是否正确。确认后消息框中提示正确。China Datang Corporation配置组件连接保存所作的操作。或者是退出时提示保存。China Datang Corporation配置组件连接保存后退出Mapper，组件间的数据传输将按照刚

20、才的配置传输数据。下图为配置好连接的程序。注意：将某个sql的结果集拖线给目标集是，并不是直接将线拖到对应的目标集，而是对应的ZERO MANY。这条线并非必须，如果没有这条线表示一批数据假如有100条纪录只有第一条纪录可以传输给目标集。如果有这条线那么所有的纪录都将被传输到目标集中。China Datang Corporation第一例第一例 数据传输数据传输程序运行China Datang Corporation选择运行的节点DB1和DB2均选择节点fps99。China Datang Corporation命名组件和连接为了方便命名组件和连接。China Datang Corporation命名组件和连接命名后的组件和连接DB1：取数据DB2：存数据连接：数据传输China Datang Corporation运行程序运行China Datang Corporation查看运行的结果数据已经写入