在SQLServer2005中实现异步触发器概要.doc

在SQL Server 2005中实现异步触发器架构 2008-03-12 00:00 在SQL Server 2005中实现异步触发器架构: 在SQL Server 2005数据库中，通过新增的Service Broker可以实现异步触发器的处理功能。本文提供一种使用Service Broker实现的通用异步触发器方法。 在本这个方法中，通过Service Broker构造异步触发器处理架构，对于要使用这种架构的表，只需要创建相应的触发器及处理触发器中数据的存储过程，并且在异步触发器架构中登记触发器和处理的存储过程即可。如果一个触发器中的数据要被多个表使用，只需要在dbo.tb_async_trigger_subscribtion中登记相应处理数据的存储过程即可，即一个表的数据变更可以被多个表订阅（使用）。 架构的步骤如下： 1． 数据库配置 需要配置数据库以允许使用Service Broker。本文以tempdb库为例，故配置均在tempdb上下文中进行。 USE tempdb GO -- 允许Service Broker ALTER DATABASE tempdb SET ENABLE_BROKER GO 2． 构建异步触发器相关的对象 下面的T-SQL创建异步触发器处理架构相关的对象。 -- ======================================= -- 异步触发器对象 -- 1. service broker 对象 -- ======================================= -- a. message type, 要求使用xml 传递数据 CREATE MESSAGE TYPE MSGT_async_trigger VALIDATION = WELL_FORMED_XML GO -- b. 只需要发送消息 CREATE CONTRACT CNT_async_trigger(MSGT_async_trigger SENT BY INITIATOR) GO -- c. 存储消息的队列 CREATE QUEUE dbo.Q_async_trigger GO -- d. 用于消息处理的服务 CREATE SERVICE SRV_async_trigger ON QUEUE dbo.Q_async_trigger(CNT_async_trigger) GO -- ======================================= -- 异步触发器对象 -- 2. 异步触发器处理的对象 -- ======================================= -- a. 登记异步触发器的表 CREATE TABLE dbo.tb_async_trigger(ID int IDENTITY PRIMARY KEY, table_name sysname,trigger_name sysname) -- b. 登记订阅异步触发器的存储过程 CREATE TABLE dbo.tb_async_trigger_subscriber(ID int IDENTITY PRIMARY KEY, procedure_name sysname) -- c. 异步触发器和存储过程之间的订阅关系 CREATE TABLE dbo.tb_async_trigger_subscribtion(trigger_id int REFERENCES dbo.tb_async_trigger(ID),procedure_id int REFERENCES dbo.tb_async_trigger_subscriber(ID), PRIMARY KEY(trigger_id, procedure_id) ) GO -- d. 发送消息的存储过程 CREATE PROC dbo.p_async_trigger_send @message xml AS SET NOCOUNT ON DECLARE @handle uniqueidentifier BEGIN DIALOG CONVERSATION @handle FROM SERVICE [SRV_async_trigger] TO SERVICE NSRV_async_trigger ON CONTRACT CNT_async_trigger WITH ENCRYPTION = OFF; SEND ON CONVERSATION @handle MESSAGE TYPE MSGT_async_trigger(@message); -- 消息发出即可, 不需要回复, 因此发出后即可结束会话 END CONVERSATIO