Oracle 流stream数据的复制

Oracle数据库提供了复制流(Streams)的功能，可以实现数据的实时复制。以下是一个简单的例子，展示如何配置和使用Oracle Streams进行数据复制。

1. 确保数据库已经启用了Oracle Streams特性。
2. 配置数据库连接。
3. 创建主数据库（生产数据库）和从数据库（复制目标数据库）之间的复制。

以下是一个基本的步骤，用于配置Oracle Streams：

-- 在主数据库上执行
-- 创建Streams的管理用户（如果尚未创建）
CREATE USER streams_admin IDENTIFIED BY password;
GRANT DBA TO streams_admin;
 
-- 配置主数据库
-- 启用归档日志模式
ALTER DATABASE FORCE LOGGING;
-- 启用主备制
ALTER SYSTEM FORCE LOGGING;
-- 启用实例初始化参数
ALTER SYSTEM SET aq_tm_processes=2 SCOPE=BOTH;
ALTER SYSTEM SET global_names=TRUE SCOPE=BOTH;
ALTER SYSTEM SET job_queue_processes=10 SCOPE=BOTH;
ALTER SYSTEM SET parallel_max_servers=20 SCOPE=BOTH;
ALTER SYSTEM SET streams_pool_size=25M SCOPE=BOTH;
-- 创建Streams池
CREATE POOL stream_pool MINIMUM 50000 CURRENT 50000 MAXIMUM 50000 INCREMENT 100;
 
-- 在从数据库上执行
-- 配置实例初始化参数
ALTER SYSTEM SET global_names=TRUE SCOPE=BOTH;
ALTER SYSTEM SET job_queue_processes=10 SCOPE=BOTH;
ALTER SYSTEM SET parallel_max_servers=20 SCOPE=BOTH;
ALTER SYSTEM SET streams_pool_size=25M SCOPE=BOTH;
-- 创建Streams池
CREATE POOL stream_pool MINIMUM 50000 CURRENT 50000 MAXIMUM 50000 INCREMENT 100;
 
-- 在主数据库上执行
-- 创建Streams的队列
BEGIN
  DBMS_STREAMS_ADM.CREATE_QUEUE(
    queue_name          => 'streams_queue',
    queue_table         => 'streams_queue_table',
    queue_user          => 'streams_admin',
    batch_size          => 100,
    batch_delay         => 0,
    log_on_error        => TRUE,
    purge_policy        => DBMS_STREAMS_ADM.purge_policy_manual,
    execution_schedule  => NULL);
END;
/
 
-- 在主数据库上执行
-- 创建Streams的转换
BEGIN
  DBMS_STREAMS_ADM.CREATE_TRANSFORMATION(
    transformation_name => 'streams_trans',
    queue_name          => 'streams_queue',
    source_database     => DBMS_STREAMS_ADM.source_database_config,
    destination_database => DBMS_STREAMS_ADM.destination_database_config,
    included_tables     => 'included_tables_list',
    excluded_tables     => 'excluded_tables_list',
    transform_function  => 'transform_function_name');
END;
/
 
-- 在主数据库上执行
-- 启用Advanced Replication
EXEC DBMS_STREAMS_ADM.set_up_replication(
  local_streams_administrator => 'streams_admin',
  remote_streams_administrator => 'streams_admin@remote_db',