SqlDependency.OnChange 不开火
SqlDependency.OnChange doesn't fire
我目前正在申请我的大学项目。数据库更改后,应用程序应通过电子邮件发送某种形式的通知。
有一个 .mdf
数据库文件,我与 (localdb)
连接,使用数据集 tables 和 SQLDataAdapter
s 查看和编辑(如果重要的话)或不,我不知道)。我正在尝试设置 SqlDependency
,以便它对 table 执行新标志检查,以便它可以发送有关带有这些标志的行的电子邮件。
问题是我无法使 sqlDependency.OnChange
事件触发,Service Broker
已启用。启动应用程序后,我启动 SqlDependency
,之后我在我的 SqlAdapter
方法之一中编辑和保存数据,数据库中的数据更改(在 mdf 文件中),但没有事件触发器。我尝试了多个教程,none 似乎对我有用。这是代码:
public void StartWatching()
{
SqlDependency.Stop(con.ConnectionString);
SqlDependency.Start(con.ConnectionString);
ExecuteWatchingQuery();
}
private void ExecuteWatchingQuery()
{
using (SqlConnection connection = new SqlConnection(con.ConnectionString))
{
connection.Open();
using (var command = new SqlCommand(
"select [id], [subject] from dbo.lots", connection))
{
var sqlDependency = new SqlDependency(command);
sqlDependency.OnChange += new OnChangeEventHandler(OnDatabaseChange);
SqlDataReader reader = command.ExecuteReader();
if (reader.HasRows)
{
Log_Text.AppendText("Watching... \n");
}
else
{
Log_Text.AppendText("No rows found.");
}
}
}
}
private void OnDatabaseChange(object sender, SqlNotificationEventArgs args)
{[enter image description here][1]
SqlNotificationInfo info = args.Info;
if (SqlNotificationInfo.Insert.Equals(info)
|| SqlNotificationInfo.Update.Equals(info)
|| SqlNotificationInfo.Delete.Equals(info))
{
Log_Text.AppendText("Saw changes: \n");
Watching();
}
ExecuteWatchingQuery();
}
来源:http://ts-soft.ru/blog/mssql-database-watching
[1]: https://i.stack.imgur.com/jyBOf.png table
问题在于,编辑和监控都是在同一个应用程序中完成的,我不确定是否不在同一个连接上。我将应用程序分为两个(一个 - 数据库编辑,另一个 - 用于监控的控制台应用程序),并且都开始工作了。
我目前正在申请我的大学项目。数据库更改后,应用程序应通过电子邮件发送某种形式的通知。
有一个 .mdf
数据库文件,我与 (localdb)
连接,使用数据集 tables 和 SQLDataAdapter
s 查看和编辑(如果重要的话)或不,我不知道)。我正在尝试设置 SqlDependency
,以便它对 table 执行新标志检查,以便它可以发送有关带有这些标志的行的电子邮件。
问题是我无法使 sqlDependency.OnChange
事件触发,Service Broker
已启用。启动应用程序后,我启动 SqlDependency
,之后我在我的 SqlAdapter
方法之一中编辑和保存数据,数据库中的数据更改(在 mdf 文件中),但没有事件触发器。我尝试了多个教程,none 似乎对我有用。这是代码:
public void StartWatching()
{
SqlDependency.Stop(con.ConnectionString);
SqlDependency.Start(con.ConnectionString);
ExecuteWatchingQuery();
}
private void ExecuteWatchingQuery()
{
using (SqlConnection connection = new SqlConnection(con.ConnectionString))
{
connection.Open();
using (var command = new SqlCommand(
"select [id], [subject] from dbo.lots", connection))
{
var sqlDependency = new SqlDependency(command);
sqlDependency.OnChange += new OnChangeEventHandler(OnDatabaseChange);
SqlDataReader reader = command.ExecuteReader();
if (reader.HasRows)
{
Log_Text.AppendText("Watching... \n");
}
else
{
Log_Text.AppendText("No rows found.");
}
}
}
}
private void OnDatabaseChange(object sender, SqlNotificationEventArgs args)
{[enter image description here][1]
SqlNotificationInfo info = args.Info;
if (SqlNotificationInfo.Insert.Equals(info)
|| SqlNotificationInfo.Update.Equals(info)
|| SqlNotificationInfo.Delete.Equals(info))
{
Log_Text.AppendText("Saw changes: \n");
Watching();
}
ExecuteWatchingQuery();
}
来源:http://ts-soft.ru/blog/mssql-database-watching
[1]: https://i.stack.imgur.com/jyBOf.png table
问题在于,编辑和监控都是在同一个应用程序中完成的,我不确定是否不在同一个连接上。我将应用程序分为两个(一个 - 数据库编辑,另一个 - 用于监控的控制台应用程序),并且都开始工作了。