监视数据库变化,线程(SqlDependency学习笔记 )
2016-04-10 20:11
423 查看
监视数据库变化,线程(SqlDependency学习笔记 )
标签: 数据库sqlserverstatistics浏览器sqllibrary2010-04-18 21:08 3914人阅读 评论(0) 收藏 举报
分类:
SQL Server(47)
sqlDependency提供了这样一种能力:当被监测的数据库中的数据发生变化时,SqlDependency会自动触发 OnChange事件来通知应用程序,从而达到让系统自动更新数据(或缓存)的目的.
快速上手可参见园友的下列文章
http://www.csharpwin.com/dotnetspace/8536r2178.shtml .NET 2.0 SqlDependency快速上手指南
http://www.csharpwin.com/dotnetspace/9563r4530.shtml 采 用SQLServer2005 Broker和SqlDependency类来提供数据更改通知(原创)
这里参考他们的文章,自己也做了一个小的示例程序(Sql2005环境)
1.先建一个测试表
CREATE TABLE [ dbo ] . [ Messages ] (
[ ID ] [ int ] IDENTITY ( 1 , 1 ) NOT NULL ,
[ UserID ] [ varchar ] ( 50 ) COLLATE Chinese_PRC_CI_AS NOT NULL ,
[ Message ] [ nvarchar ] ( 256 ) COLLATE Chinese_PRC_CI_AS NOT NULL ,
CONSTRAINT [ PK_Messages ] PRIMARY KEY CLUSTERED
(
[ ID ] ASC
) WITH (PAD_INDEX = OFF , STATISTICS_NORECOMPUTE = OFF , IGNORE_DUP_KEY = OFF ,
ALLOW_ROW_LOCKS = ON , ALLOW_PAGE_LOCKS = ON )
ON [ PRIMARY ]
)
然后可以利用Sql2005的管理器,随便输入几条数据
2.控制台程序主要代码
using System;
using System.Configuration;
using System.Data;
using System.Data.SqlClient;
namespace SqlDependencyTest
{
class Program
{
private static string _connStr;
static void Main( string [] args)
{
_connStr = ConfigurationManager.ConnectionStrings[ " ConnStr " ].ToString();
SqlDependency.Start(_connStr); // 传入连接字符串,启 动基于数据库的监听
UpdateGrid();
Console.Read();
}
private static void UpdateGrid()
{
using (SqlConnection connection = new SqlConnection(_connStr))
{
// 依赖是基于某一张表的,而且查询语句只能是简单查询语句,不能带top或*,同时必须 指定所有者,即类似[dbo].[
]
using (SqlCommand command = new SqlCommand( " select ID,UserID,[Message] From [dbo].[Messages] " , connection))
{
command.CommandType = CommandType.Text;
connection.Open();
SqlDependency dependency = new SqlDependency(command);
dependency.OnChange += new OnChangeEventHandler(dependency_OnChange);
SqlDataReader sdr = command.ExecuteReader();
Console.WriteLine();
while (sdr.Read())
{
Console.WriteLine( " Id:{0}/tUserId:{1}/tMessage:{2} " ,sdr[ " ID " ].ToString(), sdr[ " UserId "].ToString(),
sdr[ " Message " ].ToString());
}
sdr.Close();
}
}
}
private static void dependency_OnChange( object sender, SqlNotificationEventArgs e)
{
UpdateGrid();
}
}
}
3.测试运行
运行该控制台程序后,会输出[Messages]表的所有数据,这时不要关闭控制台程序,直接在Sql2005的管理器里对[Messages]表 的数据做些修改(比如新增/删除等),再看一下控制台,会发现自动重新输出了新的数据.
注意:如果在web应用中,因为页面必须通过浏览器请求才能激活服务端的处理,所以页面一旦处理完成并显示到浏览器后,放着不动的情况 下,OnChange事件始终是得不到触发的.
最后再推荐一篇园子里高人的文章:
http://www.csharpwin.com/csharpspace/1243.shtml 是 结合Enterprise Library的缓存应用程序块与SqlDependency的综合应用,写得很不错,强烈推荐想使用缓存的朋友看看.
相关文章推荐
- MySQL查询数据
- oracle小数点前零丢失的问题
- Mysql外键约束
- 数据库设计 Step by Step (3)——基本ER模型构件
- Redis主从复制
- 【Oracle】4.约束
- Oracle11g 新特性 虚拟列
- SQLSever安装出错
- 数据库设计
- Oracle VM + centos7.1+openstack kilo 多结点安装教程---基础环境配置(4)
- MySQL的注释方式
- mysql 存储过程:提供查询语句并返回查询执行影响的行数
- sql中行列互换
- 10w分区表,hive能跑,sparksql运行也完全能跑起来
- 【Oracle】3.模糊查询
- 力控调用ADO组件进行SQL数据库操作
- 【Oracle】2.92与99语法差异化比较
- 2016最新高薪必备老男孩MySQL数据库DBA核心视频
- 实战 SQL Server 2008 数据库误删除数据的恢复
- plsql 连接oralce数据库,报ora 12557 tns 协议适配器不可加载错误