从 ORACLE 到 DM 迁移实践

本章将以一个示例为载体，简单介绍使用 DTS 工具执行迁移任务的完整流程，读者可参考此示例，进一步了解 DTS 工具的使用方法和完整迁移流程。

10.1 确认迁移目标

在进行迁移之前，需要根据实际需求确认此次迁移的目标，包括迁移路径和迁移内容，简单来说，就是需要明确从哪迁移到哪，迁移什么。

例：以下是一个小型员工工作管理系统，相关对象和数据存储在某 ORACLE 实例的 C##DEMO_USER 模式下，预计将该工作管理系统迁移到一个 DM 数据库实例下。

--创建序列(用于记录员工ID)
create sequence emp_seq start with 1001 increment by 1;

--创建序列（用于记录任务ID）
create sequence task_seq start with 1 increment by 1;

--创建自定义类型(用于记录员工地址)
create or replace type address_type as object
(
street varchar2(50),
city varchar2(30),
postal_code varchar2(10)
);
/

--创建主表（员工表）
create table employees(
emp_id number primary key,
emp_name varchar2(50) not null,
emp_address address_type,
hire_date date default sysdate);

--创建从表（任务表）
create table tasks(
task_id number primary key,
emp_id number references employees(emp_id),
task_desc varchar2(100),
deadline date);

--创建视图（员工任务视图）
create view emp_tasks_view as
select e.emp_id,e.emp_name,t.task_desc,t.deadline
from employees e join tasks t on e.emp_id=t.emp_id;

--创建包规范
create or replace package emp_pkg AS
procedure add_employee(
p_name in varchar2,
p_street in varchar2,
p_city in varchar2,
p_postal in varchar2
);
function get_emp_task_count(p_emp_id in NUMBER)RETURN NUMBER;
END emp_pkg;
/

--创建包体
create or replace package body emp_pkg as
procedure add_employee(
p_name in varchar2,
p_street in varchar2,
p_city in varchar2,
p_postal in varchar2
)is
begin
insert into employees(emp_id,emp_name,emp_address)
values(emp_seq.nextval,p_name,address_type(p_street,p_city,p_postal));
commit;
end;
function get_emp_task_count(p_emp_id in number)return number is
v_count number;
BEGIN
select count(*) into v_count
from tasks
where emp_id=p_emp_id;
return v_count;
END;
END emp_pkg;
/

--创建触发器（自动设置任务期限）
create or replace trigger set_task_deadline
before insert on tasks for each row
begin
if :new.deadline is NULL THEN
:new.deadline:=SYSDATE+7;
END IF;
END;
/

--创建同义词
create synonym emp_syn for employees;

--创建存储过程（添加带任务的员工）
create or replace procedure add_employee_with_task(
p_name in varchar2,
p_task in varchar2
)is
v_emp_id NUMBER;
BEGIN
v_emp_id:=emp_seq.nextval;
insert into employees(emp_id,emp_name)values (v_emp_id,p_name);
insert into tasks(task_id,emp_id,task_desc)
values(task_seq.nextval,v_emp_id,p_task);
COMMIT;
END;
/

其中存储的数据如下所示：

