1、China Datang Corporation中国大唐集团公司中国大唐集团公司数据共享平台项目建设数据共享平台项目建设视频培训会视频培训会 第1页，共82页。China Datang Corporation第八课第八课 编写简单的程序编写简单的程序第2页，共82页。China Datang Corporation本课内容本课内容 编写简单的程序第3页，共82页。China Datang Corporation上周回顾上周回顾第4页，共82页。China Datang CorporationFEPO启动启动Fiorano提供工具FEPO编写程序、查看程序的状态和对程序进行启停管理。从上到下分别
2、输入服务器连接地址用户名密码第5页，共82页。China Datang CorporationFEPO登陆后的页面登陆后的页面第6页，共82页。China Datang Corporation查询程序查询程序左侧的程序浏览窗口分为两部分。正在运行的程序：Running Event Processes所有程序：Event Process Repository 点击Running Event Processes可以查询目前正在运行的程序。双击Running Event Processeshe和Event Process Repository下面的任何程序，可以调出程序的页面。第7页，共82页。Ch
3、ina Datang Corporation程序的状态程序的状态程序有两种状态，黑色的表示不在运行，红色或是绿色的表示正在运行。组件则有三种状态。第8页，共82页。China Datang Corporation程序的导入导出程序的导入导出通过菜单中的File和快捷按钮中可以把fiorano程序导出成文件，或是把程序导入到系统中。第9页，共82页。China Datang Corporation指定组件运行的节点指定组件运行的节点新编和新导入的程序需要先指定运行的节点，才能运行。方法是先选择组件，然后通过左边的属性页面中的Node Name属性进行修改。第10页，共82页。China Data
4、ng Corporation程序的启停管理程序的启停管理Fiorano中的程序可以通过菜单中的Actions或是快捷按钮启动和停止程序。通过三角形的按钮（Launch），可以将程序运行起来。新编程序在运行前可能需要检查节点（Connectivity）。第11页，共82页。China Datang Corporation组件的启停管理组件的启停管理程序启动后，FES向相关的FPS发出程序的启动命令，组件开始在FPS运行。FPEO可以停止单个组件或是所有组件的运行，也可以向单个没有启动成功的组件，发出启动命令。启停单个组件时需要先选中组件。第12页，共82页。China Datang Corpor
5、ation编写简单的程序编写简单的程序第13页，共82页。China Datang Corporation新建程序新建程序当我们调出一个程序后，在FEPO的主面板中就会显示该程序的内容。编程前需要调出一个空白的面板或者说新建一个空白的程序。通过菜单中的file和快捷按钮可以实现这一功能。其实新建程序只不过是清理出一个空白的主面板，供编程使用。第14页，共82页。China Datang Corporation设计程序设计程序在编写程序前首先需要设计程序。确定需要使用哪几种组件。每一种组件需要多少个。每一个组件需要实现的功能。第15页，共82页。China Datang Corporation第
6、一例第一例 数据传输数据传输第16页，共82页。China Datang Corporation第一例第一例 数据传输数据传输程序设计第17页，共82页。China Datang Corporation数据的简单传输数据的简单传输首先看一下最简单的一个例子：在相同的数据库，相同的表结构间的数据的传输。程序设计如下：使用的组件：DBDB组件使用的个数：2个第一个DB组件作用：从源数据库取数据；第二个组件的作用：是把数据保存到目的数据库。第18页，共82页。China Datang Corporation取得需要的组件取得需要的组件直接从组件面板中将DB组件拖到主面板中。DB组件的位置，组件面板-
7、DB-DB主面板中就有了两个DB组件。第19页，共82页。China Datang Corporation配置组件配置组件DB1假定DB1的作用是取数据。双击DB1组件，提示正在打开配置页面，可以通过cancel取消刚才的操作。第20页，共82页。China Datang Corporation第一例第一例 数据传输数据传输配置数据库连接第21页，共82页。China Datang Corporation配置组件配置组件DB1打开后的配置页面。第一页数据库连接配置。第22页，共82页。China Datang Corporation配置组件配置组件DB1需要配置的参数：Database：选择数
8、据库类型Driver：数据库驱动程序URL：该驱动下的连接参数User name：数据库用户名Password：数据库密码第23页，共82页。China Datang Corporation选择数据库类型选择数据库类型选择类型为Oracle第24页，共82页。China Datang Corporation配置配置URL驱动程序使用默认。不同驱动的url格式不同。默认的URL如下jdbc:oracle:thin:HostName:1521:orclHostName数据库服务器主机名或是IP1521：oracle端口，默认为1521orcl：oracle的Sid连接10.81.12.99上的数据
9、库将HostName改为10.81.12.99Sid为datangjdbc:oracle:thin:10.81.12.99:1521:datang第25页，共82页。China Datang Corporation配置配置URL第26页，共82页。China Datang Corporation指定用户名和密码指定用户名和密码数据库用户名/密码datang/datang第27页，共82页。China Datang Corporation测试数据库连接测试数据库连接使用右下角的Test测试数据库连接。第28页，共82页。China Datang Corporation测试数据库连接测试数据库连接
10、测试显示数据库连接成功。第29页，共82页。China Datang Corporation完成连接配置完成连接配置按NEXT到下一页第30页，共82页。China Datang Corporation第一例第一例 数据传输数据传输编写sql语句第31页，共82页。China Datang CorporationSQL配置配置配置组件执行的sql点击SQL configuration调出SQL配置页面第32页，共82页。China Datang CorporationSQL配置配置该页面下包含sql配置和高级属性两个分页面。第33页，共82页。China Datang Corporation添
11、加添加sql语句语句第34页，共82页。China Datang Corporation添加添加sql语句语句选择Select后调出右边写sql语句的窗口。第35页，共82页。China Datang Corporation命名执行的操作命名执行的操作一个DB组件可以执行多个sql语句，每个sql语句都需要命名以加以区分。第36页，共82页。China Datang Corporation选择执行的表选择执行的表第37页，共82页。China Datang Corporation选择执行的表选择执行的表点击前面图中的加号按钮后会出现右边的页面。在这个页面中列出了该DB所连接的数据库中，连接用户
12、可见的所有表和视图。选择TEST_A按ok，确定并退出。第38页，共82页。China Datang Corporation配置配置sql语句语句不作修改时，默认的sql语句为Select*from Test_a第39页，共82页。China Datang Corporation配置配置sql语句语句不作修改时，默认的sql语句为Select*from Test_a中间的小窗口显示，该表有三个字段，字段名分别是A、B、C。选中所有的三个字段，如上面的右图选中后的sql语句变成Select A，B，C from Test_a第40页，共82页。China Datang Corporation配置
13、配置sql语句语句在选定sql所取得字段后，配置页面中sql语句和相应的其他配置信息发生了变化。第41页，共82页。China Datang Corporation配置配置sql语句语句当前配置下执行的sql语句4个分页分别是所选字段别名和排序、where字句、分组、havine字句。通过这些简单的页面就可以写出简单的sql语句。第42页，共82页。China Datang CorporationSelect语句完成语句完成假定不需要做其他的修改，点击OK，确认并退出。第43页，共82页。China Datang Corporation选择执行方式选择执行方式几乎所有的组件都有两种执行方式。P
14、ublish resultsScheduler分别对应于一般的方式和按一定的计划执行。选择Scheduler按照计划执行。点击Next进入下一页面。第44页，共82页。China Datang Corporation退出退出sql配置页面配置页面按Finish退出sql配置页面第45页，共82页。China Datang Corporation第一例第一例 数据传输数据传输配置执行方式第46页，共82页。China Datang Corporation退出退出sql配置页面配置页面完成sql配置后，按next进入配置执行方式的页面。第47页，共82页。China Datang Corporat
15、ion配置执行方式只有在前面选择执行方式时选择Scheduler才能配置这个页面。第48页，共82页。China Datang Corporation选择执行时间间隔每10秒钟执行一次。第49页，共82页。China Datang Corporation选择执行次数只执行1次。去掉Infinite times前面的勾，否则表示执行无数次。第50页，共82页。China Datang Corporation确定执行次数在Number of polls中写入需要执行的次数。第51页，共82页。China Datang Corporation完成执行方式配置按Next进入异常处理页面。第52页，共8
16、2页。China Datang Corporation异常处理异常处理，使用默认方式。按Finish完成DB组件的配置。第53页，共82页。China Datang Corporation第一例第一例 数据传输数据传输配置第二个DB组件第54页，共82页。China Datang Corporation配置数据库连接为了范例的方便，连接的数据库还是10.81.12.99。第55页，共82页。China Datang Corporation配置sql语句第56页，共82页。China Datang Corporation配置sql语句写入数据使用Insert语句。第57页，共82页。China
17、Datang Corporation配置sql语句选择写入数据的表格Test_b第58页，共82页。China Datang Corporation配置sql语句默认为写入所有字段。表Test_b下面共有4个字段。其中Sdate有默认值sysdate即数据库当前时间。第59页，共82页。China Datang Corporation配置sql语句在insert中去掉Sdate字段。按照这样的sql语句执行组件，组件将不会对Sdate提供数值，数据库将给sdate字段附以默认值。第60页，共82页。China Datang Corporation选择默认的执行方式默认的执行方式，即Publis
18、h Results当组件接收到数据时将会执行相关的操作。第61页，共82页。China Datang Corporation执行方式页面不可用第62页，共82页。China Datang Corporation异常处理异常处理，使用默认方式。按Finish完成DB组件的配置。第63页，共82页。China Datang Corporation第一例第一例 数据传输数据传输配置数据库间的连接第64页，共82页。China Datang Corporation配置组件连接配置好两个组件后的主页面：通常情况下可以通过鼠标选择某个组件或是连接。需要建立组件间的连接时，首先需要改变鼠标的操作方式。在启停
19、程序的快捷按钮的左侧有两个按钮，分别表示鼠标为拾取实体或是建立组件间的连接。点击右边的按钮后，就可以在组件间拖线，来建立联系。第65页，共82页。China Datang Corporation配置组件连接鼠标放到DB1组件的出口OUT_PORT处按住鼠标左键不放此时拖动鼠标将会出现一条线。将这条线拖到DB2的入口处，放开鼠标左键。此时就在DB1和DB2间建立了连接。第66页，共82页。China Datang Corporation配置组件连接在通过上面的快捷按钮将鼠标换成拾取实体的方式。上图线的颜色表示连接还没有配置。需要配置连接。直接双击连接线，就可以配置连接。注意：并不是所有的组件间的
20、连接都需要配置。第67页，共82页。China Datang Corporation配置组件连接双击连接线。提示是否使用Mapper配置连接。按是调出工具Mapper。第68页，共82页。China Datang Corporation配置组件连接按是调出工具Mapper在工具Mapper的左边是DB1组件的出口，即sql语句select_data的三个结果集属性。右侧为DB2的入口，即sql语句insert的三个写入数据的列。第69页，共82页。China Datang Corporation配置组件连接将select_data得到的数据传递给insert。在select_data处按鼠标左
21、键，直接拖到ZERO MANY。第70页，共82页。China Datang Corporation配置组件连接将select_data得到的结果集属性A、B、C分别传递给insert的列A、B、C。第71页，共82页。China Datang Corporation配置组件连接上面的操作将DB1组件中sqlselect_data得到的纪录送到了DB2组件的sql insert，并且select_data得到的结果集的属性A、B、C分别传递给insert需要的列A、B、C。Mapper工具有一个按钮可以用来确认刚才的操作是否正确。确认所作的操作是否正确。确认后消息框中提示正确。第72页，共82
22、页。China Datang Corporation配置组件连接保存所作的操作。或者是退出时提示保存。第73页，共82页。China Datang Corporation配置组件连接保存后退出Mapper，组件间的数据传输将按照刚才的配置传输数据。下图为配置好连接的程序。注意：将某个sql的结果集拖线给目标集是，并不是直接将线拖到对应的目标集，而是对应的ZERO MANY。这条线并非必须，如果没有这条线表示一批数据假如有100条纪录只有第一条纪录可以传输给目标集。如果有这条线那么所有的纪录都将被传输到目标集中。第74页，共82页。China Datang Corporation第一例第一例 数
23、据传输数据传输程序运行第75页，共82页。China Datang Corporation选择运行的节点DB1和DB2均选择节点fps99。第76页，共82页。China Datang Corporation命名组件和连接为了方便命名组件和连接。第77页，共82页。China Datang Corporation命名组件和连接命名后的组件和连接DB1：取数据DB2：存数据连接：数据传输第78页，共82页。China Datang Corporation运行程序运行第79页，共82页。China Datang Corporation查看运行的结果数据已经写入test_b中。第80页，共82页。C
24、hina Datang Corporation练习在本地的服务器上安装一个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
25、 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 联系电话;第81页，共82页。China Datang Corporation练习在本地数据库的PERSON_B中写入的培训人员的相关纪录，其中每个字段的含义同字段的注释。利用12.99上的fiorano2006编写程序将本地数据库PERSON_B中的数据传输到12.99上面的表PERSON中。注：没有本地oracle数据库的电厂，可以利用12.99上面的数据库操作。第82页，共82页。
