一、在目标库建立DBLINK
目标库操作：
主机B中建立TNS(tnsname.ora),也可以使用netca建立TNS
[oracle@rac1 ~]$ cd /u01/app/oracle/product/11.2.0/db_1/network/admin/
[oracle@rac1 admin]$ vi tnsnames.ora
ORCL=
(DESCRIPTION =
(ADDRESS_LIST =
(ADDRESS = (PROTOCOL = TCP)(HOST = 192.168.67.163)(PORT = 1521))
)
(CONNECT_DATA =
(SERVICE_NAME = ORCL)
)
)
[oracle@rac1 admin]$ !sql
sqlplus '/ as sysdba'
SQL*Plus: Release 11.2.0.1.0 Production on Tue Jan 20 09:17:10
Copyright (c) 1982, , Oracle. All rights reserved.
Connected to:
Oracle Database 11g Enterprise Edition Release 11.2.0.1.0 - 64bit Production
With the Partitioning, Real Application Clusters, Automatic Storage Management, OLAP,
Data Mining and Real Application Testing options
SQL> grant create public database link,create database link to sguap206;
SQL> conn sguap206/sguap206
Connected.
SQL> create public database linksguap_linkconnect tosguap206identified bysguap206using 'ORCL';
link名称数据库A的用户数据库A的密码
Database link created.
SQL> select owner,object_name from dba_objects where object_type='DATABASE LINK';
OWNER OBJECT_NAM
------------------------------ ----------
PUBLIC SGUAP_LINK
SQL> SELECT SYSDATE FROM DUAL@SGUAP_LINK;
SYSDATE
---------
20-JAN-15
至此DBLIKE测试成功。
二、创建物化视图对表进行增量同步
1、在源库上建立物化视图日志
SQL> CREATE MATERIALIZED VIEW LOG ON PF_ALARM_TYPE WITH SEQUENCE, ROWID (TYPE_ID,TYPE_INFO) INCLUDING NEW VALUES;表的列
Materialized view log created
使用rowid,sequence捕获数据变化情况。
注意：加上including new values子句，是为了记录数据修改前的值。
2、在目标库上创建定时增量更新的物化视图
SQL> create materialized view PF_ALARM_TYPE
2 refresh fast on demand
3 start with sysdate next sysdate+1/288 with rowid
4 as
5 select * from PF_ALARM_TYPE@SGUAP_LINK;
create materialized view PF_ALARM_TYPE
*
ERROR at line 1:
ORA-00955: name is already used by an existing object
报错原因：说明你创建的物化视图名称和表名相同，可以修改物化视图的名称或者把那个表删除(谨慎)。
我这里使用删除表的操作(谨慎)。
SQL> create materialized view PF_ALARM_TYPE
2 refresh fast on demand
3 start with sysdate next sysdate+1/288 with rowid
4 as
5 select * from PF_ALARM_TYPE@SGUAP_LINK;
Materialized view created.
如果跨库跨平台时,有时必须要使用with primary key，物化视图对应的表上没有主键，如果需要索引可以另行添加。
SQL> select * from PF_ALARM_TYPE;
TYPE_ID TYPE_INFO
--------------------------------- --------------------
1无效卡
2门开超时
3强制开门
4反潜回
5胁迫开门
6互锁管制
7火警
8脱机
9控制器拆卸
9 rows selected
发现数据第一次成功同步到目标库。
测试insert:在源库插入一条数据，查看目标库。
SQL> INSERT INTO PF_ALARM_TYPE VALUES(10 ,'TEST');
1 row inserted
SQL> COMMIT;
Commit complete
目标库查看：
发现还没有同步过来，等待5分钟
SQL> SELECT * FROM PF_ALARM_TYPE;
TYPE_ID TYPE_INFO
--------------------------------- ---------------
1无效卡
2门开超时
3强制开门
4反潜回
5胁迫开门
6互锁管制
7火警
8脱机
9控制器拆卸
9 rows selected
SQL> SELECT * FROM PF_ALARM_TYPE;
TYPE_ID TYPE_INFO
--------------------------------- --------------
1无效卡
2门开超时
3强制开门
4反潜回
5胁迫开门
6互锁管制
7火警
8脱机
9控制器拆卸
10 TEST
10 rows selected
发现刚刚在源库插入的数据已经同步到目标库上。
测试update:在源库更新一条数据，查看目标库。
SQL> update PF_ALARM_TYPE set type_info='OK' where type_info='TEST';
1 row updated
SQL> commit;
Commit complete
SQL> select * from PF_ALARM_TYPE;
TYPE_ID TYPE_INFO
--------------------------------- ---------------
1无效卡
2门开超时
3强制开门
4反潜回
5胁迫开门
6互锁管制
7火警
8脱机
9控制器拆卸
10 OK
rows selected
目标库查看
SQL> SELECT * FROM PF_ALARM_TYPE;
TYPE_ID TYPE_INFO
--------------------------------- -------------------
1无效卡
2门开超时
3强制开门
4反潜回
5胁迫开门
6互锁管制
7火警
8脱机
9控制器拆卸
10 OK
10 rows selected
测试delete:在源库删除一条数据，查看目标库。
SQL> DELETE PF_ALARM_TYPE WHERE TYPE_ID=10;
1 row deleted
SQL> COMMIT;
Commit complete
SQL> SELECT * FROM PF_ALARM_TYPE;
TYPE_ID TYPE_INFO
--------------------------------- -------------------
1无效卡
2门开超时
3强制开门
4反潜回
5胁迫开门
6互锁管制
7火警
8脱机
9控制器拆卸
9 rows selected
目标库查看同步情况：
SQL> SELECT * FROM PF_ALARM_TYPE;
TYPE_ID TYPE_INFO
--------------------------------- --------------
1无效卡
2门开超时
3强制开门
4反潜回
5胁迫开门
6互锁管制
7火警
8脱机
9控制器拆卸
9 rows selected
发现源库删除的数据目标库也删除了。
