/*
--author：Bruce Qin*/
/*--
-- 删除链接和链接服务器
Exec sp_droplinkedsrvlogin syncDB,Null
Exec sp_dropserver syncDB
EXEC sp_addlinkedserver
@server='syncDB',--被访问的服务器别名
@srvproduct='',
@provider='SQLOLEDB',
@datasrc='202.**.***.43\MSSQLSERVER2008' --要访问的服务器实例名
---- @datasrc='servername\instancename'
---- servername 是运行 SQL Server 的计算机名称(或者IP)，instancename 是用户将被连接到的特定 SQL Server 实例的名称
EXEC sp_addlinkedsrvlogin
'syncDB', --被访问的服务器别名
'false',
NULL,
'sa', --帐号
'sa' --密码
exec sp_serveroption 'syncDB43','rpc out','true'; --允许调用链接服务器上的存储过程
-- 在远程服务器43的作业中调用本服务器的存储过程saveSync_process_ON187
--exec('exec Mydb_sync187.dbo.saveSync_process_ON187') at syncDB43;
**/
/*--链接服务器同步数据示例
服务器HAI：
hostname:HAI
实例名：HAI\BRUCESERVER
（测试）数据库名：Mydb_sync187
服务器CHOW：
hostname:CHOW
实例名：CHOW\SQL2008
（测试）数据库名：Mydb_sync10
同步要求：
1、在服务器HAI在的My_sync187数据库出现save、update、delete操作后，将数据同步到服务器CHOW的Mydb_sync10数据库中，保持数据一致性。
2、在服务器CHOW在的Mydb_sync10数据库出现save、update、delete操作后，将数据同步到服务器HAI的Mydb_sync187数据库中，保持数据一致性。
--*/
/*
-- 在服务器HAI上完成save、update、delete操作后将数据单向同步到服务器CHOW上的设置如下列步骤所示（在服务器CHOW的设置相似）
*/
--步骤1：在服务器HAI上创建链接服务器（链接到服务器CHOW，202.**.***.10）：
-------
Exec sp_droplinkedsrvlogin syncDB10,Null
Exec sp_dropserver syncDB10
EXEC sp_addlinkedserver
@server='syncDB10',--被访问的服务器别名
@srvproduct='',
@provider='SQLOLEDB',
@datasrc='202.**.***.10\SQL2008' --要访问的服务器
EXEC sp_addlinkedsrvlogin
'syncDB10', --被访问的服务器别名
'false',
NULL,
'sa', --帐号
'sa' --密码
--步骤2：在服务器HAI上启动 msdtc(分布式事务处理服务),并且设置为自动启动
-- 我的电脑--控制面板--管理工具--服务--右键 Distributed Transaction Coordinator--属性--启动--并将启动类型设置为自动启动
-- 注：如果在第1步Distributed Transaction Coordinator 无法启动，则是因为丢失了日志文件,重新创建日志文件,再启动就行了。重新创建 MSDTC 日志,并重新启动服务的步骤如下：
-- (1) 单击"开始",单击"运行",输入 cmd 后按"确定"。
-- (2) 输入:msdtc -resetlog (注意运行此命令时,不要执行挂起的事务)
-- (3) 最后输入:net start msdtc 回车。
--步骤3： 在服务器HAI上的数据库Mydb_sync187 创建一个作业定时远程调用服务器CHOW数据库Mydb_sync10上的同步处理存储过程。
-- 企业管理器
-- 管理
-- SQL Server代理
-- 右键作业
-- 新建作业
-- "常规"项中输入作业名称,如 Mydb_sync187_job
-- "步骤"项
-- 新建
-- "步骤名"中输入步骤名，如 Mydb_sync187_step
-- "类型"中选择"Transact-SQL 脚本(TSQL)"
-- "数据库"选择执行命令的数据库，如 Mydb_sync187
-- "命令"中输入要执行的语句:
EXEC sp_addlinkedserver
@server='syncDB10',--被访问的服务器别名
@srvproduct='',
@provider='SQLOLEDB',
@datasrc='202.**.***.10\SQL2008'; --要访问的服务器
EXEC sp_addlinkedsrvlogin
'syncDB10', --被访问的服务器别名
'false',
NULL,
'sa', --帐号
'sa'; --密码
--允许调用链接服务器syncDB10上的存储过程
EXEC sp_serveroption 'syncDB10','rpc out','true';
EXEC('exec Mydb_sync10.dbo.saveSync_process_ON10') at syncDB10;
EXEC('exec Mydb_sync10.dbo.updateSync_process_ON10') at syncDB10;
EXEC('exec Mydb_sync10.dbo.deleteSync_process_ON10') at syncDB10;
Exec sp_droplinkedsrvlogin syncDB10,Null;
Exec sp_dropserver syncDB10;
-- 确定
-- "调度"项
-- 新建调度
-- "名称"中输入调度名称
-- "调度类型"中选择你的作业执行安排
-- 如果选择"反复出现"
-- 点"更改"来设置你的时间安排 （设置合理的时间安排）
-- 然后将SQL Agent服务启动,并设置为自动启动,否则你的作业不会被执行
-- 设置方法:
-- 我的电脑--控制面板--管理工具--服务--右键 SQLSERVERAGENT--属性--启动类型--选择"自动启动"--确定.
--步骤4：在服务器HAI上调用服务器CHOW上的实现同步处理的存储过程如下
-- 服务器CHOW上Mydb_sync10数据库中创建如下的同步处理存储过程：
GO
--新增数据操作存储过程
create proc saveSync_process_ON187
as
begin tran --开始事物
--将远程服务器新增的数据同步到本服务器中
insert t_park_account(status,user_id,car_id,cardNo,cardType,cost,lowestBalanceAfterConsume,tollyLowestBalanceAC,noEntryBalance,lowBalanceNotice,openAccountTime,statusUpdateTime,remark,parkNo,balance)
select status,user_id,car_id,cardNo,cardType,cost,lowestBalanceAfterConsume,tollyLowestBalanceAC,noEntryBalance,lowBalanceNotice,openAccountTime,statusUpdateTime,remark,parkNo,balance
from syncDB187.Mydb_sync187.dbo.t_park_account _account
where not exists(
select * from t_park_account where sys_id=_account.sys_id)
--@@error的值不等于0表示上一条SQL语句执行结果有错，即采取事物回滚措施
if @@ERROR<>0
begin
rollback tran
end
insert t_park_user(sys_id,userName,credentialsType,credentialsNo,phone,mobileNumber,address)
select sys_id,userName,credentialsType,credentialsNo,phone,mobileNumber,address
from syncDB187.Mydb_sync187.dbo.t_park_user _user
where not exists(
select * from t_park_user where sys_id=_user.sys_id)
if @@ERROR<>0
begin
rollback tran
end
insert t_park_car(vehPlate,carType,carColour)
select vehPlate,carType,carColour
from syncDB187.Mydb_sync187.dbo.t_park_car _car
where not exists(
select * from t_park_car where sys_id=_car.sys_id)
if @@ERROR<>0
begin
rollback tran
end
commit tran --提交事物
GO
--更新数据操作存储过程
create proc updateSync_process_ON187
as
begin tran --开始事物
--将远程服务器更新的数据更新到本服务器中
update account
set status=_account.status,user_id=_account.user_id,car_id=_account.car_id,cardNo=_account.cardNo,cardType=_account.cardType,cost=_account.cost,lowestBalanceAfterConsume=_account.lowestBalanceAfterConsume,tollyLowestBalanceAC=_account.tollyLowestBalanceAC,noEntryBalance=_account.noEntryBalance,lowBalanceNotice=_account.lowBalanceNotice,openAccountTime=_account.openAccountTime,statusUpdateTime=_account.statusUpdateTime,remark=_account.remark,parkNo=_account.parkNo,balance=_account.balance
from syncDB187.Mydb_sync187.dbo.t_park_account _account,t_park_account account
where account.sys_id=_account.sys_id
if @@ERROR<>0
begin
rollback tran
end
update _user_
set sys_id=_user.sys_id,userName=_user.userName,credentialsType=_user.credentialsType,credentialsNo=_user.credentialsNo,phone=_user.phone,mobileNumber=_user.mobileNumber,address=_user.address
from syncDB187.Mydb_sync187.dbo.t_park_user _user,t_park_user _user_
where _user_.sys_id=_user.sys_id
if @@ERROR<>0
begin
rollback tran
end
update car
set vehPlate=_car.vehPlate,carType=_car.carType,carColour=_car.carColour
from syncDB187.Mydb_sync187.dbo.t_park_car _car,t_park_car car
where car.sys_id=_car.sys_id
if @@ERROR<>0
begin
rollback tran
end
commit tran --提交事物
GO
--删除数据操作存储过程
create proc deleteSync_process_ON187
as
begin tran --开始事物
--删除已删除的数据
delete account
from t_park_account account
where not exists(
select * from syncDB187.Mydb_sync187.dbo.t_park_account where sys_id=account.sys_id)
if @@ERROR<>0
begin
rollback tran
end
delete _user_
from t_park_user _user_
where not exists(
select * from syncDB187.Mydb_sync187.dbo.t_park_user where sys_id=_user_.sys_id)
if @@ERROR<>0
begin
rollback tran
end
delete car
from t_park_car car
where not exists(
select * from syncDB187.Mydb_sync187.dbo.t_park_car where sys_id=car.sys_id)
if @@ERROR<>0
begin
rollback tran
end
commit tran --提交事物
分享到：
相关推荐
SQLServer触发器实现不同服务器数据同步.pdf
用链接服务器同步数据sql SQL 脚本， 与链接服务器一起使用
SQL SERVER 2008 数据同步设置指南 A、B两台服务器通过事务复制实现数据同步备份的功能
详细描述数据库发布与订阅的过程，本人在中间操作的过程中走了弯路，希望大家...8．在订阅服务器新建数据库订阅，手动启动发布服务器的代理程序生成数据库快照，手动启动订阅服务器的同步程序测试发布与订阅是否成功。
SQL Server服务器同步备份，delphi源码
在VS2008下，利用c#在SQLSERVER2005实现两个数据库同步，要求：两个数据库中表名可以不一样，但是列名要一样。(利用存储过程实现)
两台SQL+Server数据同步解决方案（推荐）.doc
MSSQL_SERVER数据库增量同步软件(数据库结构及数据): 可以增量同步的.这个程序当初我写完基本上是可以实现. 数据库增量同步必须具备以下条件 一.每张表必须有主键 二.每张表必须有一个最后更新日期栏位(时间类型). ...
sqlserver定时器的设置，跨服务器的数据交接，里面有存储过程例子对A，B两个sqlserver服务器数据的互导，以及跨服务器需要设置的环境截图详解
背景介绍对sqlserver做数据库同步的时候，由于医院服务器和数据库版本的限制，选择了用发布订阅处理数据库同步，但是这个方式只能处理有主键的表，对于无主键的表
实现两个Sqlserver之间的数据库同步 对实时性有较高要求，数据同步延时尽量在1S之内 可以全库、单表、多表的数据同步 2. 读写分离 数据同步之后程序上就可以通过分别使用不同的DbContext实现程序上的读写分离 3. ...
SQL Server服务器同步备份 ,一个关于服务器同步备份的程序
手把手教你如何把一个服务器上的数据库同步到另一个服务器的数据库,简单好用
SQL2000数据同步，多台服务器异地数据同步.
SQL数据同步(独立分发服务器)，讲解如何建立SQL2005的分发服务器
实例Sql server 2005订阅复制同步分发数据到多台服务器文档里面详细的讲述是如何操作的,并且附有截图.
配置sql server主从服务器同步、实现灾难备份、读写分离
交待：使用的软硬件环境为Win XP SP2、SQL Server 2000 SP2个人版、普通双核台式机、1000M局域网，A机为已使用的服务器，上面已有数据库和海量数据，B机为此次新架服务器，两机登陆方式均为sql server身份验证模式，...
SQL Server 2005 移动版（SQL Server Mobile）或SQL Server 2000 Windows CE 2.0版（SQL Server CE 2.0）的企业和个人用户如果计划与SQL Server 2000或SQL Server 2005数据库保持同步，需要在您运行Microsoft ...
最近有个需求是要跨库进行数据同步，两个数据库分布在两台物理计算机上，自动定期同步可以通过SQL Server代理作业来实现，但是前提是需要编写一个存储过程来实现同步逻辑处理。这里的存储过程用的不是opendatasource...