SqlDependency 的使用
2024-10-10 12:39:09
1、SqlDependency是什么:
SqlDependency 对象表示应用程序和 SQL Server 实例间的查询通知依赖关系。应用程序可以创建一个 SqlDependency 对象并进行注册以通过OnChangeEventHandler 事件处理程序接收通知。
它提供了这样一种能力:当被监测的数据库中的数据发生变化时,SqlDependency会自动触发OnChange事件来通知应用程序,从而达到让系统自动更新数据(或缓存)的目的。
应用:数据实时性较高的场景、新闻、监控数据等。
可以结合SignalR来实现web的实时数据更新。
2、使用方法:
1)sql server设置:ALTER DATABASE <DatabaseName> SET ENABLE_BROKER;语句让相应的数据库启用监听服务,以便支持SqlDependency特性。
2)代码:控制台项目,web项目推荐把start放在Application_start方法中。
3)注意:查询语句中不能使用*,表名要加[dbo].[xx]。sql语句要执行。
conn =ConfigurationManager.ConnectionStrings["default"].ToString();
//Start和Stop方法
SqlDependency.Start(conn);
Update(conn); private static void Update(string conn)
{
using (
SqlConnection connection =
new SqlConnection(conn))
{
//此处 要注意 不能使用* 表名要加[dbo] 否则会出现一直调用执行 OnChange
string sql = "select agent from [dbo].[info]"; using (SqlCommand command = new SqlCommand(sql, connection))
{
connection.Open();
command.CommandType=CommandType.Text;
dependency = new SqlDependency(command);
dependency.OnChange += new OnChangeEventHandler(dependency_OnChange);
//必须要执行一下command
command.ExecuteNonQuery();
Console.WriteLine(dependency.HasChanges);
}
}
} //update insert delete都会进入
private static void dependency_OnChange(object sender, SqlNotificationEventArgs e)
{
Console.WriteLine("onchange方法中:"+dependency.HasChanges);
Console.WriteLine("数据库数据发生变化"+DateTime.Now);
//这里要再次调用
Update(conn);
}
最新文章
- webapi 中的本地登录
- java基础知识(一)数据类型(上)
- 《简明python教程》笔记一
- (十七)linux网络命令 vconfig ifconfig
- Cxgrid获取选中行列,排序规则,当前正在编辑的单元格内的值
- Openstack Neutron DVR workflow
- Struts2 和 spring mvc的 迭代标签常用属性对比
- SQL日期格式
- python编程语言缩进格式
- React Native在虚拟运行app时,报错RCTRootView not found,怎么解决?
- Chapter 3. Programming with RDDs
- mysql一库多表查询主键
- JAVA图片批量上传JS-带预览功能
- deepin 下安装goland中文字体显示全是方块
- PDF 补丁丁 0.6.0.3355 版发布(修复阅读模式、书签缩放的问题)
- Struts2,springMVC获取request和response
- catkin init/build 遇到catkin:command not found 的解决办法。
- 【RAY TRACING THE REST OF YOUR LIFE 超详解】 光线追踪 3-4 基于重要性采样的材质初探
- global $GLOBALS 区别
- How HipChat Stores And Indexes Billions Of Messages Using ElasticSearch And Redis[转]