如何跨Oracle数据库实现表级别的实时同步

一 前言

这个问题是上一篇文章《Oracle跨数据库实现定时同步指定表中的数据》中所提问题的进一步延伸。考虑到对数据的实时性要求比较高，设置成定时同步，有点不妥，需要改善升级更改为实时同步。

下面介绍到的方式，严格意义上说，并没有实现实时同步。是通过Oracle数据库创建同义词+DBlink的方式，来建立远程映射。在查看数据时，直接去远程查询源库中的表。

而我一直关注的是如何进行同步数据，却没有考虑到可以建立映射。另外，还有一点就是需要交代，就是同步到目标数据库中的表，不进行增删改 *** 作，只进行查询的 *** 作，这也是可以使用同义词方式解决问题的关键。

这种解决思路的出现，多亏了在CSDN问答时，热心网友的回答，下面就是问题详情描述。

二 问题描述

有两个Oracle数据库，分别布置在不同的服务器上，系统均为windows2003；

这里暂且说成是一个主数据库和从数据库：

(1) 主数据库:oracle_A；

(2) 从数据库:oracle_B；

在oracle_A中有一个表table_A与oracle_B中的表table_B结构相同；

我是处在oracle_B，oracle_A数据库分配给我有一个访问oracle_A表table_A的用户，该用户只拥有查询的权限；

另外，需要说明的一点，就是在oracle_B处,只需对table_B表进行查询的 *** 作，不进行其他增删改的 *** 作。

场景介绍完了，我的问题的是,如何在oracle_A中表table_A发生变化时,实时更新同步到oracle_B的table_B中

我原来的处理方式:

通过建立远程连接DBLink+JOB定时任务+存储过程的方式,实现了定时同步更新,但不能做到实时同步。

三 采用同义词+DB_Link的方式结果步骤

之所以能够选择采用同义词的方式，处理这个问题。主要还是源于在问题描述中提到一个点，那就是我们只需要对同步后的表进行查询 *** 作。这点是使用同义词方式的重要要素。

下面详细模拟一下整个实验测试的过程：

（1）首先在Oracle_A端创建一个对table_A只有查询功能的用户

<1> 创建用户

sqlplus /nolog

conn /as sysdba;

create user username identified by password;

<2> 查看所有的用户列表

用户创建完成后,查看用户是否创建成功

select from all_users;

<3>授予权限

为了能够保证能够登陆,必须赋予如下权限

--授予username用户创建session的权限,即登陆权限

grant create session to username;

--授予username用户使用表空间的权限

grant unlimited tablespace to username;

--oracle对权限管理比较严谨,普通用户之间也是默认不能互相访问的,需要互相授权

--如果scott用户要授权给username用户查看自己的test表的权限;

sqlplus scott/tiget@localhost:1521/orcl

--授予username用户查看指定的权限

grant select on test to username;

--撤销权限

基本语法同grant,关键字为revoke;

（2）验证用户是否可以成功登录，并进行访问授权的表

--使用sqlplus登录，并进行查询

sqlplus username/password@localhost:1521/orcl;

select from scotttest;

注意：查询表时，务必带上用户名，说明是哪个用户下的表。

（3）创建远程连接DB_Link

<1> 创建远程连接 db_link

create public database link db32　connect to tianzhi_test identified by "tianzhi_test" using '192168566:1521/ORCL'

<2> 测试远程连接是否成功

select from tianzhi_smartzh_item_news@db32;

（4）在Oracle_B端创建同义词

<1> 使用sqlplus登录自己的用户

sqlplus tianzhi_smart/tianzhi_smart@localhost:1521/orcl

<2> 创建同义词

create or replace public synonym TEST1130 for scottTEST@db32;

<3> 查询测试

select from TEST1130;

可以看到这与在Oracle_A源数据库中查到的table_A表中的数据一样

注意事项:

当远程查询的数据库中包含BLOB字段时,会报出如下错误

ORA-22992: 无法使用从远程表选择的 LOB 定位器

当出现这个错误的时候，那是因为跨库连接查询中的表中存在BLOB类型的字段，所以一定要注意，所有表中存在blob类型字段，

不能用 select from 连接的表

不能将blob类型的字段出现在脚本中。

