Fiorano培訓材料 第08課：編寫簡單的程序

1、China Datang Corporation中國大唐集團公司中國大唐集團公司數據共享平臺項目建設數據共享平臺項目建設視頻培訓會視頻培訓會 China Datang Corporation第八課第八課 編寫簡單的程序編寫簡單的程序China Datang Corporation本課內容本課內容 編寫簡單的程序China Datang Corporation上周回顧上周回顧China Datang CorporationFEPO啟動啟動Fiorano提供工具FEPO編寫程序、查看程序的狀態(tài)和對程序進行啟停管理。從上到下分別輸入服務器連接地址用戶名密碼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程序的狀態(tài)程序的狀態(tài)程序有兩種狀態(tài)，黑色的表示不在運行，紅色或是綠色的表示正在運行

3、。組件則有三種狀態(tài)。China Datang Corporation程序的導入導出程序的導入導出通過菜單中的File和快捷按鈕中可以把fiorano程序導出成文件，或是把程序導入到系統(tǒng)中。China Datang Corporation指定組件運行的節(jié)點指定組件運行的節(jié)點新編和新導入的程序需要先指定運行的節(jié)點，才能運行。方法是先選擇組件，然后通過左邊的屬性頁面中的Node Name屬性進行修改。China Datang Corporation程序的啟停管理程序的啟停管理Fiorano中的程序可以通過菜單中的Actions或是快捷按鈕啟動和停止程序。通過三角形的按鈕（Launch），可以將程序運

4、行起來。新編程序在運行前可能需要檢查節(jié)點（Connectivity）。China Datang Corporation組件的啟停管理組件的啟停管理程序啟動后，FES向相關的FPS發(fā)出程序的啟動命令，組件開始在FPS運行。FPEO可以停止單個組件或是所有組件的運行，也可以向單個沒有啟動成功的組件，發(fā)出啟動命令。啟停單個組件時需要先選中組件。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配置配置配置組件執(zhí)行的sql點擊SQL configuration調出SQL配置頁面China Datang CorporationSQL配置配置該頁面下包含sql配置和高級屬性兩個分頁面。China Datang Corporation添加添加sql語句語句China Dat

10、ang Corporation添加添加sql語句語句選擇Select后調出右邊寫sql語句的窗口。China Datang Corporation命名執(zhí)行的操作命名執(zhí)行的操作一個DB組件可以執(zhí)行多個sql語句，每個sql語句都需要命名以加以區(qū)分。China Datang Corporation選擇執(zhí)行的表選擇執(zhí)行的表China Datang Corporation選擇執(zhí)行的表選擇執(zhí)行的表點擊前面圖中的加號按鈕后會出現右邊的頁面。在這個頁面中列出了該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語句和相應的其他配置信息發(fā)生了變化。China Datang Corporation配置配置sql語句語句當前

12、配置下執(zhí)行的sql語句4個分頁分別是所選字段別名和排序、where字句、分組、havine字句。通過這些簡單的頁面就可以寫出簡單的sql語句。China Datang CorporationSelect語句完成語句完成假定不需要做其他的修改，點擊OK，確認并退出。China Datang Corporation選擇執(zhí)行方式選擇執(zhí)行方式幾乎所有的組件都有兩種執(zhí)行方式。Publish resultsScheduler分別對應于一般的方式和按一定的計劃執(zhí)行。選擇Scheduler按照計劃執(zhí)行。點擊Next進入下一頁面。China Datang Corporation退出退出sql配置頁面配置頁面按F

13、inish退出sql配置頁面China Datang Corporation第一例第一例 數據傳輸數據傳輸配置執(zhí)行方式China Datang Corporation退出退出sql配置頁面配置頁面完成sql配置后，按next進入配置執(zhí)行方式的頁面。China Datang Corporation配置執(zhí)行方式只有在前面選擇執(zhí)行方式時選擇Scheduler才能配置這個頁面。China Datang Corporation選擇執(zhí)行時間間隔每10秒鐘執(zhí)行一次。China Datang Corporation選擇執(zhí)行次數只執(zhí)行1次。去掉Infinite times前面的勾，否則表示執(zhí)行無數次。China

14、 Datang Corporation確定執(zhí)行次數在Number of polls中寫入需要執(zhí)行的次數。China Datang Corporation完成執(zhí)行方式配置按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語句執(zhí)行組件，組件將不會對Sdate提供數值，數據庫將給sdate字段附以默認值。China Datang Corporation選擇默認的執(zhí)行方式

16、默認的執(zhí)行方式，即Publish Results當組件接收到數據時將會執(zhí)行相關的操作。China Datang Corporation執(zhí)行方式頁面不可用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配置組件連接保存所作的操作?；蛘呤峭顺鰰r提示保存。China Datang Corporation配置組件連接保存后退出Mapper，組件間的數據傳輸將按照剛

20、才的配置傳輸數據。下圖為配置好連接的程序。注意：將某個sql的結果集拖線給目標集是，并不是直接將線拖到對應的目標集，而是對應的ZERO MANY。這條線并非必須，如果沒有這條線表示一批數據假如有100條紀錄只有第一條紀錄可以傳輸給目標集。如果有這條線那么所有的紀錄都將被傳輸到目標集中。China Datang Corporation第一例第一例 數據傳輸數據傳輸程序運行China Datang Corporation選擇運行的節(jié)點DB1和DB2均選擇節(jié)點fps99。China Datang Corporation命名組件和連接為了方便命名組件和連接。China Datang Corporation命名組件和連接命名后的組件和連接DB1：取數據DB2：存數據連接：數據傳輸China Datang Corporation運行程序運行China Datang Corporation查看運行的結果數據已經寫入