【正文】 , tbs) (triggerCmdTemp) ()myStmt = None Commit, just in case()更改歷史。, triname) triggerCmdTemp = (39。for tbs in lstTbs: if indexs 1: triname = _%d %inx inx = inx + 1 triggerCmdTemp = (39。 Create the statementmyStmt = () Execute the trigger creationinx = 1triname = 39。) */ 。 /* The following line can be unmented for symetric replication */ /* and upper(USER) upper(39。, V_FLAG, sysdate, %=(, V_[COL_NAME], ,\n\t\t, , PK)% from %=(SNP_JRN_SUBSCRIBER)% where JRN_TNAME = 39。 insert into %=(JRN_FULL_NAME)% ( JRN_SUBSCRIBER, JRN_CONSUMED, JRN_FLAG, JRN_DATE, %=(, [COL_NAME], ,\n\t\t, , PK)% ) select JRN_SUBSCRIBER, 39。D39。 if deleting then %=(, V_[COL_NAME] := :old.[COL_NAME]。I39。 if updating then %=(, V_[COL_NAME] := :new.[COL_NAME]。I39。, \n\t, , PK)% begin if inserting then %=(, V_[COL_NAME] := :new.[COL_NAME]。, triname) (dropTriCmdTemp)()dropStmt = None Commit, just in case() Create trigger (重寫) Technology: JythontriggerCmd = create or replace trigger %=(JRN_FULL_TRIGGER)%miss_index after insert or update or delete on miss_table_name for each row declare V_FLAG VARCHAR(1)。for tbs in lstTbs: if indexs 1: triname = _%d %inx inx = inx + 1 dropTriCmdTemp = (39。 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。||NAME = 39。 and OWNER||39。附錄III：JKM客戶化圖： Initialize Tablenames (新增) Technology: JythongetTbsCmd = select REFERENCED_NAME from DBA_DEPENDENCIES where TYPE = 39。) */ 。 /* The following line can be unmented for symetric replication */ /* and upper(USER) upper(39。, V_FLAG, sysdate, V_INVENTORY_ITEM_ID, V_ORGANIZATION_ID from where JRN_TNAME = 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。D39。 V_ORGANIZATION_ID := :。 end if。 V_FLAG := 39。 if updating then V_INVENTORY_ITEM_ID := :。I39。 V_ORGANIZATION_ID := :。 V_ORGANIZATION_ID NUMBER(22)。附錄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)。/demofs/oraDB/erpdata/39。users創(chuàng)建users表空間腳本。/demofs/oraDB/erpdata/39。 SIZE 32M AUTOEXTEND ON NEXT 32M MAXSIZE 2048M EXTENT MANAGEMENT LOCAL SEGMENT SPACE MANAGEMENT AUTO。 MDM SystemCREATE TABLESPACE soau_data DATAFILE 39。 在目標(biāo)系統(tǒng)插入I$表中標(biāo)識為’I’的數(shù)據(jù)；刪除臨時表I$。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ù)。下面對IKM進行詳細的說明。IKM也是作用在接口中，與LKM不同的是，IKM是目標(biāo)系統(tǒng)Datastores需要選擇KM。BEST39。%=(SRC_DSERV_NAME)%39。如下圖所示通過對這些步驟的源碼了解和執(zhí)行結(jié)果，LKM Oracle to Oracle (DBLINK) 主要步驟：其他LKM可類似理解。LKM作用是將遠程服務(wù)器的源數(shù)據(jù)下載到ODI臨時區(qū)。FLOW_CONTROL默認值是’YES’。 在接口(Interfaces)中添加CKMDesigner\Projects\singTaoMDM\ERPMDM\Interfaces\ 右鍵 選擇EditODI默認的CKM是：CKM Oracle。Models的CKM檢查靜態(tài)數(shù)據(jù)一致性：通過設(shè)立約束條件，可以清洗、過濾數(shù)據(jù)，只按需集成數(shù)據(jù)。CKM216。如果想更深入了解視圖JKM客戶化研究，可做參考。此處只是演示一下JKM的客戶化。但是經(jīng)過測試發(fā)現(xiàn)，只有對視圖進行Insert、Update、Delete操作ODI才會寫入日志，而對視圖關(guān)聯(lián)的表進行操作卻不能觸發(fā)觸發(fā)器。查看SQL：View T$CUX_MTL_SYSTEM_ITEMS_INIT_V由于篇幅過長，觸發(fā)器代碼詳見附錄II。TRIGGER39。%CUX_MTL_SYSTEM_ITEMS_INIT_V%39。SOAU39。下面以數(shù)據(jù)源來解析JKM的操作。其他步驟參考CDC接口開發(fā)章節(jié)中啟動日志(Start Journal)。解決方案：替換觸發(fā)器可以建立在多表視圖上，我們需要客戶化這個JKM，修改Step11的Create trigger源碼。Subscriber224。如果想對RKM源碼進行了解，Designer\Projects\TsingTaoMDM\KM\RKM\ RKM Oracle打開RKM Oracle，雙擊需要了解的Step，就可以看到源碼，比如Get columns，JKM啟動(或關(guān)閉)日志時執(zhí)行的KM，在Model選擇。其他的Step如果想進行了解，可以將這些步驟執(zhí)行的語句Copy到數(shù)據(jù)庫運行，查看運行結(jié)果和語句取值邏輯可以了解ODI想做什么。其實Get XXX步驟都是為Datastore的結(jié)構(gòu)進行設(shè)計。點擊，然后進入Operator查看ODI是如何反向Datastores的。為了更好對RKM進行了解，排除其他操作影響，特意新建一個模型：ERP 。此總結(jié)只描述了JKM的客戶化開發(fā)。為了驗證CDC接口的執(zhí)行準(zhǔn)確，對源系統(tǒng)數(shù)據(jù)源進行修改，添加默認采購員BEST_JULIE。點擊OK保存，CDC接口創(chuàng)建完成。復(fù)制基礎(chǔ)接口：選中復(fù)制后的接口，右鍵Edit重命名為： (CDC)Diagram TAB頁選中源系統(tǒng)Datastore：CUX_MTL_SYSTEM_ITEMS_INIT_V，勾上然后選中，設(shè)置JRN_SUBSCRI