如果这些blob类型的字段一定要导过来，可以先建立临时表再插入本地表，方法如下在pl/sql中执行

第一步 建临时表

create global temporary table foo ( X BLOB )

on commit delete rows;

第二步 插入本地表

insert into foo select blobcolumn from remoteTable@dl_remote ;

方法一：

在 SQL Server 里面， 创建一个 针对 MySQL 的数据库链接。

然后 在 SQL Server 里面， 设定一个 数据库作业。 定时向 MySQL数据库链接 同步数据。

方法二：

不同服务器数据库之间的数据 *** 作 --创建链接服务器 exec sp_addlinkedserver 'ITSV ', '', 'SQLOLEDB ', '远程服务器名或ip地址 'exec sp_addlinkedsrvlogin 'ITSV ', 'false ',null, '用户名 ', '密码'--查询示例 selectfrom ITSV数据库名dbo表名 --导入示例 selectinto 表from ITSV数据库名dbo表名 --以后不再使用时删除链接服务器 exec sp_dropserver 'ITSV ', 'droplogins '--连接远程/局域网数据(openrowset/openquery/opendatasource) --1、openrowset --查询示例 selectfromopenrowset( 'SQLOLEDB ', 'sql服务器名 '; '用户名 '; '密码',数据库名dbo表名) --生成本地表 selectinto 表fromopenrowset( 'SQLOLEDB ', 'sql服务器名 '; '用户名 '; '密码',数据库名dbo表名) --把本地表导入远程表 insertopenrowset( 'SQLOLEDB ', 'sql服务器名 '; '用户名 '; '密码',数据库名dbo表名) selectfrom 本地表 --更新本地表 update b set b列A=a列A fromopenrowset( 'SQLOLEDB ', 'sql服务器名 '; '用户名 '; '密码',数据库名dbo表名)as a innerjoin 本地表 b on acolumn1=bcolumn1 --openquery用法需要创建一个连接 --首先创建一个连接创建链接服务器 exec sp_addlinkedserver 'ITSV ', '', 'SQLOLEDB ', '远程服务器名或ip地址 '--查询selectFROMopenquery(ITSV, 'SELECT FROM 数据库dbo表名 ') --把本地表导入远程表 insertopenquery(ITSV, 'SELECT FROM 数据库dbo表名 ') selectfrom 本地表 --更新本地表 update b set b列B=a列B FROMopenquery(ITSV, 'SELECT FROM 数据库dbo表名 ') as a innerjoin 本地表 b on a列A=b列A --3、opendatasource/openrowset SELECTFROMopendatasource( 'SQLOLEDB ', 'Data Source=ip/ServerName;User ID=登陆名;Password=密码 ' )testdboroy_ta --把本地表导入远程表 insertopendatasource( 'SQLOLEDB ', 'Data Source=ip/ServerName;User ID=登陆名;Password=密码 ')数据库dbo表名 selectfromSQL code 用强制订阅实现数据库同步 *** 作 大量和批量的数据可以用数据库的同步机制处理: // 说明：为方便 *** 作,所有 *** 作均在发布服务器(分发服务器)上 *** 作,并使用推模式在客户机器使用强制订阅方式。 有疑问联系作者：zlp321001@hotmailcom 测试通过 //--1:环境服务器环境: 机器名称： ZehuaDb *** 作系统：Windows 2000 Server 数据库版本：SQL 2000 Server 个人版 客户端机器名称：Zlp *** 作系统：Windows 2000 Server 数据库版本：SQL 2000 Server 个人版 --2:建用户帐号在服务器端建立域用户帐号我的电脑管理->本地用户和组->用户->建立UserName:zlp UserPwd:zlp --3:重新启动服务器MSSQLServer我的电脑->控制面版->管理工具->服务->MSSQLServer 服务 (更改为：域用户帐号,我们新建的zlp用户 /zlp,密码:zlp) --4:安装分发服务器A:配置分发服务器工具->复制->配置发布、订阅服务器和分发->下一步->下一步(所有的均采用默认配置) B:配置发布服务器工具->复制->创建和管理发布->选择要发布的数据库(SZ)->下一步->快照发布->下一步-> 选择要发布的内容->下一步->下一步->下一步->完成C:强制配置订阅服务器(推模式,拉模式与此雷同) 工具->复制->配置发布、订阅服务器和分发->订阅服务器->新建->SQL Server数据库->输入客户端服务器名称(ZLP)->使用SQL Server 身份验证(sa,空密码)->确定->应用->确定D:初始化订阅复制监视器->发布服务器(ZEHUADB)->双击订阅->强制新建->下一步->选择启用的订阅服务器->ZLP-> 下一步->下一步->下一步->下一步->完成--5:测试配置是否成功复制监视器->发布服务器(ZEHUADB)->双击SZ:SZ->点状态->点立即运行代理程序查看：复制监视器->发布服务器(ZEHUADB)->SZ:SZ->选择ZLP:SZ(类型强制)->鼠标右键->启动同步处理如果没有错误标志(红色叉)，恭喜您配置成功 --6:测试数据 --在服务器执行:选择一个表，执行如下SQL insertinto WQ_NEWSGROUP_S select'测试成功',5 复制监视器->发布服务器(ZEHUADB)->SZ:SZ->快照->启动代理程序 ->ZLP:SZ(强制)->启动同步处理 去查看同步的 WQ_NEWSGROUP_S 是否插入了一条新的记录 测试完毕，通过。

