空间管理您的位置: 51Testing软件测试网 » Mr.南柯 » 日志

数据库主动式通知编程

上一篇 / 下一篇 2012-08-28 10:59:33 / 个人分类：数据库

查看( 404 ) / 评论( 0 ) / 评分( 0 / 0 )

bM9sC8p]!ozJ0　　概述

　　扩展存储过程51Testing软件测试网/mK,e8tm

　　1、创建扩展存储过程

H'EO8fH}{0　　2、测试动态库

　　3、创建触发器

　　概述51Testing软件测试网!| d1`]Q

　　当数据库更新的时候，如插入，删除，修改了数据记录，我们的应用程序需要知道些变更，一般情况下我们会采用轮询的方式.对数据库不间断性地查询，这种方式即不能保证实时性，又非常损耗服务的性能.那么是否有主动触发的机制，主动通知应用程序哪些记录做了更新呢？目前主要有两种机制：51Testing软件测试网oe/@,l.b.v

　　一，采用扩展存储过程，使用触发器，触发器再调用扩展存储过程，扩展存储过程再把数据通过UDP的通讯方式，发送到应用程序，这样应用程序就会收到数据库更新的通知.

　　二，SQLServer2005以后的版本，其中Service Broker机制可实现此功能。

　　扩展存储过程51Testing软件测试网&io*Za]!Ty

　　此方法的原理大概是这样的：通过触发器调用扩展存储过程，扩展存储过程再通过UDP的通讯方式，把信息发送到应用程序.51Testing软件测试网4GW'q\)H

]m\?ZFp8q~m0　　说详细些，就是说，数据库能通过触发器来探知数据库中某些表的增、删、改动作，然后再调用存储过程，存储过程中调用写好的扩展存储过程，扩展存储过程通过UDP通信方式，把数据库发生的事情通知UDP服务端，原理就是这么简单。

h'a"mx,Q+B0　　1、创建扩展存储过程

a@m:KD0　　启动VC++6.0-->新建VC++项目-->扩展存储过程DLL，如图：

51Testing软件测试网j/PT%y%v

　　点击”OK”，在下图的输入框输入扩展存储过程名，如图：51Testing软件测试网3}Y6~UD

51Testing软件测试网;i6A(zL/C

　　这里创建完成，在工程中你将看到如下接口：51Testing软件测试网{.BOi KY

51Testing软件测试网+JD/RXl(B

　　在此接口中编写你想要的操作.大概如下：

　　注：把动态库从内存中卸载的方法，执行SQL命令：DBCC 动态库名（FREE）//动态库名不要带扩展名

　　2、测试动态库

　　动态库创建好了，那么先测试一下，在数据库中创建扩展存储过程，然后调用存储过程，测试存储过程对动态库的调用是否成功。以下是所有创建，测试，与卸载的方法。51Testing软件测试网\NtM]t

　　创建扩展存储过程，SQL命令如下：51Testing软件测试网{P LKepg

　　sp_addextendedproc ‘接口名称，上一步骤中第二个图片窗口输入的名称’， '动态库所在路径，可绝对路径亦可相对路径'

use master
go
sp_addextendedproc 'TerminalFlagSynchro','.\\TerminalFlagSynchro.dll'
//删除过程:
sp_dropextendedproc 'TerminalFlagSynchro'
//把动态库从内存中卸载
DBCC TerminalFlagSynchro ( FREE )
测试:
TerminalFlagSynchro 23554, '13427960374',3

　　3、创建触发器

　　测试成功后，创建触发器调用此过程即可。以下为创建触发器示例：

51Testing软件测试网GMf~zU

USE STATIC_DB
GO
/****** Object: Trigger [dbo].[CarInfoChange]    Script. Date: 12/09/2011 20:14:18 ******/
SET ANSI_NULLS ON
GO
SET QUOTED_IDENTIFIER ON
GO
-- =============================================
-- Author:      <Mingo>
-- Create date: <2011-12-10>
-- Description: <Car_info表修改触发>
-- =============================================
alter TRIGGER [dbo].[CarInfoChange]
   ON [dbo].[CAR_INFO]
   for INSERT,UPDATE,DELETE
AS
BEGIN
    SET NOCOUNT ON;
    declare @TempCarID int ;
    declare @SIM    varchar(20);
    declare @Flag int ;
    Set @Flag = 3;
    if not exists(select 1 from inserted)--delete
        begin
            select @TempCarID = CARID, @SIM = GSM_NUMBER from deleted
            Set @Flag = 3;
        end
    else if not exists(select 1 from deleted)--add
        begin
            select @TempCarID = CARID, @SIM = GSM_NUMBER from inserted
            Set @Flag = 1;
        end
    else--update
        begin
            select @TempCarID = CARID, @SIM = GSM_NUMBER from inserted
            Set @Flag = 2;
        end
    exec master.dbo.TerminalFlagSynchro @TempCarID,@SIM, @Flag
END

　　以上只是简要说明，如果有不懂的，可以联系我。

　　出自：http://blog.csdn.net/mingojiang51Testing软件测试网 zY)sj4al[

收藏举报

TAG:

查看全部评论

bob123654

不要让那些真正对你好的人，慢慢的从你的生活中消失，无论爱情还是友情，都需要用心经营。

数据库主动式通知编程

用户菜单

我的栏目

标题搜索

日历

我的存档

数据统计

RSS订阅