【正文】 KM：完成從源系統(tǒng)和目標(biāo)系統(tǒng)的數(shù)據(jù)結(jié)構(gòu)的反向工程來形成數(shù)據(jù)模型的功能。Designer：是ODI開發(fā)的主要組件，創(chuàng)建和執(zhí)行DataStores、Interfaces、Procedure、Packages，客戶化KM等操作Operator：管理和監(jiān)控數(shù)據(jù)轉(zhuǎn)換任務(wù)的執(zhí)行情況，可用于調(diào)試。 注：如有錯誤或疑問，請大家歡迎提出和指正。主要是對ODI開發(fā)進行一次總結(jié)，描述對ODI技術(shù)開發(fā)的認(rèn)識和了解。1．MDM項目業(yè)務(wù)認(rèn)識：集中對數(shù)據(jù)進行管理，數(shù)據(jù)標(biāo)準(zhǔn)化，流程固化。ODI組件ODI主要是以下組件組成的：資料庫(Repository)：Master Repository、Work Repository。動態(tài)接口用于數(shù)據(jù)維護，是實時性的。 SKM：完成ODI和WEB服務(wù)接口的功能。grant connect,resource to soau。通常創(chuàng)建一個即可。 grant connect, resource to soam。更多用戶安全管理設(shè)置可參閱：l 創(chuàng)建工作資料庫(Work Repository) ERP 創(chuàng)建Work Repository用戶create user soaw identified by soaw default tablespace users。當(dāng)執(zhí)行ODI接口時，ODI會根據(jù)源數(shù)據(jù)服務(wù)器的Instance/，如果匹配成功，ODI會自動根據(jù)TNS信息與源數(shù)據(jù)庫之間創(chuàng)建DBLINK；如果匹配不成功，表示沒有明確DBLINK建立對象，DBLINK創(chuàng)建后無法正常連接，導(dǎo)致ODI接口執(zhí)行會拋出錯誤信息：TNS:could not resolve the connect identifier specified所以輸入Instance/dblink(Data Server)信息前。點擊OK按鈕，會出現(xiàn)一個警告(提示需要指定上行文，因為邏輯架構(gòu)還沒創(chuàng)建，可以先忽略)，點擊OK物理架構(gòu)的創(chuàng)建就完成了。創(chuàng)建邏輯代理Topology Manager\Logical Architecture\Agents\右鍵\Insert Logical Agent輸入如下信息：Name：FP Agent Physical Agents選擇FP Agent點擊OK，邏輯代理創(chuàng)建完成。因為暫時ERP測試環(huán)境沒有代理服務(wù)器，也沒有創(chuàng)建代理服務(wù)器的權(quán)限。當(dāng)然也可以更細(xì)或更廣的劃分，比如在青啤正式的ODI開發(fā)中，所有的ODI開發(fā)都放在TSINGTAO里面，并沒有很細(xì)的劃分；而在《Oracle Data Integrator應(yīng)用指南》中，直接用ORCL_DEMO的ODI開發(fā)作為Project，劃分得很細(xì)。此章節(jié)描述了標(biāo)準(zhǔn)反向，客戶化反向涉及了RKM，將在KM(知識模塊)基礎(chǔ)章節(jié)RKM中進行詳細(xì)的說明。建立反向ERP系統(tǒng)視圖的物理架構(gòu)和邏輯架構(gòu)(參考ODI架構(gòu)搭建章節(jié))：ERP ，建立成功后如下圖，Designer\Models\ERP System 右鍵模型ERP ，選擇Edit，(或雙擊模型)選擇Reverse(反向) TAB頁，輸入如下信息，Definition TAB 頁：Reverse TAB 頁：點擊按鈕，稍等片刻，Datastore就反向出來了，如圖所示，l 目標(biāo)系統(tǒng)的Datastores反向反向前準(zhǔn)備：CREATE synonym FOR 。點擊OK，創(chuàng)建接口完成。 執(zhí)行過程(Designer\Projects\singTaoMDM\ERPMDM\Procedures\) 右鍵創(chuàng)建好的過程 選擇Excute執(zhí)行后，切換到Operator查看執(zhí)行結(jié)果登錄到目標(biāo)系統(tǒng)數(shù)據(jù)庫(MDM)查看Product表中是否有需要導(dǎo)入的物料信息。注意，連接的順序是包執(zhí)行的順序。過程和接口創(chuàng)建和執(zhí)行方案方式相同。CDC概述CDC捕獲源數(shù)據(jù)的變動情況記錄到日記表，在傳遞數(shù)據(jù)時，只需要依據(jù)日志表中記錄而無需考慮未變動的數(shù)據(jù)，大大提高ELT的效率。沒有特殊需求，這個默認(rèn)設(shè)置可以進行ODI的CDC接口開發(fā)。添加到CDC(Add to CDC)Add to CDC作用是將一個模型標(biāo)記為可以進行CDC接口開發(fā)的模型。表示添加訂閱者執(zhí)行成功。特別說明： 啟動日志會刪掉當(dāng)前Datastore所有的日志數(shù)據(jù)，相當(dāng)于初始化了該Datastore的日志。點擊OK保存，CDC接口創(chuàng)建完成。點擊，然后進入Operator查看ODI是如何反向Datastores的。Subscriber224。SOAU39。但是經(jīng)過測試發(fā)現(xiàn)，只有對視圖進行Insert、Update、Delete操作ODI才會寫入日志，而對視圖關(guān)聯(lián)的表進行操作卻不能觸發(fā)觸發(fā)器。Models的CKM檢查靜態(tài)數(shù)據(jù)一致性：通過設(shè)立約束條件，可以清洗、過濾數(shù)據(jù)，只按需集成數(shù)據(jù)。如下圖所示通過對這些步驟的源碼了解和執(zhí)行結(jié)果，LKM Oracle to Oracle (DBLINK) 主要步驟：其他LKM可類似理解。下面對IKM進行詳細(xì)的說明。 SIZE 32M AUTOEXTEND ON NEXT 32M MAXSIZE 2048M EXTENT MANAGEMENT LOCAL SEGMENT SPACE MANAGEMENT AUTO。附錄II：觸發(fā)器腳本 T$CUX_MTL_SYSTEM_ITEMS_INIT_Vcreate or replace trigger T$CUX_MTL_SYSTEM_ITEMS_INIT_V instead of insert or update or delete on for each row declare V_FLAG VARCHAR(1)。 if updating then V_INVENTORY_ITEM_ID := :。D39。) */ 。 Create the list of Tablesname linked TO VIEWlstTbs = []indexs = 0 CREATE the statementscStmt = () Execute for RECORD each tablenamers = (getTbsCmd)while (()): ((REFERENCED_NAME)) indexs = indexs + 1 CLOSE statements() Commit the updates() Drop trigger (重寫) Technology: JythondropTriCmd = drop trigger %=(JRN_FULL_TRIGGER)%miss_index Create the statementdropStmt = () Drop triggersinx = 1triname = 39。I39。D39。) */ 。, tbs) (triggerCmdTemp) ()myStmt = None Commit, just in case()更改歷史。 Create the statementmyStmt = () Execute the trigger creationinx = 1triname = 39。 insert into %=(JRN_FULL_NAME)% ( JRN_SUBSCRIBER, JRN_CONSUMED, JRN_FLAG, JRN_DATE, %=(, [COL_NAME], ,\n\t\t, , PK)% ) select JRN_SUBSCRIBER, 39。 if updating then %=(, V_[COL_NAME] := :new.[COL_NAME]。for tbs in lstTbs: if indexs 1: triname = _%d %inx inx = inx + 1 dropTriCmdTemp = (39。附錄III：JKM客戶化圖： Initialize Tablenames (新增) Technology: JythongetTbsCmd = select REFERENCED_NAME from DBA_DEPENDENCIES where TYPE = 39。 insert into $CUX_MTL_SYSTEM_ITEMS_INIT_V ( JRN_SUBSCRIBER, JRN_CONSUMED, JRN_FLAG, JRN_DATE, INVENTORY_ITEM_ID, ORGANIZATION_ID ) select JRN_SUBSCRIBER, 39。 V_FLAG := 39。 V_ORGANIZATION_ID NUMBER(22)。/demofs/oraDB/erpdata/39。IKM是比較復(fù)雜的KM，下面對IKM：IKM Oracle Incremental Update主要的步驟進行簡要的說明： 在ODI臨時區(qū)先Drop后Create臨時表I$； 在臨時I$表中插入流轉(zhuǎn)數(shù)據(jù)； 回收之前未成功導(dǎo)入的數(shù)據(jù)； 執(zhí)行CKM進行數(shù)據(jù)質(zhì)量檢測； 設(shè)置I$表中需要更新的數(shù)據(jù)標(biāo)識為’U’； 設(shè)置I$表中無用數(shù)據(jù)標(biāo)識為’N’； 在數(shù)據(jù)導(dǎo)入目標(biāo)系統(tǒng)之前備份目標(biāo)數(shù)據(jù)。%=(SRC_DSERV_NAME)%39。 在接口(Interfaces)中添加CKMDesigner\Projects\singTaoMDM\ERPMDM\Interfaces\ 右鍵 選擇EditODI默認(rèn)的CKM是：CKM Oracle。此處只是演示一下JKM的客戶化。%CUX_MTL_SYSTEM_ITEMS_INIT_V%39。解決方案：替換觸發(fā)器可以建立在多表視圖上，我們需要客戶化這個JKM，修改Step11的Create trigger源碼。其實Get XXX步驟都是為Datastore的結(jié)構(gòu)進行設(shè)計。為了驗證CDC接口的執(zhí)行準(zhǔn)確，對源系統(tǒng)數(shù)據(jù)源進行修改，添加默認(rèn)采購員BEST_JULIE。 啟動日志之前需要考慮：如果待啟動日志的Datastore是首次啟動日志操作，啟動日志是必須的，無需考慮日志數(shù)據(jù)的丟失；如果不是首次，表示之前已做過啟動日志操作，只要添加訂閱者即可，無需再次啟動日志。表示警告：name is already used by an existing object。注：如果Da