SQL Server分布式数据库技术(LinkedServer,CT,SSB)

SQL Server自定义业务功能的数据同步

在不同业务需求的驱动下，数据库的模块化拆分将会面临一些比较特殊的业务逻辑处理需求。例如，在数据库层面的数据同步需求。同步过程中，可能会有一些比较复杂的业务逻辑判断。简单介绍几个SQL Server提供的数据同步功能。

图11-4 数据库的已链接服务

Provider是已链接服务器连接数据库时使用的适配器的类型，如图11-4中，左边部分显示的，列出了几趾已有的适配器的类型。示例中，使用SQLOLEDB类型的适配器进行数据库连接。

Security页用来配置链接服务器的验证信息，它包括如图11-5中所示的4种模式的验证方式。

Not be made

当选择此认证模式时，已链接服务将使用本地服务的登陆用户与远程服务登陆用户的映射配置列表中的账号。如图中，当选择此模式时，本地将只能使用sa登陆时，模拟远程服务的sa账号的权限配置。

Without using a Security context

选择此模式将不使用验证模式，它只利用SQL Server服务的登陆账号进行验证，此服务要求在Windows服务启动时，本地服务和远程服务使用相同的登陆账号。

Using current security context

当使用此模式时，要求本地和远程服务都要有相同的账号及密码，通常这些配置为Windows集成认证的时候使用。

Using this security context

使用此模式时，将使用下面配置的用户和密码进行登陆远程服务。

本小节中只是简略地介绍了关于这些配置的简要步骤，要获取更详细的内容，请参考SQL Server联机丛书（）。



图11-5 链接服务器安全配置

图11-6 更改跟踪查询结果

代码清单11-1中的执行结果如图11-6中所示，使用CHANGETABLE可以获得对应表的更改历史，更改历史会将原有表的主键记录下来，如图11-6中BusinessEntityID字段所示。

关于更改跟踪的详细信息，可以参考一下SQL Server联机丛书。

图11-7 Service Broker的组件组成



图11-8 Service Broker的工作原理

当需要进行队列传输前，需要开启一个会话（Conversation），通过会话记录下对应的服务标识，标识从源服务发送到目标服务。找到会话标识后便可以找到对应的队列。

开启会话以后，进行消息发送，对于数据库实例来说，只需要将消息写入到发送队列就可以了。消息被写入到发送队列后，后续的工作都交给Service Broker来处理。

当消息进入发送队列，Service Broker根据会话记录的服务标识，找到目标服务，并将消息拆分为多个消息片断，将消息发送到目标服务，服务接收完成所有的消息后，将消息写入到目标队列中。在写入到目标队列后，消息传递就结束了。后续的工作便交给应用处理了。

应用需要调用接收消息的命令，将消息从接收队列中取出，并进行一系列的后续业务工作。

关于Service Broker可以参考SQL Server联机丛书（）。

下面的代码是一份在同一实例下进行Service Broker配置以及测试的脚本，可以参考一下代码，并结合上图11-8中的工作原理参考Service Broker的工作方式。

use master

go

alter database AdventureWorks2008R2 set enable_broker with rollback immediate;

go

?

use AdventureWorks2008R2

go

?

create message type ReceiveMsgType validation = none;

create message type SendMsgType validation = none;

?

go

create contract SampleContract(SendMsgType sent by initiator,ReceiveMsgType sent by target,FraudEndOfStream sent by initiator);

go

?

create queue SampleTargetQue;

create service SampleTargetSrv on queue SampleTargetQue(SampleContract);

go

?

create queue SampleInitQue;

create service SampleInitSrv on queue SampleInitQue(SampleContract);

go

?

/********************************Send Test********************************************

declare @handle uniqueidentifier,@msg varchar(8000) = ‘this is a test message!‘;

?

begin dialog conversation @handle

from service SampleInitSrv

to service ‘SampleTargetSrv‘

on contract SampleContract

with encryption = off;

?

send on conversation @handle

message type SendMsgType(@msg)

?

**********************************************************************************/

?

/*****************************Receive Test*************************************************

declare @receivemsg varchar(8000),@Handle uniqueidentifier;

waitfor(receive top(1) @Handle = conversation_handle,

????????????@receivemsg = Message_Body

????????????from SampleTargetQue),timeout 1000

end conversation @handle;

select @receivemsg;

?

**********************************************************************************/

代码清单11-2 同实例下的Service Broker配置