如何找出哪个SQLDependency触发了更改函数?
-
11-12-2019 - |
题
我正在探索查询通知 SQLDependency
班级。构建一个简单的工作示例很容易,但我觉得我错过了一些东西。一旦我走过一个简单的单表/单依赖示例,我就想知道 我如何找出哪个依赖项触发了我的回调?
我在解释时遇到了一些麻烦,所以我在下面提供了一个简单的示例。什么时候 AChange()
被称为我无法查看依赖项内的 sql,并且我没有对关联缓存对象的引用。
那么男孩该做什么呢?
- 选项1 - 为每个我想要跟踪的对象创建一个不同的函数,并在回调中对缓存键(或相关信息)进行硬编码。这感觉很脏,并且消除了在不部署新代码的情况下添加新缓存项的可能性——ewww。
- 选项2 - 使用依赖项
Id
属性和并行跟踪结构
我只是错过了什么吗?这是否是一个缺陷 SQLDependency
结构?我已经看过 20 篇关于这个主题的不同文章,它们似乎都有相同的漏洞。建议?
代码示例
public class DependencyCache{
public static string cacheName = "Client1";
public static MemoryCache memCache = new MemoryCache(cacheName);
public DependencyCache() {
SqlDependency.Start(connString);
}
private static string GetSQL() {
return "select someString FROM dbo.TestTable";
}
public void DoTest() {
if (memCache["TEST_KEY"] != null ) {
Debug.WriteLine("resources found in cache");
return;
}
Cache_GetData();
}
private void Cache_GetData() {
SqlConnection oConn;
SqlCommand oCmd;
SqlDependency oDep;
SqlDataReader oRS;
List<string> stuff = new List<string>();
CacheItemPolicy policy = new CacheItemPolicy();
SqlDependency.Start(connString);
using (oConn = new SqlConnection(connString) ) {
using (oCmd = new SqlCommand(GetSQL(), oConn) ) {
oDep = new SqlDependency(oCmd);
oConn.Open();
oRS = oCmd.ExecuteReader();
while(oRS.Read() ) {
resources.Add( oRS.GetString(0) );
}
oDep.OnChange += new OnChangeEventHandler (AChange);
}
}
memCache.Set("TEST_KEY", stuff, policy);
}
private void AChange( object sender, SqlNotificationEventArgs e) {
string msg= "Dependency Change \nINFO: {0} : SOURCE {1} :TYPE: {2}";
Debug.WriteLine(String.Format(msg, e.Info, e.Source, e.Type));
// If multiple queries use this as a callback how can i figure
// out WHAT QUERY TRIGGERED the change?
// I can't figure out how to tell multiple dependency objects apart
((SqlDependency)sender).OnChange -= Cache_SqlDependency_OnChange;
Cache_GetData(); //reload data
}
}
解决方案
首先也是最重要的:必须设置处理程序 前 执行命令:
oDep = new SqlDependency(oCmd);
oConn.Open();
oDep.OnChange += new OnChangeEventHandler (AChange);
oRS = oCmd.ExecuteReader();
while(oRS.Read() ) {
resources.Add( oRS.GetString(0) );
}
否则,您会出现一个窗口,通知可能会丢失并且您的回调永远不会被调用。
现在关于你的问题:您应该为每个查询使用单独的回调。虽然这看起来很麻烦,但实际上使用 lambda 就很简单了。像下面这样:
oDep = new SqlDependency(oCmd);
oConn.Open();
oDep.OnChange += (sender, e) =>
{
string msg = "Dependency Change \nINFO: {0} : SOURCE {1} :TYPE: {2}";
Debug.WriteLine(String.Format(msg, e.Info, e.Source, e.Type));
// The command that trigger the notification is captured in the context:
// is oCmd
//
// You can now call a handler passing in the relevant info:
//
Reload_Data(oCmd, ...);
};
oRS = oCmd.ExecuteReader();
...
并记住 总是 检查通知来源、信息和类型。否则,当您收到原因通知时,您可能会面临令人作呕的风险 其他 比数据更改,例如无效查询。作为旁注,我想补充一点,好的缓存设计不会在失效时刷新缓存,而只是使缓存的项目失效并让 下一个请求 实际上去拿一件新鲜的东西。通过“主动”方法,即使不需要,您也会刷新缓存的项目,在访问它们之前多次刷新等等。我在示例中遗漏了错误处理和正确的线程同步(两者都是必需的)。
最后,看一下 LinqtoCache 它几乎可以完成您想要做的事情,但对于 LINQ 查询。
不隶属于 StackOverflow