3

我想将 SqlCacheDependency 与视图和过程一起使用。

我正在使用Linq to Sql。

我当前使用的代码仅在您使用单表时有效：

public static List<T> LinqCache<T>(this System.Linq.IQueryable<T> q, System.Data.Linq.DataContext dc, string CacheId)
{
   try
   {
      List<T> objCache = (List<T>)System.Web.HttpRuntime.Cache.Get(CacheId);

      if (objCache == null)
      {
         /////////No cache... implement new SqlCacheDependeny//////////
         //1. Get connstring from DataContext
         string connStr = dc.Connection.ConnectionString;

         var c = System.Web.Caching.SqlCacheDependencyAdmin.GetTablesEnabledForNotifications(connStr);

         //2. Get SqlCommand from DataContext and the LinqQuery
         string sqlCmd = dc.GetCommand(q).CommandText;

         //3. Create Conn to use in SqlCacheDependency
         using (System.Data.SqlClient.SqlConnection conn = new System.Data.SqlClient.SqlConnection(connStr))
         {
            conn.Open();
            //4. Create Command to use in SqlCacheDependency
            using (System.Data.SqlClient.SqlCommand cmd = new System.Data.SqlClient.SqlCommand(sqlCmd, conn))
            {
               //5.0 Add all parameters provided by the Linq Query
               foreach (System.Data.Common.DbParameter dbp in dc.GetCommand(q).Parameters)
               {
                  cmd.Parameters.Add(new System.Data.SqlClient.SqlParameter(dbp.ParameterName, dbp.Value));
               }

               //5.1 Enable DB for Notifications... Only needed once per DB...
               System.Web.Caching.SqlCacheDependencyAdmin.EnableNotifications(connStr);

               //5.2 Get ElementType for the query
               string NotificationTable = q.ElementType.Name;

               //5.3 Enable the elementtype for notification (if not done!)
               if (!System.Web.Caching.SqlCacheDependencyAdmin.GetTablesEnabledForNotifications(connStr).Contains(NotificationTable))
                  System.Web.Caching.SqlCacheDependencyAdmin.EnableTableForNotifications(connStr, NotificationTable);

               //6. Create SqlCacheDependency
               System.Web.Caching.SqlCacheDependency sqldep = new System.Web.Caching.SqlCacheDependency(cmd);
               // - removed 090506 - 7. Refresh the LinqQuery from DB so that we will not use the current Linq cache
               // - removed 090506 - dc.Refresh(System.Data.Linq.RefreshMode.OverwriteCurrentValues, q);
               //8. Execute SqlCacheDepency query...
               cmd.ExecuteNonQuery();
               //9. Execute LINQ-query to have something to cache...
               objCache = q.ToList();
               //10. Cache the result but use the already created objectCache. Or else the Linq-query will be executed once more...
               System.Web.HttpRuntime.Cache.Insert(CacheId, objCache, sqldep);
            }
         }
      }
      //Return the created (or cached) List
      return objCache;
   }
   catch (Exception ex)
   {
     throw ex;
   }
}

现在我想为视图（多个表）实现 sqlcachedependency。

我尝试使用此查询

System.Web.Caching.SqlCacheDependency
dep1 = new System.Web.Caching.SqlCacheDependency(cmd1),
dep2 = new System.Web.Caching.SqlCacheDependency(cmd2);

System.Web.Caching.AggregateCacheDependency aggDep = new System.Web.Caching.AggregateCacheDependency();
aggDep.Add(dep1, dep2);

dc.Refresh(System.Data.Linq.RefreshMode.OverwriteCurrentValues, q);
cmd.ExecuteNonQuery();
objCache = q.ToList();
System.Web.HttpRuntime.Cache.Insert(CacheId, objCache, aggDep);

但是这个查询不起作用，因为即使我更改了基础表，缓存也不会变得无效。

我用谷歌搜索了太久，但我找不到适用于视图和过程或多个表的代码。

4

1 回答 1

1

使用基于表的通知时，您不需要发出单独的 SqlCommand 样式查询——您的 ExecuteNonQuery 和相关代码是多余的。只需使用您构建的 AggregateCacheDependency 添加 LINQ 结果。

您确定您已完全启用基于表的更改通知吗？有一个表，一些触发器和一个存储过程需要在数据库中创建，加上服务器上的一些代码来触发周期性轮询。在声明缓存没有过期之前，请确保等待足够长的时间让轮询发生。

您还可以自己查看更改表的内容，以查看更改是否在 DB 端被拾取：

SELECT * FROM [dbo].[AspNet_SqlCacheTablesForChangeNotification]

如果来自单个表的更改有效，您可以尝试使用 SqlCacheDependency.CreateOutputDependency(string depend) 来简化您的代码。参数是一个或多个表的列表，格式为“DdName:TableName;DbName:TableName”。DbName 来自 web.config。

说了这么多，我还应该指出，基于表的更改通知已被弃用，新代码应该使用 Service Broker 通知。是的，它们可以与 LINQ 一起使用。

于 2011-12-03T00:38:36.207 回答