1、数据实时备份同步，数据库服务器出问题时我们也有其正常工作时的备份

2、数据实时备份同步，一台服务器负载不起时，可以用来做负载均衡

3、数据实时备份同步，数据库服务器可以无间断，无损失迁移

4、主服务器被攻击或当机时另一台服务同步机可以应急

a、配置发布服务器

b、选中指定 [服务器] 节点

c、从 [工具] 下拉菜单的 [复制] 子菜单中选择 [发布、订阅服务器和分发] 命令

d、系统d出一个对话框点 [下一步] 然后看着提示 *** 作

--直到"指定快照文件夹"

--在"快照文件夹"中输入准备工作中创建的目录: \\<服务器名>\pub

一[下一步] 直 *** 作到完成。

e、当完成了出版服务器的设置以后系统会为该服务器的树形结构中添加一个复制监视器

同时也生成一个分发数据库(distribution)

1、如果RDS上的数据没有发生增删改的 *** 作的话，可以生成物理备份或者逻辑备份，然后将物理备份和逻辑备份通过Xtrabackup或者mysqldump将数据导入到自建库。

2、如果在物理备份已经生成后对于数据库仍然有增删改的 *** 作的话，则需要您在恢复物理备份后还需要追加后续的binlog文件，可以通过API/控制台获取binlog文件去追加增量数据。

这里有一个非常需要注意的一点是在解压出来物理备份文件后除了数据和索引文件外还有得到如下图中的一些文件。

由于在物理备份上应用binlog是需要记录binlog的pos点的，所有的RDS都是采用主备架构保证高可用性的，为保证主库正常对外提供服务，备份 *** 作是在从库上执行的，但是生成出来的binlog文件却既有可能是主库或者从库上生成（两个binlog文件的pos点是不一致的）。提供给用户的也可能是这里面的任意一份，因此在物理备份文件中给用户提供了两个binlog文件的pos点，如下图：

用户在应用binlog的时候需要两个pos点都测试一下，哪个pos点可以在binlog中找到从这个pos点开始应用binlog。 

3、用户想要将RDS上的增量数据同步在自建库的binlog上可以使用DTS的数据订阅功能，可以通过SDK消费增量数据即可再自己应用该数据。

MySQL数据同步主要有三种方式:

1利用MySQL自身的数据库同步功能

2利用MySQL数据库的特性(数据库存在固顶目录,并且以文件形式存储),进行数据库目录同步以达到数据同步目的

3利用专用的MySQL数据库同步软件

1利用MySQL自身的数据库同步功能：

MySQL从32315版本以后提供数据库复制功能。利用该功能可以实现两个数据库同步，主从模式，互相备份模式的功能

数据库同步复制功能的设置都在mysql的设置文件中体现。mysql的配置文件（一般是mycnf），在unix环境下在/etc/mysql/mycnf或者在mysql用户的home目录下的mycnf。

