我正在关注博客 http://www.venkatbaggu.com/signalr-database-update-notifications-asp-net-mvc-usiing-sql-dependency/,以便将 signalR 推送消息发送到连接的客户端。我的调试器永远不会命中 onchange 事件。
my Global.asax.cs:
string connString = ConfigurationManager.ConnectionStrings["DefaultConnection"].ConnectionString;
protected void Application_Start()
{
// basic stuff
SqlDependency.Start(connString);
var repo = new Repositories.MarkerRepository();
repo.GetAllMarkers(); // to register the dependency
}
我的标记存储库.cs:
readonly string _connString = ConfigurationManager.ConnectionStrings["DefaultConnection"].ConnectionString;
private MarkersHub _mh = new MarkersHub(); // my signalr hub class
public IEnumerable<House> GetAllMarkers()
{
var markers = new List<House>();
using (var connection = new SqlConnection(_connString))
{
connection.Open();
using (var command = new SqlCommand(@"SELECT * FROM [dbo].Houses", connection))
{
command.Notification = null;
var dependency = new SqlDependency(command);
dependency.OnChange += new OnChangeEventHandler(dependency_OnChange);
if (connection.State == ConnectionState.Closed)
connection.Open();
var reader = command.ExecuteReader();
while (reader.Read())
{
markers.Add(item: new House {
ID = (int)reader["ID"],
Name = (string)reader["Name"],
Code = reader["Code"] != DBNull.Value ? (string)reader["Code"] : "",
Latitude = Convert.ToDouble(reader["Latitude"]),
Longitude = Convert.ToDouble(reader["Longitude"])
});
}
}
}
return markers;
}
private void dependency_OnChange(object sender, SqlNotificationEventArgs e)
{
if (e.Type == SqlNotificationType.Change)
{
_mh.SendMarkers();
}
}
我曾经遇到过一次打击,但没有变化,只是订阅通知。我已经阅读了很多关于重新订阅的信息,但是当它遇到此事件时,sql:
select * from sys.dm_qn_subscriptions
仍然不返回任何行。不在我的数据库或主服务器上。所以我认为重新订阅更改事件的博客文章中存在错误?此示例 https://msdn.microsoft.com/en-us/library/a52dhwx7(VS.80(.aspx 在 onchange 事件中取消注册,并调用注册新事件的方法。有人可以验证我的假设吗?
这些是我的事件中SqlNotificationEventArgs e
的值,并告诉我要依赖的查询无效。
SqlNotificationEventArgs.Type
--> SqlNotificationType.Subscribe
SqlNotificationEventArgs.Info
--> SqlNotificationInfo.Invalid
SqlNotificationEventArgs.Source
--> SqlNotificationSource.Statement
该语句不能使用星号 (( 或 table_name. 语法来指定列。
来源 https://msdn.microsoft.com/en-us/library/ms181122.aspx