ODIG安装及使用

1、ODI安装与使用ODI是oracle的数据抽取工具，11G融合了wls和jdev，不10G相比出现了教大幅度的变化。环境介绍：OS：Win7-32bitOracle-DB：10GXEWLS：10.3.3 ODI RCU安装资料库解压完成后需要rcuHomeBIN目录下面打开rcu.bat文件，选择创建填写数据库连接信息填写数据库连接信息填写ODI数据库用户口令填写ODI相关对象信息，主资料库ID，口令创建表空间开始创建表空间创建完毕后作创建对象前确认开始创建主资料库和工作资料库创建完成安装ODI解压后到disk1中点击setup，选择需要按照的ODI对象，本机上安装服务器和编辑器！作检查选择安

2、装目录数据库连接信息ODI应用超级用户口令代理名称和代理端口确讣安装信息开始安装安装完毕！创建domain进入$ODI_HOME$commonbin运行config.cmd来创建domain填写domain的名称Weblogic域管理员口令选择java sdk填写数据库连接信息作数据库连接信息验证选择domain功能配置管理服务器信息配置受管理server集群配置，由于不做集群，直接下一步计算机配置集群服务器配置，直接下一步服务安装配置概要开始创建域创建完毕启动服务首先启动Adminerver 然后到D:OracleMiddlewarewlserver_10.3serverbin目录下面启劢s

3、tartNodeManager.cmd 到D:OracleMiddlewarewlserver_10.3commonnodemanager目录下面修改perties文件中StartScriptEnabled=true将false改为true，重启nodemanager 进入weblogic console页面 服务器->控制->启动odiServer例子一、建立资料库连接并创建一个初始化表的接口1. 点击连接到资料库，填写资料库连接信息2. 打开SQL Developer，使用以下的sql语句创建新的用户create user ODI_STAGE id

4、entified by ODI_STAGEdefault tablespace users temporary tablespace temp;grant connect, resource, create trigger, create view to ODI_STAGE;3. 在ODI中打开拓扑导航页，选择物理体系结构，展开技术节，右键单击Oracle并选择新建数据服务器4. 在新建窗口，输入以下的参数。点JDBC标签ParameterValueNameODI_STAGEInstance/dblink (Data Server)ORCLUserODI_STAGEPasswordODI_ST

5、AGE设置JDBC连接保存连接点“测试连接”5. 展开Oracle节点，右键单击ODI_STAGE，选择新建物理方案6. 在方案（方案）和方案（工作方案）下拉框，选择ODI_STAGE方案，点击保存按钮，关闭ODI_STAGE.ODI_STAGE物理方案，在弹出的信息窗口选择确定7. 打开逻辑体系结构，找到技术->Oracle，右键单击Oracle并选择新建逻辑方案8. 将逻辑方案命名为ODI_STAGE，设置Global上下文的物理方案为ODI_STAGE.ODI_STAGE,保存并关闭。9. 在设计器页点击项目页的图标，选择新建项目10. 在新建对象窗口的名称栏目输入Procedur

6、e-CRT-TBL，代码栏目自动填充为Procedure-CRT-TBL， 点保存按钮可以看到新建的Procedure-CRT-TBL已经出现在项目列表中11. 在项目页依次展开Procedure-CRT-TBL->第一个文件夹，右键单击过程选择新建过程12. 在新对象窗口将新建的过程命名为PRD-create-populate-table，目标技术选择Oracle，点详细资料页签，点按钮添加一个步骤13. 在信息窗口中输入以下参数，选择忽略错误，选择详细资料参数值名称Drop table技术Oracle方案ODI_STAGE命令DROP table ODI_STAGE.SRC_SALE

