Sql Server 2005/2008 SqlCacheDependency查询通知的使用总结

核心提示： 如果您的应用程序数据库连接字符串如果不存放在web.config中, 也没关系, 这不是必须的，您只要能在下面访问到即可.5.启动SqlDependency监听.在Global.ascx里的Application_Start和Application_End里增加如下代码：voidApplicat

如果您的应用程序数据库连接字符串如果不存放在web.config中, 也没关系, 这不是必须的，您只要能在下面访问到即可.

5.启动SqlDependency监听.

在Global.ascx里的Application_Start和Application_End里增加如下代码：

　　　　void　Application_Start(object　sender,　EventArgs　e)　
　　　　{
　　　　　　　　string　connString　=　System.Web.Configuration.WebConfigurationManager.ConnectionStrings["TestConnectionString"].ConnectionString;
　　　　　　　　System.Data.SqlClient.SqlDependency.Start(connString);
　　　　}　　　　
　　　　void　Application_End(object　sender,　EventArgs　e)　
　　　　{　　　　　　　
　　　　　　　　string　connString　=　System.Web.Configuration.WebConfigurationManager.ConnectionStrings["TestConnectionString"].ConnectionString;
　　　　　　　　System.Data.SqlClient.SqlDependency.Stop(connString);
　　　　}

注意：System.Data.SqlClient.SqlDependency.Start(connString)可以多次执行，也就是说，除了在这里，您还可以在您程序的代码里加上这句。

6.主体程序

从cache或db中获取数据。

private　DataSet　GetData()
{
　　　　　　　　　　　　if　(HttpRuntime.Cache["EntityResourceCollection"]　!=　null)
　　　　　　　　　　　　{
　　　　　　　　　　　　　　　　//get　entity　resource　collection　from　cache
　　　　　　　　　　　　　　　　return　(DataSet)HttpRuntime.Cache["EntityResourceCollection"];
　　　　　　　　　　　　}
　　　　　　　　　　　　else
　　　　　　　　　　　　{
　　　　　　　　　　　　　　　　//get　from　database
　　　　　　　　　　　　　　　　DataSet　ds　=　new　DataSet();
　　　　　　　　　　　　　　　　SqlDependency.Start(ConfigurationManager.ConnectionStrings["GFDBConnectionString"].ConnectionString);
　　　　　　　　　　　　　　　　using　(SqlConnection　connection　=　new　SqlConnection(ConfigurationManager.ConnectionStrings["GFDBConnectionString"].ConnectionString))
　　　　　　　　　　　　　　　　{
　　　　　　　　　　　　　　　　　　　　string　sql　=　"　Select　cityid,　cityname　From　dbo.tbl_city";
　　　　　　　　　　　　　　　　　　　　using　(SqlCommand　command　=　new　SqlCommand(sql,　connection))
　　　　　　　　　　　　　　　　　　　　{
　　　　　　　　　　　　　　　　　　　　　　　　SqlCacheDependency　dependency　=　new　SqlCacheDependency(command);
　　　　　　　　　　　　　　　　　　　　　　　　using　(SqlDataAdapter　adapter　=　new　SqlDataAdapter())　//查询数据
　　　　　　　　　　　　　　　　　　　　　　　　{
　　　　　　　　　　　　　　　　　　　　　　　　　　　　adapter.SelectCommand　=　command;
　　　　　　　　　　　　　　　　　　　　　　　　　　　　adapter.Fill(ds);
　　　　　　　　　　　　　　　　　　　　　　　　}
　　　　　　　　　　　　　　　　　　　　　　　　HttpRuntime.Cache.Insert("EntityResourceCollection",　ds,　dependency);
　　　　　　　　　　　　　　　　　　　　}
　　　　　　　　　　　　　　　　}
　　　　　　　　　　　　　　　　return　ds;
　　　　　　　　　　　　}
　　　　　　　　}

注意： string sql = " Select cityid, cityname From dbo.tbl_city";语句的要求非常严格，具体请参照msdn介绍。

基本上就是这6步。

注意，如果您的代码中使用了SqlCacheDependencyAdmin.EnableNotifications(connectionString)，或者SqlCacheDependency是使用（库名，表名)方式构建的 SqlCacheDependency scd = new SqlCacheDependency("数据库名称","表名")，这说明，您仍然在使用sqlserver 7.0/2000 轮询的方式进行缓存依赖检查，虽然在sql 2005/2008里运行没问题，但有些不经济。