同构或异构数据库数据实时同步

同构或异构数据库的数据实时同步

目录

同构或异构数据库的数据实时同步 ........................................ 错误！未定义书签。

目录 .............................................................. 错误！ 未定义书签。

一、 术语解释： .................................................. 错误！未定义书签。

二、 同构数据库的同步： .......................................... 错误！未定义书签。

1.

2.

三、 异构数据库的同步 ............................................ 错误！未定义书签。

建立发布服务器 .............................................. 错误！未定义书签。

新建订阅服务器 .............................................. 错误！未定义书签。

1. MSDTC

2.

3.

的配置 .............................................. 错误！未定义书签。

创建链接服务器 ............................................... 错误！未定义书签。

创建触发器 ................................................... 错误！未定义书签。

术语解释:

同构： 需要同步的两张表一模一样

异构： 需要同步的两张表结构不一样

主：本文所说的数据同步两个数据库是部署在不同的服务器上。

同构数据库的同步:

这里简单介绍一下，主要采用的 自带的数据复制技术，我们这里采

SQLServer2005

用数据快照的方式同步。复制中涉及到分布式服务器部署的概念，涉及到发布服务器、 分发服务器以及

订阅服务器。

前提：因为需要用到 划作业，所以需要开启 代理服务，点 击运行键

SQLSERVESQLSERVE

R

入 ，进入服务界面，启动 务， 并设置为自动启

SQL Server Age nt (MSSQLSERVER)

动；

1.

建立发布服务器 (1)连接进入 SQLSERVER在根节点下打开复制，右击本

地发布，选择新建发布。

2) 进入新建发布向导，选择下一步；

3) 选择需进行数据同步的源数据库，按下一步；

4) 选择快照发布，按下一步；

5) 选择需要同步的表和列，按下一步；

6) 不需要筛选表行，直接按下一步；

7) 按图示选择，然后点击旁边的更改；

8) 点击更改后进入设置时间间隔页面，按图示我们设置 作业执行时间

间隔为 3 分钟， 设置完毕后点击确定， 然后 继续下一步；

9) 在代理安全性下，选择安全设置；

10) 如图所示， 需要键入本机的 Windows 账号登录名密

码以及SqlServer的用户名和密码，然后点击确定，继续

下一步；

（ 11） 按照图示勾选，生成脚本文件可选可不选，然后点 击下一步；

（ 12） 默认设置，继续下一步；

（ 13） 填写发布名称，然后点击完成

（ 14） 然后开始自动创建发布，成功后点击关闭；

（ 15） 然后再本地发布下出现了我们的发布

2.

新建订阅服务器

（1） 打开复制，右击本地订阅，选择新建订阅。

（2） 点击下一步，选择发布服务器，点下一步

（3） 这里我们选择推送订阅，视具体情况而选择，然后点 击下一步

（4）选择添加订阅服务器，添加 SQL订阅服务器

（ 5） 然后会弹出连接到服务器界面，连接到你为其同步数 据的服务

器， 配置好点击连接， 注意这里需要输入机器名， 不能填写 IP 地

址

（ 6） 然后会出现如下界面，选择需要向其同步数据的数据 库，并按

下一步

7) 这里需要建立连接，点击旁边有省略号的按钮

8) 会出现如下界面，按图示进行选择，下方输入订阅服 务器的数据库名

和密码，上方也可以选第一个选项，用 Windows 登录名和密码的方式连

接，但由于我示例连接 的是虚拟机， root 用户的权限不够， 在最后

配置完成之后 会有错误提示，其实用机器名 Windows 用户名，下边输

入密码的方式也是可以的， 我这里选的是第二个选项， 使 用SQLSERVE

代理的方式，然后点击确定；

直接点击下

9)

一步

.rh.

10)

11)

12)

13)

14)

点击下一

步

点击下一

步

点击下一

步

点击下一

步

点击完成

出现如下界面，然后点击关闭

.rk

.rk

.rk

.rk

15)

16) 然后会在你的发布下出现一个订阅，同时在链接服

务器里出现一个链接

链接服务器：

同时在远程服务器，也就是你的订阅服务器里的本地订阅里也会出现对服务器数据 的订阅，然后服务

