文档介绍：OracleCDC操作手册Oracle的增量数据处理方案中联新时代CDC简介CDC是一种数据增量处理技术在构建数据仓库系统的ETL过程中,:准确性,能够将业务系统中的数据按一定的频率准确的取到数据仓库中性能,不能对业务系统造成太大的压力,影响现有业务目前,最为常用的ETL增量数据处理方式有三种:时间戳日志对比(CDC)全面数据对比三种方式各有优劣,时间戳是目前应用比较普遍的方式。在Oracle=中推出了两种主要的ETL方案,一种是我们熟悉的物化视图(materializedview),另一种就是本文将要介绍的CDC组件(ChangeDataCapture改变数据捕获)。CDC特性是在Oracle9i数据库中引入的。CDC能够帮助你识别从上次提取之后发生变化的数据。利用CDC,在对源表进行INSERT、UPDATE或DELETE等操作的同时就可以提取数据,并且变化的数据被保存在数据库的变化表中。这样就可以捕获发生变化的数据,然后利用数据库视图以一种可控的方式提供给目标系统。CDC与传统增量处理方式的对比分析我们对比一下CDC方式与传统的全表对比与时间戳方式。全表对比使用数据仓库中的当前表与业务系统表进行对比,取得变化了的数据,典型是使用minus语句:SELECT*FROMnew_versionMINUSSELECT*FROMold_version;使用全表对比有以下几方面的问题:需要将业务系统中表全部转输,造成很高的网络负载需要对两版本的表进行全表扫描,性能代价非常高无法反映数据的历史状态,如无法捕捉库存的历史变化记录还有一种常用的方式是时间戳, 它是以业务表中某一个字段的值,作为判断新旧数据的标志。如,”病人费用记录”中的登记时间,每次只抽取上次抽取记录时间以后产生的数据。时间戳方式存在以下问题:无法捕获对时间戳以前数据的delete和update操作,在数据准确性上受到了一定的限制。而类似于ZLHIS这种业务系统对已经发生的数据进行update和delete操作非常普遍(如划价记录转收费记录),应用场景受到了限制。要求业务系统的表必须一个可以标识新旧数据的列,而某些表没有设置这种列。CDC的发布订立模型CDC体系结构基于发布者/订阅者模型。发布者捕捉变化数据并提供给订阅者。订阅者使用从发布者那里获得的变化数据。通常,CDC系统拥有一个发布者和多个订阅者。发布者首先需要识别捕获变化数据所需的源表。然后,它捕捉变化的数据并将其保存在特别创建的变化表中。它还使订阅者能够控制对变化数据的访问。订阅者需要清楚自己感兴趣的是哪些变化数据。一个订阅者可能不会对发布者发布的所有数据都感兴趣。订阅者需要创建一个订阅者视图来访问经发布者授权可以访问的变化数据。CDC有几个重要的基本概念需要先明确一下:源表(SourceTable),业务数据库的需要捕获数据的源表变化表(ChangeTable),保存从源表捕获的变化数据(包括各种DML产生的数据)变化集(ChangeSet),是保证事务一致性的数据集合。一个变化集对应多个变化表订阅视图(SubscriptionView),提供给读取变化表数据的视图订阅窗口(SubscriptionWindow),。变化数据处理完成后,可以对清除订阅窗口。CDC的同步与异步模式同步模式,实时的捕获变化数据并存储到变化表中,发布者与订阅都位于同一数据库中。下图说明了同步模式的基本架构。异步模式,以Oracle流复制技术为基础,由于流复制比较复杂,DC相关的数据库对象(Package)包(Package)DBMS_CDC_PUBLISH,用于定义发布操作DBMS_CDC_SUBSCRIBE,用于定义订阅操作角色EXECUTE_CATALOG_ROLESELECT_CATALOG_ROLECREATETABLEandCREATESESSIONprivilegesEXECUTEontheDBMS_CDC_PUBLISHpackage视图ALL_SOURCE_TABLES源表ALL_PUBLISHED_COLUMNS发布的表列All_Subscribed_Columns订阅的表列All_Subscriptions所有订阅All_Subscribed_Tables已经订阅的表CDC的实施步骤初始化设置初始化参数由于CDC需要在后台开启作业,需要将参数JOB_QUEUE_PROCESSES增加2个,java_pool_size至少在50M以上。SQL>altersystemsetjob_queue_processes=14;SystemalteredSQL>altersystemsetjava_pool_size=50m;SystemalteredSQL>创建订阅、发布用户、表空间SQL>createtablespacets