当前位置:Gxlcms > mysql > oracle物化视图同步两个数据库间的数据

oracle物化视图同步两个数据库间的数据

时间:2021-07-01 10:21:17 帮助过:22人阅读

两个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 t

  两个oracle 10g 数据库,通过物化视图同步数据的具体实施流程

  源库是 192.168.1.81

  目标库是192.168.1.96

oracle物化视图同步两个数据库间的数据   三联

  统计库用的服务器是 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 userb.test1@DBLINK_SNAP_QUERY 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 userb.test1@DBLINK_SNAP_QUERY;

  ----------------------------

  创建完毕后在统计库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以便回收空间。

人气教程排行