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