Oracle Streams是Oracle数据库内置的数据流处理技术，通过捕获源端数据库的数据变更，经过队列传输后应用到目标端数据库，实现跨实例的数据同步，无需额外采购第三方同步工具，适配多种业务场景下的数据流转需求。
Oracle Streams核心组件
搭建前需要先了解Oracle Streams的核心组成部分，各组件分工协作完成整个同步流程：
- 捕获进程（Capture Process）：运行在源端数据库，负责捕获数据字典变更、DML、DDL等操作，生成逻辑变更记录（LCR）。
- 队列（Queue）：分为源端队列和目标端队列，用于存储捕获到的LCR，是数据流转的中间存储载体。
- 传播进程（Propagation Process）：负责将源端队列中的LCR传输到目标端的队列中。
- 应用进程（Apply Process）：运行在目标端数据库，负责读取队列中的LCR，将其转换为对应的数据库操作并执行。
- 规则（Rule）：用于定义哪些数据变更需要被捕获、传播和应用，可灵活控制同步的范围。
搭建前的环境准备
搭建Oracle Streams需要满足以下基础环境条件：
- 源端和目标端数据库版本建议一致，最低支持Oracle 10g及以上版本，避免版本差异导致兼容性问题。
- 源端和目标端数据库之间网络互通，可正常建立数据库连接。
- 两个数据库都需要开启归档日志模式，同时设置相关的Streams初始化参数。
初始化参数配置
需要在源端和目标端分别修改数据库参数，执行以下SQL语句：
-- 源端和目标端都需要执行，设置Streams池大小，根据实际业务调整 ALTER SYSTEM SET streams_pool_size = 512M SCOPE=SPFILE; -- 设置全局名称，确保数据库唯一标识 ALTER SYSTEM SET global_names = TRUE SCOPE=SPFILE; -- 开启补充日志，捕获进程需要依赖补充日志获取完整变更信息 ALTER DATABASE ADD SUPPLEMENTAL LOG DATA; -- 重启数据库使参数生效 SHUTDOWN IMMEDIATE; STARTUP MOUNT; ALTER DATABASE ARCHIVELOG; ALTER DATABASE OPEN;
搭建全流程步骤
1. 创建Streams管理用户并授权
为了便于管理，分别在源端和目标端创建专用的Streams管理员用户，并授予对应权限：
-- 源端执行，创建用户并授权 CREATE USER streams_admin IDENTIFIED BY streams123; GRANT CONNECT, RESOURCE, DBA TO streams_admin; GRANT SELECT_CATALOG_ROLE TO streams_admin; GRANT EXECUTE_CATALOG_ROLE TO streams_admin; -- 目标端执行相同语句创建用户
2. 配置数据库连接
在源端配置到目标端的数据库链路，在目标端配置到源端的数据库链路，方便进程之间通信：
-- 源端创建到目标端的链路，target_ip为目标端数据库IP，orcl为目标端服务名 CREATE DATABASE LINK target_db_link CONNECT TO streams_admin IDENTIFIED BY streams123 USING '(DESCRIPTION=(ADDRESS=(PROTOCOL=TCP)(HOST=target_ip)(PORT=1521))(CONNECT_DATA=(SERVICE_NAME=orcl)))'; -- 目标端创建到源端的链路，source_ip为源端数据库IP CREATE DATABASE LINK source_db_link CONNECT TO streams_admin IDENTIFIED BY streams123 USING '(DESCRIPTION=(ADDRESS=(PROTOCOL=TCP)(HOST=source_ip)(PORT=1521))(CONNECT_DATA=(SERVICE_NAME=orcl)))';
3. 创建队列
分别在源端和目标端创建Streams队列，用于存储变更数据：
-- 源端执行，创建源端队列，队列名为source_queue
BEGIN
DBMS_STREAMS_ADM.SET_UP_QUEUE(
queue_name => 'source_queue',
queue_table => 'source_queue_table',
queue_user => 'streams_admin'
);
END;
/
-- 目标端执行，创建目标端队列，队列名为target_queue
BEGIN
DBMS_STREAMS_ADM.SET_UP_QUEUE(
queue_name => 'target_queue',
queue_table => 'target_queue_table',
queue_user => 'streams_admin'
);
END;
/4. 配置捕获进程
在源端配置捕获进程，指定需要捕获的变更范围，这里以同步scott用户下的所有表为例：
BEGIN
DBMS_STREAMS_ADM.ADD_TABLE_RULES(
table_name => 'scott.%', -- 同步scott用户下所有表
streams_type => 'capture',
streams_name => 'source_capture',
queue_name => 'streams_admin.source_queue',
include_dml => TRUE,
include_ddl => TRUE
);
END;
/5. 配置传播进程
在源端配置传播进程，将源端队列的LCR传输到目标端队列：
BEGIN
DBMS_STREAMS_ADM.ADD_TABLE_PROPAGATION_RULES(
table_name => 'scott.%',
streams_name => 'source_propagation',
source_queue_name => 'streams_admin.source_queue',
destination_queue_name => 'streams_admin.target_queue@target_db_link',
include_dml => TRUE,
include_ddl => TRUE
);
END;
/6. 配置应用进程
在目标端配置应用进程，读取目标端队列的LCR并应用到本地数据库：
BEGIN
DBMS_STREAMS_ADM.ADD_TABLE_RULES(
table_name => 'scott.%',
streams_type => 'apply',
streams_name => 'target_apply',
queue_name => 'streams_admin.target_queue',
include_dml => TRUE,
include_ddl => TRUE
);
END;
/7. 启动进程并验证
分别启动源端的捕获和传播进程，以及目标端的应用进程：
-- 源端启动捕获进程 BEGIN DBMS_CAPTURE_ADM.START_CAPTURE(capture_name => 'source_capture'); END; / -- 源端启动传播进程 BEGIN DBMS_PROPAGATION_ADM.START_PROPAGATION(propagation_name => 'source_propagation'); END; / -- 目标端启动应用进程 BEGIN DBMS_APPLY_ADM.START_APPLY(apply_name => 'target_apply'); END; /
验证同步效果：在源端scott用户下创建测试表并插入数据，查看目标端是否同步生成对应数据：
-- 源端执行 CREATE TABLE scott.test_streams(id NUMBER PRIMARY KEY, name VARCHAR2(50)); INSERT INTO scott.test_streams VALUES(1, '测试数据'); COMMIT; -- 目标端执行查询，查看是否有数据 SELECT * FROM scott.test_streams;
常见问题排查
- 如果同步没有生效，先查看各进程状态：
SELECT name, status FROM dba_capture;查看捕获进程状态，SELECT name, status FROM dba_apply;查看应用进程状态，状态为ENABLED表示正常运行。 - 若捕获进程报错，可查看
DBA_APPLY_ERROR表获取具体错误信息，根据错误提示调整规则或修复数据冲突。 - 确保源端和目标端的表结构一致，若存在结构差异，需要先同步表结构再启动DDL同步。
Oracle_Streams数据同步流复制数据库搭建修改时间：2026-06-04 01:16:44