WEB开发网
开发学院数据库MSSQL Server Sql Server 2005/2008 SqlCacheDependency查询通知... 阅读

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

 2010-03-26 00:00:00 来源:WEB开发网   
核心提示: 如果您的应用程序数据库连接字符串如果不存放在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里运行没问题,但有些不经济。      

上一页  1 2 

Tags:Sql Server SqlCacheDependency

编辑录入:爽爽 [复制链接] [打 印]
赞助商链接