windows环境中，如果c:根目录下有mycnf文件则取该配置文件。当运行mysql的winmysqladminexe工具时候，该工具会把c:根目录下的mycnf命名为mycnfbak。并在winnt目录下创建myini。mysql服务器启动时候会读该配置文件。所以可以把mycnf中的内容拷贝到myini文件中，用myini文件作为mysql服务器的配置文件。

设置方法：

设置范例环境：

*** 作系统：window2000professional

mysql：404-beta-max-nt-log

Aip:10101022

Bip:10101053

A:设置

1增加一个用户最为同步的用户帐号：

GRANTFILEONTObackup@'10101053'IDENTIFIEDBY‘1234’

2增加一个数据库作为同步数据库：

createdatabasebackup

B:设置

1增加一个用户最为同步的用户帐号：

GRANTFILEONTObackup@'10101022'IDENTIFIEDBY‘1234’

2增加一个数据库作为同步数据库：

createdatabasebackup

主从模式：A->B

A为master

修改Amysql的myini文件。在mysqld配置项中加入下面配置：

server-id=1

log-bin

#设置需要记录log可以设置log-bin=c:mysqlbakmysqllog设置日志文件的目录，

#其中mysqllog是日志文件的名称，mysql将建立不同扩展名，文件名为mysqllog的几个日志文件。

binlog-do-db=backup#指定需要日志的数据库

重起数据库服务。

用showmasterstatus命令看日志情况。

B为slave

修改Bmysql的myini文件。在mysqld配置项中加入下面配置：

server-id=2

master-host=10101022

master-user=backup#同步用户帐号

master-password=1234

master-port=3306

master-connect-retry=60预设重试间隔60秒

replicate-do-db=backup告诉slave只做backup数据库的更新

重起数据库

用showslavestatus看同步配置情况。

注意：由于设置了slave的配置信息，mysql在数据库目录下生成masterinfo

所以如有要修改相关slave的配置要先删除该文件。否则修改的配置不能生效。

双机互备模式。

如果在A加入slave设置，在B加入master设置，则可以做B->A的同步。

在A的配置文件中mysqld配置项加入以下设置：

master-host=10101053

master-user=backup

master-password=1234

replicate-do-db=backup

master-connect-retry=10

在B的配置文件中mysqld配置项加入以下设置：

log-bin=c:mysqllogmysqllog

binlog-do-db=backup

注意：当有错误产生时err日志文件。同步的线程退出，当纠正错误后要让同步机制进行工作，运行slavestart

重起AB机器，则可以实现双向的热备。

测试：

向B批量插入大数据量表AA（1872000）条

A数据库每秒钟可以更新2500条数据。

2数据库目录同步：

方法和文件同步一样,设置好需要同步的两个数据库目录就可以了!

缺点很明显,数据同步只能单向进行,可以作为备份方案

3用专用的MySQL同步软件进行同步 ：

这方面的软件有SQLBalance和MyReplicator,优点是方便直观,还有很多争强功能!

缺点和2一样,只能单项同步!

当然也可以修改镜像网站的程序为提交数据到母数据库,读取则在当前镜像下的数据,不过,修改起来麻烦!普通用户修改也非常难!呵呵,大家了解一下就可以!给大家一个思路!有能力的朋友可以试试阿!

4关于MySQL论坛的数据同步

由于数据来源的不可控制(不好表达),论坛数据是实时的,而且还要考虑来自镜像论坛的数据,如何实现镜像论坛与母论坛数据同步呢

用1中介绍的MySQL自带的数据库同步功能互相备份模式就可以实现的!

不过,具体的应用我没有测试!稳定性不敢保证!

有能力的朋友推荐用下面这种思路来同步,相对来说减少点效率,但能减少发生的错误!

比如镜像论坛数据同步:

1母论坛和镜像论坛的数据全写在母论坛数据库里,主从模式,读取只在本地读取,这个需要修改程序!

2每次写数据,都同时提交到两个数据库中,安全,但是效率很差,也得修改程序!

MSSQL

MSSQL数据同步利用数据库复制技术实现数据同步更新(来自网络,也是非常完美的教程)

复制的概念 ：

复制是将一组数据从一个数据源拷贝到多个数据源的技术，是将一份数据发布到多个存储站点上的有效方式。使用复制技术，用户可以将一份数据发布到多台服务器上，从而使不同的服务器用户都可以在权限的许可的范围内共享这份数据。复制技术可以确保分布在不同地点的数据自动同步更新，从而保证数据的一致性。

