【正文】 KM：完成從源系統(tǒng)和目標(biāo)系統(tǒng)的數(shù)據(jù)結(jié)構(gòu)的反向工程來(lái)形成數(shù)據(jù)模型的功能。Designer：是ODI開發(fā)的主要組件，創(chuàng)建和執(zhí)行DataStores、Interfaces、Procedure、Packages，客戶化KM等操作Operator：管理和監(jiān)控?cái)?shù)據(jù)轉(zhuǎn)換任務(wù)的執(zhí)行情況，可用于調(diào)試。 注：如有錯(cuò)誤或疑問(wèn)，請(qǐng)大家歡迎提出和指正。主要是對(duì)ODI開發(fā)進(jìn)行一次總結(jié)，描述對(duì)ODI技術(shù)開發(fā)的認(rèn)識(shí)和了解。1．MDM項(xiàng)目業(yè)務(wù)認(rèn)識(shí)：集中對(duì)數(shù)據(jù)進(jìn)行管理，數(shù)據(jù)標(biāo)準(zhǔn)化，流程固化。ODI組件ODI主要是以下組件組成的：資料庫(kù)(Repository)：Master Repository、Work Repository。動(dòng)態(tài)接口用于數(shù)據(jù)維護(hù)，是實(shí)時(shí)性的。 SKM：完成ODI和WEB服務(wù)接口的功能。grant connect,resource to soau。通常創(chuàng)建一個(gè)即可。 grant connect, resource to soam。更多用戶安全管理設(shè)置可參閱：l 創(chuàng)建工作資料庫(kù)(Work Repository) ERP 創(chuàng)建Work Repository用戶create user soaw identified by soaw default tablespace users。當(dāng)執(zhí)行ODI接口時(shí)，ODI會(huì)根據(jù)源數(shù)據(jù)服務(wù)器的Instance/，如果匹配成功，ODI會(huì)自動(dòng)根據(jù)TNS信息與源數(shù)據(jù)庫(kù)之間創(chuàng)建DBLINK；如果匹配不成功，表示沒(méi)有明確DBLINK建立對(duì)象，DBLINK創(chuàng)建后無(wú)法正常連接，導(dǎo)致ODI接口執(zhí)行會(huì)拋出錯(cuò)誤信息：TNS:could not resolve the connect identifier specified所以輸入Instance/dblink(Data Server)信息前。點(diǎn)擊OK按鈕，會(huì)出現(xiàn)一個(gè)警告(提示需要指定上行文，因?yàn)檫壿嫾軜?gòu)還沒(méi)創(chuàng)建，可以先忽略)，點(diǎn)擊OK物理架構(gòu)的創(chuàng)建就完成了。創(chuàng)建邏輯代理Topology Manager\Logical Architecture\Agents\右鍵\Insert Logical Agent輸入如下信息：Name：FP Agent Physical Agents選擇FP Agent點(diǎn)擊OK，邏輯代理創(chuàng)建完成。因?yàn)闀簳r(shí)ERP測(cè)試環(huán)境沒(méi)有代理服務(wù)器，也沒(méi)有創(chuàng)建代理服務(wù)器的權(quán)限。當(dāng)然也可以更細(xì)或更廣的劃分，比如在青啤正式的ODI開發(fā)中，所有的ODI開發(fā)都放在TSINGTAO里面，并沒(méi)有很細(xì)的劃分；而在《Oracle Data Integrator應(yīng)用指南》中，直接用ORCL_DEMO的ODI開發(fā)作為Project，劃分得很細(xì)。此章節(jié)描述了標(biāo)準(zhǔn)反向，客戶化反向涉及了RKM，將在KM(知識(shí)模塊)基礎(chǔ)章節(jié)RKM中進(jìn)行詳細(xì)的說(shuō)明。建立反向ERP系統(tǒng)視圖的物理架構(gòu)和邏輯架構(gòu)(參考ODI架構(gòu)搭建章節(jié))：ERP ，建立成功后如下圖，Designer\Models\ERP System 右鍵模型ERP ，選擇Edit，(或雙擊模型)選擇Reverse(反向) TAB頁(yè)，輸入如下信息，Definition TAB 頁(yè)：Reverse TAB 頁(yè)：點(diǎn)擊按鈕，稍等片刻，Datastore就反向出來(lái)了，如圖所示，l 目標(biāo)系統(tǒng)的Datastores反向反向前準(zhǔn)備：CREATE synonym FOR 。點(diǎn)擊OK，創(chuàng)建接口完成。 執(zhí)行過(guò)程(Designer\Projects\singTaoMDM\ERPMDM\Procedures\) 右鍵創(chuàng)建好的過(guò)程 選擇Excute執(zhí)行后，切換到Operator查看執(zhí)行結(jié)果登錄到目標(biāo)系統(tǒng)數(shù)據(jù)庫(kù)(MDM)查看Product表中是否有需要導(dǎo)入的物料信息。注意，連接的順序是包執(zhí)行的順序。過(guò)程和接口創(chuàng)建和執(zhí)行方案方式相同。CDC概述CDC捕獲源數(shù)據(jù)的變動(dòng)情況記錄到日記表，在傳遞數(shù)據(jù)時(shí)，只需要依據(jù)日志表中記錄而無(wú)需考慮未變動(dòng)的數(shù)據(jù)，大大提高ELT的效率。沒(méi)有特殊需求，這個(gè)默認(rèn)設(shè)置可以進(jìn)行ODI的CDC接口開發(fā)。添加到CDC(Add to CDC)Add to CDC作用是將一個(gè)模型標(biāo)記為可以進(jìn)行CDC接口開發(fā)的模型。表示添加訂閱者執(zhí)行成功。特別說(shuō)明： 啟動(dòng)日志會(huì)刪掉當(dāng)前Datastore所有的日志數(shù)據(jù)，相當(dāng)于初始化了該Datastore的日志。點(diǎn)擊OK保存，CDC接口創(chuàng)建完成。點(diǎn)擊，然后進(jìn)入Operator查看ODI是如何反向Datastores的。Subscriber224。SOAU39。但是經(jīng)過(guò)測(cè)試發(fā)現(xiàn)，只有對(duì)視圖進(jìn)行Insert、Update、Delete操作ODI才會(huì)寫入日志，而對(duì)視圖關(guān)聯(lián)的表進(jìn)行操作卻不能觸發(fā)觸發(fā)器。Models的CKM檢查靜態(tài)數(shù)據(jù)一致性：通過(guò)設(shè)立約束條件，可以清洗、過(guò)濾數(shù)據(jù)，只按需集成數(shù)據(jù)。如下圖所示通過(guò)對(duì)這些步驟的源碼了解和執(zhí)行結(jié)果，LKM Oracle to Oracle (DBLINK) 主要步驟：其他LKM可類似理解。下面對(duì)IKM進(jìn)行詳細(xì)的說(shuō)明。 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，下面對(duì)IKM：IKM Oracle Incremental Update主要的步驟進(jìn)行簡(jiǎn)要的說(shuō)明： 在ODI臨時(shí)區(qū)先Drop后Create臨時(shí)表I$； 在臨時(shí)I$表中插入流轉(zhuǎn)數(shù)據(jù)； 回收之前未成功導(dǎo)入的數(shù)據(jù)； 執(zhí)行CKM進(jìn)行數(shù)據(jù)質(zhì)量檢測(cè)； 設(shè)置I$表中需要更新的數(shù)據(jù)標(biāo)識(shí)為’U’； 設(shè)置I$表中無(wú)用數(shù)據(jù)標(biāo)識(shí)為’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ā)器可以建立在多表視圖上，我們需要客戶化這個(gè)JKM，修改Step11的Create trigger源碼。其實(shí)Get XXX步驟都是為Datastore的結(jié)構(gòu)進(jìn)行設(shè)計(jì)。為了驗(yàn)證CDC接口的執(zhí)行準(zhǔn)確，對(duì)源系統(tǒng)數(shù)據(jù)源進(jìn)行修改，添加默認(rèn)采購(gòu)員BEST_JULIE。 啟動(dòng)日志之前需要考慮：如果待啟動(dòng)日志的Datastore是首次啟動(dòng)日志操作，啟動(dòng)日志是必須的，無(wú)需考慮日志數(shù)據(jù)的丟失；如果不是首次，表示之前已做過(guò)啟動(dòng)日志操作，只要添加訂閱者即可，無(wú)需再次啟動(dòng)日志。表示警告：name is already used by an existing object。注：如果Da