【文章內容簡介】 ema。如果在CUX Schema下反向會導致反向出來Datastore是沒有結構的，如下圖所示，那么在做CUX_MTL_SYSTEM_ITEMS_INIT_V反向之前我們需要建立一個為視圖反向的物理架構和邏輯架構：ERP 。按照ODI開發(fā)要求，還需要創(chuàng)建對應的ERP ，本次案例沒有將其獨立出來。這個案例告訴我們，反向Datastores選擇的物理架構的Schema必須是數(shù)據(jù)源Schema，否則反向會出現(xiàn)上面的問題。反向前準備：CREATE synonym FOR 。CREATE synonym FOR 。建立反向ERP系統(tǒng)視圖的物理架構和邏輯架構(參考ODI架構搭建章節(jié))：ERP ，建立成功后如下圖，Designer\Models\ERP System 右鍵模型ERP ，選擇Edit，(或雙擊模型)選擇Reverse(反向) TAB頁，輸入如下信息，Definition TAB 頁：Reverse TAB 頁：點擊按鈕，稍等片刻，Datastore就反向出來了，如圖所示，l 目標系統(tǒng)的Datastores反向反向前準備：CREATE synonym FOR 。GRANT SELECT,INSERT,UPDATE,DELETE ON TO soau。說明： Datastores反向失敗原因分析 確保待反向的表/視圖是屬于當前Schema(數(shù)據(jù)源)。 確保ODI的Work Schema(SOAU)用戶能訪問到反向數(shù)據(jù)存儲的數(shù)據(jù)源。創(chuàng)建和執(zhí)行接口(Interfaces)ODI接口開發(fā)是ODI開發(fā)的核心?；A接口一般用于ODI數(shù)據(jù)初期導入，運行一次。216。 創(chuàng)建接口Designer\Projects\singTaoMDM\ERPMDM\Interfaces 右鍵Insert Interface輸入如下信息，Definition TAB頁 Name：Diagram TAB頁Flow TAB頁：源系統(tǒng)Datastore選擇默認標準Oracle的LKM:LKM Oracle to Oracle (DBLINK)目標系統(tǒng)Datastore選擇默認標準Oracle的IKM:IKM Oracle Incremental Update其他默認即可。點擊OK，創(chuàng)建接口完成。216。 執(zhí)行接口(Designer\Projects\singTaoMDM\ERPMDM\Interfaces\) 右鍵創(chuàng)建好的接口 選擇Excute執(zhí)行完，去Operator查看執(zhí)行結果同時檢測目標系統(tǒng)數(shù)據(jù)庫數(shù)據(jù)是否導入成功，創(chuàng)建和執(zhí)行過程(Procedures)216。 創(chuàng)建過程Designer\Projects\singTaoMDM\ERPMDM\Procedures 右鍵Insert Procedure輸入如下信息，Definition TAB頁Name：點擊圖上圖標，彈出窗口，輸入如下信息Name：Import itemsSchema：ERP Command：begin 。end。說明：，API是創(chuàng)建在APPS用戶下的，所以上面的Schema選擇ERP 。點擊OK，Procedure創(chuàng)建完成了。216。 執(zhí)行過程(Designer\Projects\singTaoMDM\ERPMDM\Procedures\) 右鍵創(chuàng)建好的過程 選擇Excute執(zhí)行后，切換到Operator查看執(zhí)行結果登錄到目標系統(tǒng)數(shù)據(jù)庫(MDM)查看Product表中是否有需要導入的物料信息。SELECT * FROM mtl_system_items_b。SELECT * FROM mtl_system_items_tl。創(chuàng)建和執(zhí)行包(Packages)將需要一起執(zhí)行的接口、過程放在一起打包，讓ODI依次執(zhí)行。216。 創(chuàng)建包Designer\Projects\singTaoMDM\ERPMDM\Packages 右鍵Insert Package輸入如下信息，Definition TAB頁Name：Diagram TAB 頁選中需要放入包得接口或過程，按住鼠標不放，拖曳到Diagram TAB 頁灰色區(qū)域中，如圖所示用這個方式將接口：：，ODI會默認第一個拖到包中的接口或是程序設為包執(zhí)行的第一步。如果你想設置另外的為第一步執(zhí)行，可以選中你需設置的接口或過程，右鍵 選擇First Step。然后選擇這兩個箭頭，對包中的接口和視圖進行先后順序的連接。注意，連接的順序是包執(zhí)行的順序。圖上表示的是：，；接口執(zhí)行失敗，則執(zhí)行結束，不會執(zhí)行過程了。如果想接口執(zhí)行失敗還繼續(xù)執(zhí)行過程則連接箭頭選擇。點擊OK，包創(chuàng)建完成了。如圖所示216。 執(zhí)行包(Designer\Projects\singTaoMDM\ERPMDM\Packages\) 右鍵創(chuàng)建好的包 選擇Excute執(zhí)行后，切換到Operator查看執(zhí)行結果如果想了解詳細的執(zhí)行結果，可展開Steps查看。創(chuàng)建和執(zhí)行方案(Scenarios)創(chuàng)建方案一般用于接口或過程或包按設定的計劃進行執(zhí)行。這里對包：。過程和接口創(chuàng)建和執(zhí)行方案方式相同。216。 創(chuàng)建方案(Designer\Projects\singTaoMDM\ERPMDM\Packages\) 右鍵需要創(chuàng)建方案的包 選擇 Generate Scenario… 如沒特殊需求，Name和Version的值默認即可。點擊OK，ODI生成了Scenarios文件，展開有剛新建的的Scenario。繼續(xù)展開Scenario：ERP_MDM_IMPORT_ITEMS，右鍵 Insert Scheduling輸入如下信息Definition TAB頁：定義上下文、代理、日志級別、活動期間、執(zhí)行頻率Execution Cycle TAB頁：定義執(zhí)行時的循環(huán)次數(shù)、循環(huán)起始時間、循環(huán)間隔等上圖定義的是每10分鐘執(zhí)行一次。216。 執(zhí)行方案右鍵創(chuàng)建的方案：ERP_MDM_IMPORT_ITEMS，選擇 Execute執(zhí)行成功后，創(chuàng)建方案的包，就會每10分鐘執(zhí)行一次。CDC接口開發(fā)CDC全稱Changed Data Capture，捕獲變化的數(shù)據(jù)。CDC概述CDC捕獲源數(shù)據(jù)的變動情況記錄到日記表，在傳遞數(shù)據(jù)時，只需要依據(jù)日志表中記錄而無需考慮未變動的數(shù)據(jù)，大大提高ELT的效率。日志ODI的CDC由日志記錄來推動，日志是CDC的一部分，用于記錄在數(shù)據(jù)源上改變(insert、delete、update)的數(shù)據(jù)。日志記錄機制包括四種要素Journals、Capture processes、Subscribers、Journalizing views。Journals：日志，存儲變化的數(shù)據(jù)的地方，在關系型數(shù)據(jù)庫中一般指的就是表格。Capture processes：捕獲進程，用來捕獲數(shù)據(jù)源上的數(shù)據(jù)變化并寫入Journals中，通常指的就是觸發(fā)器；也可用數(shù)據(jù)源上可用的專門的捕獲程序（例如支持從數(shù)據(jù)源服務器log獲取數(shù)據(jù)的程序）。Subscribers：訂閱者，記錄的是需要使用CDC數(shù)據(jù)的使用者；只有所有的訂閱者都使用了CDC數(shù)據(jù)后，日志內容才能被清除。Journalizing views：日志查看程序，可用于查看日志內的數(shù)據(jù)內容，并且可獲取CDC數(shù)據(jù)以支持ODI將新數(shù)據(jù)寫入目標數(shù)據(jù)存儲中。設置模型日志(Journalizing)Designer\模型文件(ERP System) \右鍵 模型(ERP ) 選擇Edit，選擇Journalizing TAB頁，設置模型日志，ODI會默認Journalizing Mode為Simple，JKM為JKM Oracle 。沒有特殊需求，這個默認設置可以進行ODI的CDC接口開發(fā)。但是所選取的案例需要注意：源系統(tǒng)(ERP)的Datastore的數(shù)據(jù)源是視圖。默認的JKM Oracle ，是不能滿足我們需求的，本人對這個JKM進行了客戶化，具體客戶化內容詳見KM(只是模塊)基礎章節(jié)，客戶化后JKM為：JKM Oracle 。說明： 簡單（Simple）：通常用于單個Datastore（通常就是代表一個表）。一致性集（Consistent Set）：當一組Datastore采用CDC方式時，為保證數(shù)據(jù)的前后順序和完整性制約關系，我們需要告訴ODI按照一定的順序來抓取，ODI是通過設置Consistency Window來實現(xiàn)的。這樣一組Datastore就叫做Consistent Set。此外，ODI建議，如果Subsriber很多，用Consistent Set有助于提高性能。注：對于一個Datastore來說，Simple和Consistent Set不能同時存在。添加到CDC(Add to CDC)Add to CDC作用是將一個模型標記為可以進行CDC接口開發(fā)的模型。Designer\模型文件(ERP System) \模型(ERP )\右鍵 Datastore(CUX_MTL_SYSTEM_ITEMS_INIT_V)\Changed Data Capture\Add to CDC選擇Add to CDC，刷新之后Datastore變?yōu)榱耍嗔藗€黃色的小時鐘。注：如果Datastore沒有Primary Key，Add to CDC會報錯。所以在Add to CDC之前，查看Datastore是否有Primary Key，沒有則需要創(chuàng)建一個。創(chuàng)建CDC接口的時候此Datastore就可以增加日志字段了。如下圖所示，如果Datastore沒有Add to CDC，上圖紅色框部分是灰色的，不可選擇。添加訂閱者(Subscriber(s))添加訂閱者意義在于對數(shù)據(jù)源記錄進行insert、delete、update操作時，會給訂閱者一條對應的操作記錄，ODI會依據(jù)Datastores的訂閱者信息捕獲對應數(shù)據(jù)，對目標數(shù)據(jù)源進行一致的操作。Designer\模型文件(ERP System) \模型(ERP )\右鍵 Datastore(CUX_MTL_SYSTEM_ITEMS_INIT_V)\Changed Data Capture\Subscriber\ Subscriber(s)輸入訂閱者信息，點擊OK，點擊OK，進入組件Operator查看添加訂閱者是否成功。表示添加訂閱者執(zhí)行成功。附：不妨來了解添加訂閱者這個操作，ODI做了些什么？展開核心步驟是3和4步，雙擊3，會發(fā)現(xiàn)ODI在Work Schema(SOAU)下創(chuàng)建一個訂閱者表：。表示警告：name is already used by an existing object。我們可以推測，ODI的SOAU工作架構下，所有的訂閱者都存放在這個表中(其實ODI就是將所有訂閱者存放在這個表中)。步驟4