婚庆网站建设方案,国内新闻大事,网络规划设计师报名条件,网站开发的选题依据oracle的Stream解析–数据共享
在g版本常用#xff0c;如果是c版本项目一般都会选择goldengate#xff0c;比stream靠谱多了 Oracle中的stream是消息队列一种应用形式#xff0c;原理如下#xff1a;
收集oracle中的事件#xff0c;将事件保存在队列里#xff0c;然后将…oracle的Stream解析–数据共享
在g版本常用如果是c版本项目一般都会选择goldengate比stream靠谱多了 Oracle中的stream是消息队列一种应用形式原理如下
收集oracle中的事件将事件保存在队列里然后将事件发布给不同的订阅者。从管理员角度就是捕获oracle的redo日志然后将其通过网络传递到其他数据库来进行一种复制变化进而完成库级数据同步。 主要目的为数据共享不是灾容备份
#stream的实现方式#采取guard的logical standy标准但是在进行日志恢复阶段时不会将redo记录还原成sql语句而是还原成LCR进行发送然后再target端再执行LCR语句。可以保证数据的完整性。#限制#因为不是标准的logcial standy进行还原发送所以需要在两端分别查看stream是否支持将要发送的数据类型select * from dba_streams_newly_supported; #或者all开头select * from dba_streams_unsupported; #所有者表名不支持的原因#Stream环境下进行数据同步分为启动数据库 source database与终点数据库Target Database.在两恶搞数据库上各自创建队列source作为发送端target作为接收端
#队列创建后source端发起CP捕获进程使用logminer从日志中提取ddl dml语句创建并存储与逻辑变记录LCR。source会将LCR内同保存到本地发送队列中最后由pp传播进程发送到Target端streams使用前的注意点
确定复制集等级共三种复制等级表级、用户级、库级。用户最麻烦决定复制站点LCR的捕获方式 本地捕获 从source进行在联机日志与归档日志中取得LCR**下游捕获 ** 在target进行尽在归档日志中获取LCR 决定拓扑复制结构
stream数据共享创建实操—用户级复制
由于数据共享需要分成主库与从库所以本次创建测试环境本地不同global_name相同版本的11g数据库两套实例名称主库prince从库prince2安装时设置使用两个端口两套监听。假定使用同步的是tbbb用户。
下面是最重要的先看好了
#装配错误处理--消除本次配置所有信息不知道配到哪里出现了错误不小心敲错我允许你从头开始#主从执行需要先取消掉已经创建的进程 捕获、传播和应用进程至少不是enabled状态exec DBMS_STREAMS_ADM.remove_streams_configuration();不要本地装两套数据库去设置实验环境笔者一开始就是这样老是失败出现各种问最后弄个虚拟机有条件干脆再弄个电脑无痛安装我下面就不改流程纯粹图省事
#操作前注意事项两端都要进行检查。sys用户进行主从共用操作#1、启用oracle需要先确保两端安装logminer与开启归档日志#具体操作方式请参照其余文章此处不再赘述#2、两端数据库参数确认与修改alter system set global_namestrue scope both; #global_name置为有效可以先show parameter确认下alter system set aq_tm_processes2 scopeboth;#本参数非必须oracle默认一般就够可以确认下#以下为检查参数需要show parameteralter system set job_queue_processes 10 scopeboth;alter system set sga_target 300m scopespfile;alter system set open_links4 scopespfile;alter system set statistics_levelTYPICAL scopeboth #务必确认处于性能统计模式#以下为logminer确认参数alter system set _job_queue_interval1 scopespfile; #确认提高检查队列所需检查时间alter system set aq_tm_processes1;alter system set streams_pool_size200m scopeboth;#此参数一定要足够大防止内存过小使stream信息没有数据即时被同步。#启用追加日志如果数据库表段有主键就不被需要logminer时已经开启。可以show检查一下alter database add supplemental log data#只是同步部分表的表级同步可以进行追加alter table add supplement log group log_group_name(table_column_name) always;#3、预备条件#创建两个专门用于stream管理表空间和用户给予权限,在两个不同的主从库上分别进行#主库CREATE TABLESPACE streams_tbs DATAFILE E:/ORACLE/prince/streams_tbs001.dbf SIZE 100M REUSE AUTOEXTEND ON MAXSIZE UNLIMITED; create user streamadmin1 identified by streamadmin1 DEFAULT TABLESPACE streams_tbsGRANT DBA to streamadmin1;#dba权限exec DBMS_STREAMS_AUTH.GRANT_ADMIN_PRIVILEGE(streamadmin1) #赋予stream管理权限#从库CREATE TABLESPACE streams_tbs DATAFILE E:/ORACLE/prince2/streams_tbs001.dbf SIZE 100M REUSE AUTOEXTEND ON MAXSIZE UNLIMITED; create user streamadmin2 identified by streamadmin2 DEFAULT TABLESPACE streams_tbsGRANT DBA to streamadmin2;#dba权限exec DBMS_STREAMS_AUTH.GRANT_ADMIN_PRIVILEGE(streamadmin2) #赋予stream管理权限#在这两个数据库prince和prince2的tnsname.ora分别加上对端的链接实例名称用于后续创建dblink使用prince2 #假设prince主库使用1523端口那主库下的tnsname.ora就添加如下配置(DESCRIPTION (ADDRESS_LIST (ADDRESS (PROTOCOL TCP)(HOST localhost)(PORT 1524))#对端使用的端口与ip我是本地装了两套所以时localhost)(CONNECT_DATA (SID prince2)#连接实例名对端实例名(SERVER DEDICATED)#看情况指定))#两端创建测试用户已经有的就不用了CREATE USER TBBB IDENTIFIED BY TBBB ;grant dba to tbbb;#这边本次测试没有限制我直接dba省事#生产环境的还需要额外将主库用户的数据和结构主要是结构导入到从库用户里去千万注意我这测试环境都是null用户所以无所谓
exp useridtbb/tbbprince fileE:\oracle object_consistenty rowsy
imp useridtbb/tbbprince2 fileE:\oracle ignorey commity logE:\oracle\123.log streams_instantiationy fromusertbb tousertbb #不同用户还需要做映射请按照步骤同步进行创建
#stream创建流程-主库source端
#1、创建远程dblink#以之前创建的stream管理员账户登录create database link prince2 connect to streamadmin2 identified by streamadmin2 using prince2; #对端的用户名密码 link指定最好与连接实例名称一致否则容易报错。使用tnsname的prince进行连接。#成功后进行如下方式确认是否成功conn streamadmin2/streamadmin2 #连接到从库select * from global_name#通过global_name确认是否到达从库无误后exit重新进入主库#2、创建stream队列-主库master流队列
exec DBMS_STREAMS_ADM.SET_UP_QUEUE(queue_table TBBBSOURCE_QUEUE_TABLE, queue_name TBBBSOURCE_QUEUE,queue_user STREAMADMIN1);#检查是否成功创建队列select owner,queue_table,name from dba_queues where ownerSTREAMADMIN;#3、主库创建捕获进程
exec dbms_streams_adm.add_schema_rules(schema_name tbbb,streams_type capture,streams_name capture_tbbb,queue_name STREAMADMIN1.TBBBSOURCE_QUEUE,include_dml true,include_ddl true,include_tagged_lcr false,source_database null,inclusion_rule true);select CAPTURE_NAME,QUEUE_NAME,START_SCN,STATUS,CAPTURE_TYPE from dba_capture;
select * from ALL_CAPTURE_PREPARED_SCHEMAS; #确认进程是否创建成功exec DBMS_CAPTURE_ADM.START_CAPTURE(capture_name CAPTURE_TBB);select capture_name,status from dba_capture;exec dbms_capture_adm.stop_capture(capture_name CAPTURE_TBB); #停止进程#4、创建传播进程
exec DBMS_STREAMS_ADM.ADD_SCHEMA_PROPAGATION_RULES(schema_name tbbb, streams_name capture_tbbb, source_queue_name STREAMADMIN1.TBBBSOURCE_QUEUE,destination_queue_name STREAMADMIN2.TBBBTARGET_QUEUEprince2,include_dml true,include_ddl true,source_database prince,inclusion_rule true,queue_to_queue true);#指定的是从库target连接建议在从库target创建完apply进程后进行我有碰到报错select * from all_propagation #确认传播进程情况报错信息和状态会在这里显示select PROPAGATION_NAME,SOURCE_QUEUE_NAME,DESTINATION_QUEUE_NAME,DESTINATION_DBLINK,STATUS from dba_propagation;exec dbms_propagation_adm.start_propagation(capture_tbbb);#启动传播进程后续使用exec dbms_propagation_adm.stop_propagation(capture_tbbb);#关闭传播进程exec dbms_aqadm.alter_propagation_schedule(queue_name STREAMADMIN1.TBBBSOURCE_QUEUE,destination prince2,latency 0); #消除进程休眠时间变为实时传播。有报错大概率dblink不对我本地装两套有碰见oci导致的。
#stream创建流程-从库target端
#1、创建远程dblink#以之前创建的stream管理员账户登录create database link prince connect to streamadmin1 identified by streamadmin1 using prince;#提示成功即可因为是从库我们无法远程到主库#2、创建stream队列-从库backup流队列 exec dbms_streams_adm.set_up_queue(queue_tableprince2_queue_table,queue_nameprince2_queue);#检查是否成功创建队列select owner,queue_table,name from dba_queues --name TCOPYTARGET_QUEUEselect owner,queue_table,object_type from dba_queue_tables #两个必须都有否则一定失败#3、创建apply进程exec DBMS_STREAMS_ADM.ADD_SCHEMA_RULES(schema_name tbbb,streams_type apply,streams_name tbbb_apply_stream,queue_name STREAMADMIN2.TBBBTARGET_QUEUE,include_dml true,include_ddl true,include_tagged_lcr false,source_database prince,inclusion_rule true);select apply_name,queue_name,status from dba_apply #确认状态exec dbms_apply_adm.start_apply(apply_name tbbb_apply_stream);#进程启动与停止exec dbms_apply_adm.stop_apply(apply_name tbbb_apply_stream);#启动stream进程#从库启动 apply进程exec dbms_apply_adm.start_apply(apply_name tbbb_apply_stream);#主库启动捕获进程和传播进程exec DBMS_CAPTURE_ADM.START_CAPTURE(capture_name CAPTURE_TBB);exec dbms_propagation_adm.start_propagation(capture_tbbb);#检验方式主库用户创建、crud等等操作完后去从库用户检查不是实时的就先#dblink错误处理
select * from dba_db_links;
drop public database link name;
#name为语句查出的db_link名称只能删除本用户创建dblink其他用户的就算你是dba也动不了
stream数据共享创建实操—库级复制
#1、确认参数 且处于归档模式
alter system set aq_tm_processes4 scopespfile;
alter system set job_queue_processes5 scopespfile;
alter system set global_namestrue scopespfile;
alter system set streams_pool_size51m scopespfile;
#2、还是在主库和目标库创建连接是改tnsname还是直接指定随你
#3、创建主从库的stream管理员
#4、主从库创建文件夹
create directory dir_DBA as D:/Stream/prince;
create directory dir_DBA2 as D:/Stream/prince2;
#5、主库source执行
dbms_streams_adm.maintain_global(source_directory_object dir_DBA,destination_directory_object dir_DBA2,source_databaseprince,destination_database prince2,perform_actionstrue,include_ddltrue,instantiationDBMS_STREAMS_ADM.INSTANTIATION_FULL_NETWORK);
#6、然后就完了
