我不知道为什么SqlCacheDependency
对象的HasChanged
值最初从命令执行返回为false,但在数据从数据库返回后几乎立即返回,值更改为true。为什么我的SqlCacheDependency HasChanged会变回false,但在更改为true后几乎立即变为false?
有时甚至在项目被插入到缓存之前发生,导致缓存立即丢弃它,有时候是在插入之后,我可以获取一个枚举器,它在缓存中但是在我循环到该项目在缓存中已被删除。
存储过程:
ALTER PROCEDURE [dbo].[ntz_dal_ER_X_Note_SelectAllWER_ID]
@ER_ID int
AS
BEGIN
SELECT
ER_X_Note_ID,
ER_ID,
Note_ID
FROM dbo.ER_X_Note e
WHERE
ER_ID = @ER_ID
END
的数据库是MS SQL Server 2008中,中介服务已启用,以及一些输出做缓存和保持缓存。举例来说,这个工作得很好:
ALTER PROC [dbo].[ntz_dal_GetCacheControllerByEntityName] (
@Name varchar(50)
) AS
BEGIN
SELECT
CacheController_ID,
EntityName,
CacheEnabled,
Expiration
From dbo.CacheController cc
WHERE EntityName = @Name
END
它调用存储过程中的问题,失败的代码:
,工程 const string sprocName = "ntz_dal_GetCacheControllerByEntityName";
string cacheControlPrefix = "CacheController_" + CachePrefix;
CacheControl controller = (CacheControl)_cache[cacheControlPrefix];
if (controller == null)
{
try
{
SqlParameter[] arParms = {
new SqlParameter("@Name", CachePrefix),
};
SqlCacheDependency sqlCacheDependency;
// Execute query.
DataSet result = _dbTransaction != null
? _dbConnection.ExecuteDataset(_dbTransaction, sprocName, out sqlCacheDependency, arParms)
: _dbConnection.ExecuteDataset(sprocName, out sqlCacheDependency, arParms);
controller = result.Tables[0].Rows.Count == 0
? new CacheControl(false)
: new CacheControl(result.Tables[0].Rows[0]);
_cache.Insert(cacheControlPrefix, controller, sqlCacheDependency);
}
catch (Exception ex)
{
// if sproc retreival fails cache the result of false so we don't keep trying
// this is the only case where it can be added with no expiration date
controller = new CacheControl(false);
// direct cache insert, no dependency, no expiration, never try again for this entity
if (HttpContext.Current != null && UseCaching && _cache != null) _cache.Insert(cacheControlPrefix, controller);
}
}
return controller;
的AddToCache
方法重载,
DataSet toReturn;
Hashtable paramHash = new Hashtable();
paramHash.Add("ER_ID", _eR_ID.IsNull ? null : _eR_ID.Value.ToString());
string cacheName = BuildCacheString("ntz_dal_ER_X_Note_SelectAllWER_ID", paramHash);
toReturn = (DataSet)GetFromCache(cacheName);
if (toReturn == null)
{
// Set up parameters (1 input and 0 output)
SqlParameter[] arParms = {
new SqlParameter("@ER_ID", _eR_ID),
};
SqlCacheDependency scd;
// Execute query.
toReturn = _dbTransaction != null
? _dbConnection.ExecuteDataset(_dbTransaction, "dbo.[ntz_dal_ER_X_Note_SelectAllWER_ID]", out scd, arParms)
: _dbConnection.ExecuteDataset("dbo.[ntz_dal_ER_X_Note_SelectAllWER_ID]", out scd, arParms);
AddToCache(cacheName, toReturn, scd);
}
return toReturn;
代码有更多的测试;工作方法中的直接_cache.Insert
是绕过其他测试。工作代码有助于确定数据库缓存是否应该发生。
你可以看到,当“非工作”的数据最初检索,一切都OK:
而是介于随机超出该点,在这种情况下,刚刚步入下一个方法
然而数据并没有改变;我是唯一一个接触这个数据库实例的人。
我会试试它,但我认为这不太可能,因为param哈希仅用于构建创建缓存项的密钥名称。 – 2011-12-27 00:38:39
@TheEvilGreebo:对不起,我觉得我没有足够的沟通。我认为问题是这行代码'新的SqlParameter(“@ ER_ID”,_eR_ID)'。这将整个_eR_ID对象传递给参数,我不确定它是如何将它转换为Sql的值(我怀疑它在对象上调用了ToString())。之前在代码中使用_eR_ID.Value,所以我认为您需要的最小更改是'new SqlParameter(“@ ER_ID”,_eR_ID.Value)'。 – 2011-12-27 00:51:58
哦,我明白你的意思了。那么_eR_ID是一个SqlInt32 - 所以人们会认为使用它初始化一个新的SqlParm不会引起问题,但它值得一试! – 2011-12-27 01:47:51