SqlDependency.OnChange 未在日期时间列上使用筛选器触发
SqlDependency.OnChange is not firing with filter on datetime column
我在 SqlDependency 中使用此 SQL 语句时遇到问题。它根本没有激活 SqlDependency.OnChange 事件,而是在 SQL 服务器查询 window.
上按预期返回结果
SELECT [Order].OrderId
FROM [dbo].[Order]
WHERE [Order].CreatedOn > '20150815 21:11:57.502'
我阅读了此处支持的SELECT声明部分https://technet.microsoft.com/en-us/library/ms181122(v=sql.105).aspx,但没有发现任何违反规则的情况。
有什么想法吗?
更新:
我的完整代码如下:
private void CheckForNewOrders(DateTime dt)
{
string json = null;
string conStr = ConfigurationManager.ConnectionStrings["connstring"].ConnectionString;
using (SqlConnection connection = new SqlConnection(conStr))
{
string query = string.Format(@"
SELECT [Order].OrderId
FROM [dbo].[Order]
WHERE [Order].CreatedOn > '{0}'"
, dt.ToString("yyyyMMdd HH:mm:ss.fff")); // 20150814 00:00:00.000
using (SqlCommand command = new SqlCommand(query, connection))
{
command.Notification = null;
SqlDependency dependency = new SqlDependency(command);
dependency.OnChange += new OnChangeEventHandler(dependency_OnChange);
connection.Open();
SqlDataReader reader = command.ExecuteReader();
if (reader.HasRows)
{
reader.Read();
json = "testing ... "; reader[0].ToString();
}
}
}
}
private void dependency_OnChange(object sender, SqlNotificationEventArgs e)
{
if (e.Type == SqlNotificationType.Change)
{
CheckForNewOrders(DateTime.Now);
}
}
更新(响应 jmelosegui 的回答):
query = string.Format(@"
SELECT [Order].OrderId
FROM [dbo].[Order]
WHERE [Order].CreatedOn > @CreatedOn");
...
using (SqlCommand command = new SqlCommand(query, connection))
{
command.Parameters.Add("@CreatedOn", SqlDbType.DateTime);
command.Parameters["@CreatedOn"].Value = DateTime.Now;
command.Notification = null;
SqlDependency dependency = new SqlDependency(command);
dependency.OnChange += new OnChangeEventHandler(dependency_OnChange);
connection.Open();
SqlDataReader reader = command.ExecuteReader();
if (reader.HasRows)
{
...
}
}
我认为您应该收到不是那种类型的通知事件。
你能不能在你的 dependency_OnChange
方法中添加一个 else 分支,看看你是否得到任何其他 SqlNotificationType
,例如:
private void dependency_OnChange(object sender, SqlNotificationEventArgs e)
{
if (e.Type == SqlNotificationType.Change)
{
CheckForNewOrders(DateTime.Now);
}
else
{
//Do somthing here
Console.WriteLine(e.Type);
}
}
更新
能否尝试添加类型化参数:
WHERE [Order].CreatedOn > @myDateTime
并传入一个 DateTime 类型的参数,而不是使用字符串转换。
首先,检查所有 sql 依赖服务限制。当 sql table 更改将触发时,where 子句在 sql 依赖事件中不起作用。您的查询应该修改。
query = string.Format(@"
SELECT [Order].OrderId
FROM [dbo].[Order]
ORDER BY [dbo].[Order].DateTime desc
);
请应用这些更改并调试项目。
我在 SqlDependency 中使用此 SQL 语句时遇到问题。它根本没有激活 SqlDependency.OnChange 事件,而是在 SQL 服务器查询 window.
上按预期返回结果SELECT [Order].OrderId
FROM [dbo].[Order]
WHERE [Order].CreatedOn > '20150815 21:11:57.502'
我阅读了此处支持的SELECT声明部分https://technet.microsoft.com/en-us/library/ms181122(v=sql.105).aspx,但没有发现任何违反规则的情况。
有什么想法吗?
更新:
我的完整代码如下:
private void CheckForNewOrders(DateTime dt)
{
string json = null;
string conStr = ConfigurationManager.ConnectionStrings["connstring"].ConnectionString;
using (SqlConnection connection = new SqlConnection(conStr))
{
string query = string.Format(@"
SELECT [Order].OrderId
FROM [dbo].[Order]
WHERE [Order].CreatedOn > '{0}'"
, dt.ToString("yyyyMMdd HH:mm:ss.fff")); // 20150814 00:00:00.000
using (SqlCommand command = new SqlCommand(query, connection))
{
command.Notification = null;
SqlDependency dependency = new SqlDependency(command);
dependency.OnChange += new OnChangeEventHandler(dependency_OnChange);
connection.Open();
SqlDataReader reader = command.ExecuteReader();
if (reader.HasRows)
{
reader.Read();
json = "testing ... "; reader[0].ToString();
}
}
}
}
private void dependency_OnChange(object sender, SqlNotificationEventArgs e)
{
if (e.Type == SqlNotificationType.Change)
{
CheckForNewOrders(DateTime.Now);
}
}
更新(响应 jmelosegui 的回答):
query = string.Format(@"
SELECT [Order].OrderId
FROM [dbo].[Order]
WHERE [Order].CreatedOn > @CreatedOn");
...
using (SqlCommand command = new SqlCommand(query, connection))
{
command.Parameters.Add("@CreatedOn", SqlDbType.DateTime);
command.Parameters["@CreatedOn"].Value = DateTime.Now;
command.Notification = null;
SqlDependency dependency = new SqlDependency(command);
dependency.OnChange += new OnChangeEventHandler(dependency_OnChange);
connection.Open();
SqlDataReader reader = command.ExecuteReader();
if (reader.HasRows)
{
...
}
}
我认为您应该收到不是那种类型的通知事件。
你能不能在你的 dependency_OnChange
方法中添加一个 else 分支,看看你是否得到任何其他 SqlNotificationType
,例如:
private void dependency_OnChange(object sender, SqlNotificationEventArgs e)
{
if (e.Type == SqlNotificationType.Change)
{
CheckForNewOrders(DateTime.Now);
}
else
{
//Do somthing here
Console.WriteLine(e.Type);
}
}
更新
能否尝试添加类型化参数:
WHERE [Order].CreatedOn > @myDateTime
并传入一个 DateTime 类型的参数,而不是使用字符串转换。
首先,检查所有 sql 依赖服务限制。当 sql table 更改将触发时,where 子句在 sql 依赖事件中不起作用。您的查询应该修改。
query = string.Format(@"
SELECT [Order].OrderId
FROM [dbo].[Order]
ORDER BY [dbo].[Order].DateTime desc
);
请应用这些更改并调试项目。