站长论坛

标题: 讲解在SQL Server 2005中实现异步触发器架构 [打印本页]

作者: ajax 时间: 2008-10-29 13:12
标题: 讲解在SQL Server 2005中实现异步触发器架构
以下为引用的内容：
;  col = T.c.value('@col[1]', 'int')
         FROM @message.nodes('/root/inserted/inserted') T(c)
      )
      INSERT dbo.t2(
         id, col)
      SELECT
         id, col
      FROM I
      SET IDENTITY_INSERT dbo.t2 OFF
END
ELSE             -- 删除
BEGIN
;WITH
D AS(
      SELECT
         id = T.c.value('@id[1]', 'int'),
         col = T.c.value('@col[1]', 'int')
      FROM @message.nodes('/root/deleted/deleted') T(c)
)
DELETE A
FROM dbo.t2 A, D
WHERE A.ID = D.ID
END
GO

-- b.2 记录操作记录到dbo.tb_log 的存储过程
CREATE PROC dbo.p_Record_log
@message xml
AS
SET NOCOUNT ON
DECLARE
@inserted bit,
@deleted bit
SELECT
@inserted = @message.exist('/root/inserted'),
@deleted = @message.exist('/root/deleted')
INSERT dbo.tb_log(
user_name,
operate_type,
inserted,
deleted)
SELECT
@message.value('(/root/user_name)[1]', 'sysname'),
operate_type = CASE
                  WHEN @inserted = 1 AND @deleted = 1 THEN 'update'
                  WHEN @inserted = 1 THEN 'insert'
                  WHEN @deleted = 1 THEN 'delete'
            END,
@message.query('/root/inserted'),
@message.query('/root/deleted')
GO

-- ===============================
-- 在异步触发器处理系统中登记对象
INSERT dbo.tb_async_trigger(
table_name, trigger_name)
VALUES(
N't1', N'TR_async_trigger')

INSERT dbo.tb_async_trigger_subscriber(
procedure_name)
SELECT N'dbo.p_Sync_t1_t2' UNION ALL
SELECT N'dbo.p_Record_log'

INSERT

[ 本帖最后由 ajax 于 2008-10-29 13:14 编辑 ]

作者: ajax 时间: 2008-10-29 13:13
标题: 讲解在SQL Server 2005中实现异步触发器架构
以下为引用的内容：
dbo.tb_async_trigger_subscribtion(
trigger_id, procedure_id)
SELECT 1, 1 UNION ALL
SELECT 1, 2
GO

4.使用测试

下面的T-SQL修改表dbo.t1中的数据，并检查dbo.t2、dbo.tb_log中的数据，以确定异步触发器架构的工作是否成功。

执行完成后可以看到dbo.t2、dbo.tb_log中有相关的记录。

-- ===============================
-- 测试
INSERT dbo.t1
SELECT 1 UNION ALL
SELECT 2

UPDATE dbo.t1 SET
col = 2
WHERE id = 1

DELETE dbo.t1
WHERE id = 2

-- 显示结果
WAITFOR DELAY '00:00:05'
-- 延迟5 分钟, 以便有时间处理消息(因为是异步的)
SELECT * FROM dbo.t2
SELECT * FROM dbo.tb_log
GO

5.使用测试

下面的T-SQL删除本文中建立的所有对象。

-- =======================================
-- 5. 删除相关的对象
-- =======================================
-- a. 删除service broker 对象
DROP SERVICE SRV_async_trigger
DROP QUEUE dbo.Q_async_trigger
DROP CONTRACT CNT_async_trigger
DROP MESSAGE TYPE MSGT_async_trigger
GO

-- b. 删除异步触发器处理的相关对象
DROP PROC dbo.p_async_trigger_process
DROP PROC dbo.p_async_trigger_send
DROP TABLE dbo.tb_async_trigger_subscribtion
DROP TABLE dbo.tb_async_trigger_subscriber
DROP TABLE dbo.tb_async_trigger
GO

-- c. 删除测试的对象
DROP TABLE dbo.tb_log, dbo.t1, dbo.t2
DROP PROC dbo.p_Sync_t1_t2, dbo.p_Record_log

欢迎光临站长论坛 (https://www.tzlink.com/bbs/)