SQL复制的基本元素包括

出版服务器、订阅服务器、分发服务器、出版物、文章

SQL复制的工作原理

SQLSERVER主要采用出版物、订阅的方式来处理复制。源数据所在的服务器是出版服务器，负责发表数据。出版服务器把要发表的数据的所有改变情况的拷贝复制到分发服务器，分发服务器包含有一个分发数据库，可接收数据的所有改变，并保存这些改变，再把这些改变分发给订阅服务器

SQLSERVER复制技术类型

SQLSERVER提供了三种复制技术，分别是：

1、快照复制（呆会我们就使用这个）

2、事务复制

3、合并复制

只要把上面这些概念弄清楚了那么对复制也就有了一定的理解。接下来我们就一步一步来实现复制的步骤。

第一先来配置出版服务器

(1)选中指定[服务器]节点

(2)从[工具]下拉菜单的[复制]子菜单中选择[发布、订阅服务器和分发]命令

(3)系统d出一个对话框点[下一步]然后看着提示一直 *** 作到完成。

(4)当完成了出版服务器的设置以后系统会为该服务器的树形结构中添加一个复制监视器。同时也生成一个分发数据库(distribution)

第二创建出版物

(1)选中指定的服务器

(2)从[工具]菜单的[复制]子菜单中选择[创建和管理发布]命令。此时系统会d出一个对话框

(3)选择要创建出版物的数据库，然后单击[创建发布]

(4)在[创建发布向导]的提示对话框中单击[下一步]系统就会d出一个对话框。对话框上的内容是复制的三个类型。我们现在选第一个也就是默认的快照发布(其他两个大家可以去看看帮助)

(5)单击[下一步]系统要求指定可以订阅该发布的数据库服务器类型，SQLSERVER允许在不同的数据库如ORACLE或ACCESS之间进行数据复制。但是在这里我们选择运行"SQLSERVER2000"的数据库服务器

(6)单击[下一步]系统就d出一个定义文章的对话框也就是选择要出版的表

(7)然后[下一步]直到 *** 作完成。当完成出版物的创建后创建出版物的数据库也就变成了一个共享数据库。

第三设计订阅

(1)选中指定的订阅服务器

(2)从[工具]下拉菜单中选择[复制]子菜单的[请求订阅]

(3)按照单击[下一步] *** 作直到系统会提示检查SQLSERVER代理服务的运行状态，执行复制 *** 作的前提条件是SQLSERVER代理服务必须已经启动。

(4)单击[完成]。完成订阅 *** 作。

完成上面的步骤其实复制也就是成功了。但是如何来知道复制是否成功了呢？这里可以通过这种方法来快速看是否成功。展开出版服务器下面的复制——发布内容——右键发布内容——属性——击活——状态然后点立即运行代理程序接着点代理程序属性击活调度把调度设置为每一天发生，每一分钟，在0：00：00和23：59：59之间。接下来就是判断复制是否成功了打开C:/ProgramFiles/MicrosoftSQLServer/MSSQL/REPLDATA/unc/XIAOWANGZI_database_database下面看是不是有一些以时间做为文件名的文件夹差不多一分中就产生一个。要是你还不信的话就打开你的数据库看在订阅的服务器的指定订阅数据库下看是不是看到了你刚才所发布的表—

一个手工同步的方案

--定时同步服务器上的数据

--例子:

--测试环境,SQLServer2000,远程服务器名:xz,用户名为:sa,无密码,测试数据库:test

--服务器上的表(查询分析器连接到服务器上创建)

createtable[user](idintprimarykey,numbervarchar(4),namevarchar(10))

--以下在局域网(本机 *** 作)

--本机的表,state说明:null表示新增记录,1表示修改过的记录,0表示无变化的记录

ifexists(selectfromdbosysobjectswhereid=object_id(N'[user]')andOBJECTPROPERTY(id,N'IsUserTable')=1)

droptable[user]

GO

createtable[user]

(idintidentity(1,1),numbervarchar(4),namevarchar(10),statebit)

go

--创建触发器,维护state字段的值

createtriggert_stateon[user]

afterupdate

as

update[user]setstate=1

from[user]ajoininsertedbonaid=bid