器数据库更新，计划会按时间间隔执行，执行时就会用数据快照 的方式同步订阅服务器的数据了，如图这是订

阅服务器的本地订阅： 需要注意的是，发布服务器的代理服务一定要开，如果订阅服务器的本地订阅里看 不

到订阅的话多刷几次就好了，数据库的同步复制到此结束。

三、 异构数据库的同步

异构数据库同步用到的技术包括触发器， 接服务器。实现

原理是需同步数据的双方需要都开启 服务，并进行配置，的配置稍后会讲到，

MSDTC, RPC SQLSERVER!

135teInetMSDTCRPC,

端口，可以试 因为的通信依赖于所以有防火墙的话双方都需要开启

SQLSERVE135

啲配置管 试端口是不是通的，两个数据库服务器应该都支持远程连接，在

MSDTCMSDTC

理器里可以进行配置， 然后建立链接服务器， 然后为服务器上需要同步的表分别建立触发器， 在触发器里进

行同步语句的编写，这样就实现了异构数据库的数据实时同步。

SQL

1. MSDTC

的配置

（1） 双方启动MSDTC服务

MSDTC

服务提供分布式事务服务，如果要在数据库中使用分布式事务，必须在参与的 双方服务器启动

MSDTCDistributed Transaction Coordinator

（）服务。

操作步骤：

开始设置控制面板 管理工具 组件服务 打开组件服务节点

-＞-＞-＞-＞

右击我的电脑属性选择选项卡

-＞-＞MSDTC

点击安全配置

根据图片所示将必要项打上勾点击确定重启服务即可

（2） 打开双方 135 端口

MSDTCRPC（ Remote Procedure Call （RPC）RPC135 RPC

服务依赖于 服务使用 端口，保证

，

服务启动，如果服务器有防火墙，保证 端口不被防火墙挡住。

135

（tel net IP 135 Adva need

使用“ ”命令测试对方端口是否对外开放。 也可用端口扫描软件（比如

Port Scanner

）扫描端口以判断端口是否开放。

操作

:

步骤 向防火添加

1

点击添加程序 点击浏览

-＞

找到 文件夹下的 文件 点打开即可。

system32

，

步骤 添加 端口

2 135

点击添加端口

填入 点确定即可。

135

步骤设置

3 SQL2005

）

打开 企业管理器

SQL2005

右击根节点， 打开服务器属性窗口将 “需要将分布式事务用于服务器到服务器” 的项勾上即 可

2.

创建链接服务器

（1） 打开本地数据库 ,选择根节点 => 服务器对象 => 链 接服务器，右

键单击链接服务器，选择新建链接服务器

（2） 常规配置，链接服务器名字可以随便起，但是产品名

称必须为大写的 SQLSERVE

R

（3） 安全性配置，需要输入远程服务器的用户名和密码

（4）服务器选项，Rpc和Rpc Out设置为true,然后点击 确定 OK

R

3.

创建触发器

在创建触发器之前，可以先试试链接服务器是否成功建

立，用 语句搜 索尝试一下，如：

Select

lect * from

注意格式： 链接服务器别

名 数据库 表名 如果成功的话继续创建触发器，不成功的话检查原因

. .dbo. .

创建触发器语法：

u expoxian

go

CREATE TRIGGER Tri_LatestSensorData

ON SY_LatestSensorData

FOR INSERT

AS

BEGIN

Inrt

into , f_uploadTime , f_code1 , f_code2 , f_code3 , f_code4 , f_code5 , f_code6 ） SELECT

f_gatewayId , f_uploadTime , f_code1 , f_code2 , f_code3 , f_code4 , f_code5 , f_ code6 from Inrted

END

删除触发器语法：

drop trigger Tri_LatestSensorData

针对表建立触发器之后， 可以在服务器插入一条记录试试， 看看远程服务器能不能实时更新数据：

inrt

into

SY_LatestSensorData ( f_gatewayId , f_uploadTime , f_code1 , f_code2 , f_code3

f_code4 , f_code5 , f_code6 )

values ( 'S00007' , getdate (), 1, 1, 1, 1, 1, 1)

综上所述，就是异构数据库同步的方法，本文到此结束。