--EMPLOYEES员工表：
insert into employees(emp_id,emp_name,emp_address,hire_date)
values(emp_seq.nextval,'张明',address_type('长安街100号','北京','100000'),to_date('2010-03-15','YYYY-MM-DD'));
insert into employees(emp_id,emp_name,emp_address,hire_date)
values(emp_seq.nextval,'李华',address_type('南京路200号','上海','200000'),to_date('2016-08-15','YYYY-MM-DD'));
insert into employees(emp_id,emp_name,emp_address,hire_date)
values(emp_seq.nextval,'王芳',address_type('天河路300号','广州','510000'),to_date('2017-07-12','YYYY-MM-DD'));
insert into employees(emp_id,emp_name,emp_address,hire_date)
values(emp_seq.nextval,'刘强',address_type('科技园路400号','深圳','518000'),to_date('2018-01-12','YYYY-MM-DD'));
insert into employees(emp_id,emp_name,emp_address,hire_date)
values(emp_seq.nextval,'陈静',address_type('西湖路500号','杭州','310000'),to_date('2019-03-19','YYYY-MM-DD'));
insert into employees(emp_id,emp_name,emp_address,hire_date)
values(emp_seq.nextval,'赵勇',address_type('长江道600号','武汉','430000'),to_date('2020-07-08','YYYY-MM-DD'));
insert into employees(emp_id,emp_name,emp_address,hire_date)
values(emp_seq.nextval,'孙丽',address_type('滨海大道700号','天津','103000'),to_date('2020-11-29','YYYY-MM-DD'));
insert into employees(emp_id,emp_name,emp_address,hire_date)
values(emp_seq.nextval,'周涛',address_type('天府广场800号','成都','610000'),to_date('2021-01-16','YYYY-MM-DD'));
insert into employees(emp_id,emp_name,emp_address,hire_date)
values(emp_seq.nextval,'吴刚',address_type('中山路900号','南京','210000'),to_date('2022-09-15','YYYY-MM-DD'));
insert into employees(emp_id,emp_name,emp_address,hire_date)
values(emp_seq.nextval,'郑小红',address_type('解放路1000号','重庆','400000'),to_date('2023-01-15','YYYY-MM-DD'));


\--TASKS任务表
\--张明
INSERT INTO TASKS(task_id,emp_id,task_desc,deadline)
values(task_seq.nextval,1001,'完成季度财报'，to_date('2025-12-15','YYYY-MM-DD'));
INSERT INTO TASKS(task_id,emp_id,task_desc,deadline)
values(task_seq.nextval,1001,'准备年度预算方案'，to_date('2025-12-20','YYYY-MM-DD'));
\--李华
INSERT INTO TASKS(task_id,emp_id,task_desc,deadline)
values(task_seq.nextval,1002,'开发新客户管理系统'，to_date('2025-11-30','YYYY-MM-DD'));
INSERT INTO TASKS(task_id,emp_id,task_desc,deadline)
values(task_seq.nextval,1002,'优化数据库查询性能'，to_date('2025-12-10','YYYY-MM-DD'));
\--王芳
INSERT INTO TASKS(task_id,emp_id,task_desc,deadline)
values(task_seq.nextval,1003,'组织团队建设活动'，to_date('2025-12-10','YYYY-MM-DD'));
INSERT INTO TASKS(task_id,emp_id,task_desc,deadline)
values(task_seq.nextval,1003,'安排员工培训计划'，to_date('2025-12-18','YYYY-MM-DD'));
\--刘强
INSERT INTO TASKS(task_id,emp_id,task_desc,deadline)
values(task_seq.nextval,1004,'服务器安全漏洞修复'，to_date('2025-12-05','YYYY-MM-DD'));
INSERT INTO TASKS(task_id,emp_id,task_desc,deadline)
values(task_seq.nextval,1004,'系统备份策略优化'，to_date('2025-12-12','YYYY-MM-DD'));
\--陈静
INSERT INTO TASKS(task_id,emp_id,task_desc,deadline)
values(task_seq.nextval,1005,'设计产品用户界面'，to_date('2025-12-15','YYYY-MM-DD'));
\--赵勇
INSERT INTO TASKS(task_id,emp_id,task_desc,deadline)
values(task_seq.nextval,1006,'代码审查和质量检查'，to_date('2025-12-20','YYYY-MM-DD'));
\--孙丽
INSERT INTO TASKS(task_id,emp_id,task_desc,deadline)
values(task_seq.nextval,1007,'客户满意度调研报告'，to_date('2025-12-20','YYYY-MM-DD'));
\--赵勇
INSERT INTO TASKS(task_id,emp_id,task_desc,deadline)
values(task_seq.nextval,1008,'制定部门工作流程'，to_date('2025-12-20','YYYY-MM-DD'));
\--吴刚
INSERT INTO TASKS(task_id,emp_id,task_desc,deadline)
values(task_seq.nextval,1009,'采购办公设备'，to_date('2025-12-15','YYYY-MM-DD'));
\--郑小红
INSERT INTO TASKS(task_id,emp_id,task_desc,deadline)
values(task_seq.nextval,1010,'整理供应商材料'，to_date('2025-12-20','YYYY-MM-DD'));

本示例中数据所在源库 ORACLE 和目标库 DM 的信息如下所示：

表10.1 数据源和目的服务