两个oracle 10g 数据库,通过物化视图同步数据的具体实施流程
源库是 192.168.1.81
目标库是192.168.1.96
统计库用的服务器是 81
在统计库81上创建只读用户snap_query,用于查询
conn /as sysdba
create user snap_query identified by snap_query
default tablespace users
temporary tablespace temp;
grant connect to snap_query;
grant select on userb.test1 to snap_query;
为表建立实体化视图日志,要求这些表带有primary key
create materialized view log
on userb.test1
tablespace ts12
with primary key
excluding new values;
----------------------------
在测试库96上
以sys用户登陆,查看并修改job_queue_processes的值
sql> show parameter spfile --先检查是否是spfile(服务器端初始化文件)
sql> show parameter job_queue_process --如果为零 用以下命令修改
sql> alter system set job_queue_processes=10 scope=spfile;
创建表空间,用于存放物化视图内容(即test1)
create tablespace ts_event
datafile 'i:\ts_event_01.dbf' size 5000m,
'i:\ts_event_02.dbf' size 5000m;
创建用户
create user ts12_st identified by ts12_st_2010
default tablespace ts_event
temporary tablespace temp;
grant connect,resource,create snapshot to ts12_st;
grant create database link to ts12_st;
在tnsnames.ora中配置网络别名ts12tj连接到81
创建数据库链
conn ts12_st/ts12_st_2010
create database link dblink_snap_query
connect to snap_query identified by snap_query
using 'ts12tj';
测试:
select event_id,test1ype
from where rownum<10
创建物化视图
create materialized view test1_st2
build immediate
using index
refresh force
next sysdate 12/24
as
select
event_id,
event_code,
call_time,
tele_x,
tele_y,
test1ype,
event_content,
road_code,
place,
direction,
place_x,
place_y,
update_time,
main_assistant_road
from ;
----------------------------
创建完毕后在统计库81上执行
grant select on mlog$_test1 to snap_query;
在81上检查需要更新情况:
select '数据量 '||count(0) from test1 union
select '需更新量 '||count(0) from mlog$_test1;
----------------------------
在96上手工刷新物化视图方法:
exec dbms_mview.refresh('test1_st');
公司环境测试300万条耗时1 小时
经过长时间(1年)运行后,日志表mlog$_test1可能需要move以便回收空间。
阅读(5046) | 评论(0) | 转发(1) |