1

在实现非常基本的 SqlCacheDependency 原型时遇到问题。

已经用 sproc 试过了，但现在我要直接执行命令了。

    public SqlCommand GetReadCommand(int ID)
    {
        SqlCommand cmd = new SqlCommand("SELECT dbo.Entity.Entity_ID, dbo.Entity.Name FROM dbo.Entity WHERE Entity_ID = @ID", _conn);
        cmd.CommandType = CommandType.Text;
        cmd.Parameters.Add(new SqlParameter("ID", ID));

        return cmd;
    }

    public SqlCacheDependency GetSqlDependency(int ID)
    {
        SqlCommand cmd = GetReadCommand(ID);
        SqlCacheDependency dep = new SqlCacheDependency(cmd);
        return dep;
    }

我正在读取所有对象的数据集，并对我手动插入的一些数据创建一个非常简单的依赖测试：

    public DataSet SelectAll()
    {
        DataSet result;
        if (_cache["Entity_FullSet"] == null)
        {
            SqlCommand cmd = new SqlCommand("dbo.GetAllEntities", _conn);
            cmd.CommandType = CommandType.StoredProcedure;
            _conn.Open();

            SqlDataAdapter da = new SqlDataAdapter(cmd);
            result = new DataSet();
            da.Fill(result);


            _cache[MasterCacheKey()] = DateTime.Now;
            string[] mk = new[] { MasterCacheKey() };
            CacheDependency cd = new CacheDependency(null, mk);

            SqlCacheDependency scd = new SqlCacheDependency(GetReadCommand(1));
            CacheDependency[] cds = new[] { cd, scd };

            AggregateCacheDependency acd = new AggregateCacheDependency();
            acd.Add(acd);

            _cache.Insert("Entity_FullSet", result, scd);
            _conn.Close();
        }
        else
        {
            result = (DataSet)_cache["Entity_FullSet"];
        }
        return result;
    }

'主密钥'用于测试聚合缓存依赖项 - 更改它效果很好，但对 1（变量 scd）的 sql 依赖项根本不起作用。如果我去更新表 - 甚至删除行 - 没有任何反应，缓存不会被清除。

在此处输入图像描述

任何关于为什么 sql 依赖项没有注册/触发的想法将不胜感激！

4

1 回答 1

1

您是否在数据库中启用了服务代理，并打开了查询通知？

ALTER DATABASE [YourDB] SET ENABLE_BROKER WITH ROLLBACK IMMEDIATE

在 Application_Start() 中：

SqlDependency.Start(connectionString)

并在 Application_End() 中调用 Stop()。

您可以发布存储过程的代码吗？你有没有机会SET NOCOUNT ON在你的 SP 开始？如果是这样，那将阻止查询通知。

对于上面发布的代码，请尝试将这些由 3 部分组成的列名称替换为一个或两个部分的名称。例如，将“dbo.Entity.Entity_ID”替换为“Entity_ID”或（更好的）“e.Entity_ID”（在将别名“e”分配给 dbo.Entity 之后）。

于 2011-12-17T08:16:54.160 回答