whereastateisnotnull

go

--为了方便同步处理,创建链接服务器到要同步的服务器

--这里的远程服务器名为:xz,用户名为:sa,无密码

ifexists(select1frommastersysserverswheresrvname='srv_lnk')

execsp_dropserver'srv_lnk','droplogins'

go

execsp_addlinkedserver'srv_lnk','','SQLOLEDB','xz'

execsp_addlinkedsrvlogin'srv_lnk','false',null,'sa'

go

--创建同步处理的存储过程

ifexists(selectfromdbosysobjectswhereid=object_id(N'[dbo]

[p_synchro]')andOBJECTPROPERTY(id,N'IsProcedure')=1)

dropprocedure[dbo][p_synchro]

GO

createprocp_synchro

as

--setXACT_ABORTon

--启动远程服务器的MSDTC服务

execmasterxp_cmdshell'isql/S"xz"/U"sa"/P""/q"execmasterxp_cmdshell''netstartmsdtc'',no_output"',no_output

--启动本机的MSDTC服务

--execmasterxp_cmdshell'netstartmsdtc',no_output

--进行分布事务处理,如果表用标识列做主键,用下面的方法

--BEGINDISTRIBUTEDTRANSACTION

--同步删除的数据

deletefromsrv_lnktestdbo[user]

whereidnotin(selectidfrom[user])

--同步新增的数据

insertintosrv_lnktestdbo[user]

selectid,number,namefrom[user]wherestateisnull

--同步修改的数据

updatesrv_lnktestdbo[user]set

number=bnumber,name=bname

fromsrv_lnktestdbo[user]a

join[user]bonaid=bid

wherebstate=1

--同步后更新本机的标志

update[user]setstate=0whereisnull(state,1)=1

--COMMITTRAN

go

--创建作业,定时执行数据同步的存储过程

ifexists(SELECT1frommsdbsysjobswherename='数据处理')

EXECUTEmsdbdbosp_delete_job@job_name='数据处理'

execmsdbsp_add_job@job_name='数据处理'

--创建作业步骤

declare@sqlvarchar(800),@dbnamevarchar(250)

select@sql='execp_synchro'--数据处理的命令

@dbname=db_name()--执行数据处理的数据库名

execmsdbsp_add_jobstep@job_name='数据处理',

@step_name='数据同步',

@subsystem='TSQL',

@database_name=@dbname,

@command=@sql,

@retry_attempts=5,--重试次数

@retry_interval=5--重试间隔

--创建调度

EXECmsdbsp_add_jobschedule@job_name='数据处理',

@name='时间安排',

@freq_type=4,--每天

@freq_interval=1,--每天执行一次

@active_start_time=00000--0点执行

这个要根据不同情况具体分析，有几种方案参考：

数据库A和数据库B是建立在两台独立的数据库服务器上，那么采用dblink方式是一种可行的方式，存在两个数据同步过程：

一、数据库A正常运行的时候需要将数据同步到备用库即数据库B；

二、数据库A不正常的时候启用数据库B，在数据库A恢复正常之前的数据更新都发生在数据库B，那么需要将数据库B的数据同步给数据库A。

第一种方式：前提是数据库A和数据库B本地网是24小时互通的同时对数据同步实时性有比较高的要求，那么可以建立DBLINK，在两个库都建触发器，不管当前在哪个库发生数据更新的时候实时同步数据到目标数据库；

第二种方式：如果数据同步的实时性要求不高，则可以通过定制存储过程的方式（给两个库的数据表加时间戳或者更新标志，）定时同步数据；

第三种方式：通过给两个数据库的数据表加更新标志字段，以第一种方式为主以满足实时性的要求，以第二种方式为辅弥补可能存在的触发器执行更新未成功的情况。

以上的方案都是从数据层面所做的处理，对于数据实时同步还是会存在一定的风险，那么双机热备应该说是最好的选择了。

以上就是关于如何跨Oracle数据库实现表级别的实时同步全部的内容，包括:如何跨Oracle数据库实现表级别的实时同步、如何将数据从 SQL Server 实时或定时同步到 MySQL 数据库、数据库怎么实现数据同步等相关内容解答，如果想了解更多相关内容，可以关注我们，你们的支持是我们更新的动力！