设为首页 加入收藏

TOP

Oracle CDC数据增量测试代码实例(一)
2017-12-14 14:32:23 】 浏览:385
Tags:Oracle CDC 数据 增量 测试 代码 实例

创建表空间

创建临时表空间=====================================

create temporary tablespace test_temp
tempfile 'e:\oracle\oradata\cdctest\test_temp01.dbf'
size 32m
autoextend on
next 32m maxsize 2048m
extent management local;

创建数据表空间======================================

create tablespace test_data
logging
datafile 'e:\oracle\oradata\cdctest\test_data01.dbf'
size 32m
autoextend on
next 32m maxsize 2048m
extent management local;

创建用户

1)业务操作用户

创建业务操作用户并指定表空间=========================

create user appuser identified by appuser 
default tablespace test_data
temporary tablespace test_temp;

给用户授予权限======================================

grant connect,resource, create view to appuser

2)发布用户

创建发布用户并指定表空间=============================

create user cdc_pub identified by cdc 
default tablespace test_data
temporary tablespace test_temp;

给用户授予权限=======================================

grant connect,resource to cdc_pub -- connect 连接权限,resource用于给开发人员用的角色
grant SELECT_CATALOG_ROLE TO cdc_pub --可以查看一些数据字典的视图·
GRANT EXECUTE_CATALOG_ROLE TO cdc_pub--执行目录角色,能够执行所有系统包
GRANT EXECUTE ON DBMS_CDC_PUBLISH TO cdc_pub--用于定义发布操作
grant create job to cdc_pub --创建任务

3)订阅用户

创建订阅用户并指定表空间=============================

create user cdc_sub identified by cdc 
default tablespace test_data
temporary tablespace test_temp;

给用户授予权限=======================================

grant connect,resource to cdc_sub -- connect 连接权限,resource用于给开发人员用的角色
grant execute on DBMS_CDC_SUBSCRIBE TO CDC_SUB --用于定义订阅操作

2.创建业务表:以业务用户账户(APPUSER)登录

create table SalesOrder(
orderId int not null,
customerId int not null,
duedate date not null,
deliverTo int not null,
createddttm date default sysdate,
constraint pk_salesOrder primary key (orderId)
)

select * from salesorder



create table salesorderdetail(
solineId int not null,
orderId int not null,
itemNumber varchar2(20) not null,
quantity decimal(13,4),
linePrice decimal(13,4),
constraint pk_sodetail primary key (solineId)
)

select * from salesorderdetail

3.创建发布:以发布者登录(CDC_PUB)

1)创建发布集

BEGIN
 DBMS_CDC_PUBLISH.CREATE_CHANGE_SET(
 change_set_name => 'CDC_SET_SO',  --改变集 
 description => 'Change set for SalesOrder, SalesOrderDetail',
 change_source_name => 'SYNC_SOURCE');
END;

2)创建发布表:一个发布集对应多个发布的表

发布表即是用于存放变更了的数据的表。以下语句将在发布者(CDC_PUB)名下新建两个发布表:CT_SALESORDER和CT_SALESORDERDETAIL。

BEGIN
   DBMS_CDC_PUBLISH.CREATE_CHANGE_TABLE( 
   DDL_MARKERS=>'n',
   owner => 'cdc_pub',  --发布表的Owner! 
   change_table_name => 'CT_SalesOrder',  --发布表名
   change_set_name => 'CDC_SET_SO',  --改变集
   source_schema => 'appuser',  --业务表的Owner
   source_table => 'SalesOrder',  --业务表
   column_type_list => 'OrderID int, CustomerID int, DueDate Date,  DeliverTo int, 
               CreateDTTM Date',   --发布表中的列定义 
   capture_values => 'new',  -- 获取更改的值
   rs_id => 'n',
   row_id => 'n',
   user_id => 'n',
   timestamp => 'n',
   object_id => 'n',
   source_colmap => 'n',
   target_colmap => 'n',
   options_string => null );
END;

BEGIN
   DBMS_CDC_PUBLISH.CREATE_CHANGE_TABLE( 
   DDL_MARKERS=>'n',
   owner => 'cdc_pub',
   change_table_name => 'CT_SalesOrderDetail',
   change_set_name => 'CDC_SET_SO',
   source_schema => 'appuser',
   s
首页 上一页 1 2 下一页 尾页 1/2/2
】【打印繁体】【投稿】【收藏】 【推荐】【举报】【评论】 【关闭】 【返回顶部
上一篇Mysql数据库基于Mysql-索引-BTree.. 下一篇Oracle如何查询重复数据?

最新文章

热门文章

Hot 文章

Python

C 语言

C++基础

大数据基础

linux编程基础

C/C++面试题目