7、S_PERSON114. 点添加另外的步骤，输入以下参数参数值名称Create Table技术Oracle方案ODI_STAGE命令CREATE table "SRC_SALES_PERSON1" ("SALES_PERSON_ID" NUMBER(8,0) NOT NULL,"FIRST_NAME" VARCHAR2(80),"LAST_NAME" VARCHAR2(80),"DATE_HIRED" VARCHAR2(80),"DATE_UPDATED" DATE NOT

8、NULL,constraint "TRG_SALES_PERSON1_PK" primary key("SALES_PERSON_ID")15. 点添加另外的步骤初始化SRC_SALES_PERSON1表，输入以下参数参数值名称Populate table技术Oracle方案ODI_STAGE命令begininsert into ODI_STAGE.SRC_SALES_PERSON1 values(11,'Andrew','Andersen','22/02/1999',sysdate);insert int

9、o ODI_STAGE.SRC_SALES_PERSON1 values(12,'John','Galagers','20/04/2000',sysdate);insert into ODI_STAGE.SRC_SALES_PERSON1 values(13,'Jeffrey','Jeferson','32422',sysdate);insert into ODI_STAGE.SRC_SALES_PERSON1 values(20,'Jennie','Daumesnil

10、9;,'28/02/1988',sysdate);insert into ODI_STAGE.SRC_SALES_PERSON1 values(21,'Steve','Barrot','24/09/1992',sysdate);insert into ODI_STAGE.SRC_SALES_PERSON1 values(22,'Mary','Carlin','14/03/1995',sysdate);insert into ODI_STAGE.SRC_SALES_PERSON1 va

11、lues(30,'Paul','Moore','36467',sysdate);insert into ODI_STAGE.SRC_SALES_PERSON1 values(31,'Paul','Edwood','18/03/2003',sysdate);insert into ODI_STAGE.SRC_SALES_PERSON1 values(32,'Megan','Keegan','29/05/2001',sysdate);insert into

12、 ODI_STAGE.SRC_SALES_PERSON1 values(40,'Rodolph','Bauman','29/05/2000',sysdate);insert into ODI_STAGE.SRC_SALES_PERSON1 values(41,'Stanley','Fischer','37233',sysdate);insert into ODI_STAGE.SRC_SALES_PERSON1 values(42,'Brian','Schmidt',&

13、#39;25/08/1992',sysdate);insert into ODI_STAGE.SRC_SALES_PERSON1 values(50,'Anish','Ishimoto','30/01/1992',sysdate);insert into ODI_STAGE.SRC_SALES_PERSON1 values(51,'Cynthia','Nagata','28/02/1994',sysdate);insert into ODI_STAGE.SRC_SALES_PERSON1 v

14、alues(52,'William','Kudo','28/03/1993',sysdate);end;16. 检查新创建的命令并保存。17. 展开Procedure-CRT-TBL > 过程，选择刚刚创建的过程PRD-create-populate-table并选择执行18. 打开ODI操作，点击所有执行，点刷新图标，找到刚启动的过程，检查是否成功执行。19. 打开SQL developer双击ODI_STAGE连接，选择表节点，单击刷新按钮，双击新创建的表SRC_SALES_PERSON1，单击数据标签，确认SRC_SALES_PERS

15、ON1表已经正确创建，并初始化了数据。例子二、创建项目和接口将数据从一个表导入到另一个表1. 打开设计器页，新建项目将项目命名为ODI_exp_FT_RT2. 引入知识模块LKM File to SQL、CKM Oracle 和IKM SQL Incremental Update。3. 打开SQL developer，使用以下的语句创建表TRG_SALES_PERSONCREATE table "TRG_SALES_PERSON"("SALES_PERSON_ID" NUMBER(8,0) NOT NULL,"FIRST_NAME"

16、VARCHAR2(80),"LAST_NAME" VARCHAR2(80),"DATE_HIRED" VARCHAR2(80),"DATE_UPDATED" DATE NOT NULL,constraint "TRG_SALES_PERSON_PK" primary key("SALES_PERSON_ID")4. 在ODI中打开拓扑导航页，选择物理体系结构，展开技术节，右键单击Oracle并选择新建数据服务器5. 在新建窗口，输入以下的参数。点JDBC标签ParameterValueNameO

17、DI_STAGEInstance/dblink (Data Server)ORCLUserODI_STAGEPasswordODI_STAGE设置JDBC连接保存连接点“测试连接”6. 展开Oracle节点，右键单击ODI_STAGE，选择新建物理方案7. 在方案（方案）和方案（工作方案）下拉框，选择ODI_STAGE方案，点击保存按钮，关闭ODI_STAGE.ODI_STAGE物理方案，在弹出的信息窗口选择确定8. 打开逻辑体系结构，找到技术->Oracle，右键单击Oracle并选择新建逻辑方案9. 将逻辑方案命名为ODI_STAGE，设置Global上下文的物理方案为ODI_STA

18、GE.ODI_STAGE,保存并关闭。10. 建立模型点模型输入以下参数：名称：Oracle_RDBMS1技术：Oracle逻辑方案：ODI_STAGE在逆向工程页设置如下，关闭Oracle_RDBMS1页11. 右键单击Oracle_RDBMS1选择逆向工程12. 在ODI设计器中依次展开项目->ODI_exp_FF_RT->第一个文件夹，右键单击接口选择新建接口接口命名为INT-EXP-FF-RT，反选临时区域与目标区不同复选框，点映射页签。从模型中将SRC_SALES_PERSON拖和TRG_SALES_PERSON拖到如下的区域结果如下，点“控制”确认CKM选择器选择的是C

19、KM Oracle13. 保存并执行点开操作查看执行结果例子三、CDC抽取1. 添加知识模块在前面例子使用的项目ODI_exp_FT_RT中添加知识模块JKM Oracle Simple2. 设计器模块Oracle_RDBMS1双击日记记录ODI已经默认选择模式为“简单”、KM为“JKM Oracle Simple. ODI_exp_FT_RT”3. 添加到CDC设计器模块Oracle_RDBMS1SRC_SALES_PERSON1右键已更改数据捕获添加到CDC操作完成后可以看到表的左上角增加了一个黄色的时钟4. 添加订阅设计器模块Oracle_RDBMS1SRC_SALES_PERSON1右

20、键已更改数据捕获订户订阅添加订户CDCT，订户名字可以为任意值，在设置后边的接口的Filter时要用到5. 启动日记设计器模块Oracle_RDBMS1SRC_SALES_PERSON1右键已更改数据捕获启动日记日记启动以后可以看到左上方的黄色时钟标示变成绿色6. 测试在SRC_SALES_PERSON1表中修改一条记录然后再增加一条记录设计器模块Oracle_RDBMS1SRC_SALES_PERSON1右键已更改数据捕获日记数据可以看到已经捕获到数据的变化情况7. 接口启用CDC双击例子二中建立的接口INT-EXP-FF-RT，点“映射”，点源端的表 勾选下面的“仅已进行日记记录的数据”，

21、可以看到源区域多了一个漏斗状的过滤图标，点过滤图标，修改下面的实施区域内容为JRN_SUBSCRIBER = 'CDCT'。保存后，执行接口确认刚刚捕获的变化数据已经全部同步到目标表中。例子四、使用代理1. 确认存在“拓扑物理体系结构代理WF_AGENT”和“拓扑逻辑体系结构代理WF_AGENT”如果不存在，新建物理代理和逻辑代理，新建的物理代理和逻辑代理如下：物理代理：逻辑代理：2. 生成场景项目ODI_exp_FI_RT第一个文件夹接口INT_EXP_FF_RT右键生成场景项目ODI_exp_FI_RT第一个文件夹接口INT_EXP_FF_RT场景 INT_EXP_FF_R

22、T版本001调度右键新建调度填写以下参数：代理：WF_AGENT执行：启动时转到执行循环页修改为如下内容 经过以上设置，当启动代理WF_AGENT后程序会每一分钟执行一次接口3. 启动代理启动windows command窗口，转到目录D:OracleMiddlewareOracle_ODI1oraclediagentbin下，执行agent.bat "-NAME=WF_AGENT" "-PORT=27776"可以看到如下结果说明代理已经正常启动，接口就能够按照在前面调度中设置的频率执行了。例子五、CDC抽取（Consistent Set）环境准备使用前

23、面建立的用户ODI_STAGE登录Oracle数据库新建两张表，并修改soctt用户的权限：create table DEPT( DEPTNO NUMBER(2) not null, DNAME VARCHAR2(14), LOC VARCHAR2(13);alter table DEPT add constraint PK_DEPT primary key (DEPTNO) using index;create table EMP( EMPNO NUMBER(4) not null, ENAME VARCHAR2(10), JOB VARCHAR2(9), MGR NUMBER(4), HI

24、REDATE DATE, SAL NUMBER(7,2), COMM NUMBER(7,2), DEPTNO NUMBER(2);alter table EMP add constraint PK_EMP primary key (EMPNO) using index;alter table EMP add constraint FK_DEPTNO foreign key (DEPTNO) references DEPT (DEPTNO);-填充数据INSERT INTO dept SELECT * FROM scott.dept;INSERT INTO emp SELECT * FROM s

25、cott.emp;-修改scott用户权限grant connect,resource to scott;grant create view to scott;建立模型先添加物理体系结构scott，物理体系结构的定义如下图：scott物体体系结构方案如下：添加逻辑体系结构：新建项目CDC_CONSISTENT，并导入知识库 JKM Oracle Consistent新建模型Oracle_scott，并点逆向工程，获得数据库信息：日记记录设置模型Oracle_scott双击日记记录日记记录模式选择“一致性集合”，知识模块选择JKM Oracle Consistent.CDC_CONSISTENT

26、添加到CDC模型Oracle_scottdept右键已更改数据捕获添加到CDC模型Oracle_scottemp右键已更改数据捕获添加到CDC调整顺序增加订阅模型Oracle_scott右键已更改数据捕获订户订阅添加一个名字叫“SCOTT”的订阅者启动日记模型 Oracle_scott 右键已更改数据捕获启动日记测试在PL/SQL Developer中执行下列语句往源系统插入数据INSERT INTO scott.dept SELECT MAX(deptno) + 1, 'TEST', 'TEST' FROM scott.dept;INSERT INTO scott.emp SELECT MAX(empno) + 1, MAX(ename), MAX(job), MAX(mgr), MAX(hiredate), MAX(sal), MAX(comm), MAX(deptno)