SqlDependency.OnChange 触发但 SqlDataReader 没有返回数据
SqlDependency.OnChange firing but SqlDataReader is not returning with data
当我使用日期时间列过滤器执行查询时
WHERE [Order].CreatedOn >= @CreatedOn
使用 SqlDependency
,数据源的更改会触发 SqlDependency.OnChange
事件,但与 SqlCommand
关联的 SqlDataReader
不会 return 数据(reader.HasRows
总是 returns false
).
当我将 SQL 语句中的过滤条件更改为
WHERE [Order].StatusId = 1"
它工作正常并且 SqlDataReader
returns 数据 (reader.HasRows
returns true
)
代码:
using System;
using System.Collections.Generic;
using System.Configuration;
using System.Data;
using System.Data.SqlClient;
using System.Linq;
using System.Web;
using System.Web.UI;
using System.Web.UI.WebControls;
namespace SignalRServer
{
public partial class DepartmentScreen : System.Web.UI.Page
{
protected void Page_Load(object sender, EventArgs e)
{
var u = System.Security.Principal.WindowsIdentity.GetCurrent().User;
var UserName = u.Translate(Type.GetType("System.Security.Principal.NTAccount")).Value;
CheckForNewOrders(DateTime.Now);
}
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 >= @CreatedOn");
// query = string.Format(@"
// SELECT [Order].OrderId
// FROM [dbo].[Order]
// WHERE [Order].StatusId = 1");
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)
{
reader.Read();
json = reader[0].ToString();
}
}
}
SignalRHub hub = new SignalRHub();
hub.OrderReceived(json, null);
}
private void dependency_OnChange(object sender, SqlNotificationEventArgs e)
{
if (e.Type == SqlNotificationType.Change)
{
CheckForNewOrders(DateTime.Now);
}
else
{
//Do somthing here
//Console.WriteLine(e.Type);
}
}
}
}
图片:
当从 onchange
事件调用方法 CheckForNewOrders
时
command.Parameters.Add("@CreatedOn", SqlDbType.DateTime);
command.Parameters["@CreatedOn"].Value = DateTime.Now;
对于参数 @CreatedOn
,您正在传递 DateTime.Now
(不是其更改时间)。数据库中不会有满足条件的数据。
当将 DateTime.Now 作为参考日期传递时,您不太可能检索到在某个时间点创建的记录(除非记录是在将来创建的,因此您对您的服务器时间或列名 "createdOn" 非常误导)。
要根据某个更新日期获取最新记录,您需要执行以下操作:
- 创建一个全局变量来保存您创建的最大日期
已经检索到(
_refDate
在我的例子中,初始化为值
您选择 DateTime.MinValue 在我的例子中在第一次调用中获取所有记录,然后仅增量获取它们,您也可以使用 DateTime.Now 在某个时刻开始)
- 触发 CheckForNewOrders 查询
- 当您检索结果时,还要发送 CreatedOn 列并将检索到的最大 CreatedOn 日期保存为新的参考日期
- 当数据库中的值发生变化并触发
dependency_OnChange
事件时,您需要使用 _refDate
的最后一个值触发查询,以便获取尚未检索到的所有内容
- 再次更新
_refDate
的值,依此类推..
未测试,但这应该有效(注意 _refDate 可以在全球范围内访问)
public partial class DepartmentScreen : System.Web.UI.Page
{
protected void Page_Load(object sender, EventArgs e)
{
var u = System.Security.Principal.WindowsIdentity.GetCurrent().User;
var UserName = u.Translate(Type.GetType("System.Security.Principal.NTAccount")).Value;
CheckForNewOrders(_refDate);
}
private DateTime _refDate = DateTime.MinValue;
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, [Order].CreatedOn
FROM [dbo].[Order]
WHERE [Order].CreatedOn >= @CreatedOn");
// query = string.Format(@"
// SELECT [Order].OrderId
// FROM [dbo].[Order]
// WHERE [Order].StatusId = 1");
using (SqlCommand command = new SqlCommand(query, connection))
{
command.Parameters.Add("@CreatedOn", SqlDbType.DateTime);
command.Parameters["@CreatedOn"].Value = dt;
command.Notification = null;
SqlDependency dependency = new SqlDependency(command);
dependency.OnChange += new OnChangeEventHandler(dependency_OnChange);
connection.Open();
SqlDataReader reader = command.ExecuteReader();
if (reader.HasRows)
{
while (reader.Read())
{
//json = reader[0].ToString();
var date = Convert.ToDateTime(reader["CreatedOn"]);
if (date > _refDate)
{
_refDate = date;
}
}
}
}
}
//SignalRHub hub = new SignalRHub();
//hub.OrderReceived(json, null);
}
private void dependency_OnChange(object sender, SqlNotificationEventArgs e)
{
if (e.Type == SqlNotificationType.Change)
{
CheckForNewOrders(_refDate);
}
else
{
//Do somthing here
//Console.WriteLine(e.Type);
}
}
}
}
当我使用日期时间列过滤器执行查询时
WHERE [Order].CreatedOn >= @CreatedOn
使用 SqlDependency
,数据源的更改会触发 SqlDependency.OnChange
事件,但与 SqlCommand
关联的 SqlDataReader
不会 return 数据(reader.HasRows
总是 returns false
).
当我将 SQL 语句中的过滤条件更改为
WHERE [Order].StatusId = 1"
它工作正常并且 SqlDataReader
returns 数据 (reader.HasRows
returns true
)
代码:
using System;
using System.Collections.Generic;
using System.Configuration;
using System.Data;
using System.Data.SqlClient;
using System.Linq;
using System.Web;
using System.Web.UI;
using System.Web.UI.WebControls;
namespace SignalRServer
{
public partial class DepartmentScreen : System.Web.UI.Page
{
protected void Page_Load(object sender, EventArgs e)
{
var u = System.Security.Principal.WindowsIdentity.GetCurrent().User;
var UserName = u.Translate(Type.GetType("System.Security.Principal.NTAccount")).Value;
CheckForNewOrders(DateTime.Now);
}
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 >= @CreatedOn");
// query = string.Format(@"
// SELECT [Order].OrderId
// FROM [dbo].[Order]
// WHERE [Order].StatusId = 1");
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)
{
reader.Read();
json = reader[0].ToString();
}
}
}
SignalRHub hub = new SignalRHub();
hub.OrderReceived(json, null);
}
private void dependency_OnChange(object sender, SqlNotificationEventArgs e)
{
if (e.Type == SqlNotificationType.Change)
{
CheckForNewOrders(DateTime.Now);
}
else
{
//Do somthing here
//Console.WriteLine(e.Type);
}
}
}
}
图片:
当从 onchange
事件调用方法 CheckForNewOrders
时
command.Parameters.Add("@CreatedOn", SqlDbType.DateTime);
command.Parameters["@CreatedOn"].Value = DateTime.Now;
对于参数 @CreatedOn
,您正在传递 DateTime.Now
(不是其更改时间)。数据库中不会有满足条件的数据。
当将 DateTime.Now 作为参考日期传递时,您不太可能检索到在某个时间点创建的记录(除非记录是在将来创建的,因此您对您的服务器时间或列名 "createdOn" 非常误导)。
要根据某个更新日期获取最新记录,您需要执行以下操作:
- 创建一个全局变量来保存您创建的最大日期
已经检索到(
_refDate
在我的例子中,初始化为值 您选择 DateTime.MinValue 在我的例子中在第一次调用中获取所有记录,然后仅增量获取它们,您也可以使用 DateTime.Now 在某个时刻开始) - 触发 CheckForNewOrders 查询
- 当您检索结果时,还要发送 CreatedOn 列并将检索到的最大 CreatedOn 日期保存为新的参考日期
- 当数据库中的值发生变化并触发
dependency_OnChange
事件时,您需要使用_refDate
的最后一个值触发查询,以便获取尚未检索到的所有内容 - 再次更新
_refDate
的值,依此类推..
未测试,但这应该有效(注意 _refDate 可以在全球范围内访问)
public partial class DepartmentScreen : System.Web.UI.Page
{
protected void Page_Load(object sender, EventArgs e)
{
var u = System.Security.Principal.WindowsIdentity.GetCurrent().User;
var UserName = u.Translate(Type.GetType("System.Security.Principal.NTAccount")).Value;
CheckForNewOrders(_refDate);
}
private DateTime _refDate = DateTime.MinValue;
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, [Order].CreatedOn
FROM [dbo].[Order]
WHERE [Order].CreatedOn >= @CreatedOn");
// query = string.Format(@"
// SELECT [Order].OrderId
// FROM [dbo].[Order]
// WHERE [Order].StatusId = 1");
using (SqlCommand command = new SqlCommand(query, connection))
{
command.Parameters.Add("@CreatedOn", SqlDbType.DateTime);
command.Parameters["@CreatedOn"].Value = dt;
command.Notification = null;
SqlDependency dependency = new SqlDependency(command);
dependency.OnChange += new OnChangeEventHandler(dependency_OnChange);
connection.Open();
SqlDataReader reader = command.ExecuteReader();
if (reader.HasRows)
{
while (reader.Read())
{
//json = reader[0].ToString();
var date = Convert.ToDateTime(reader["CreatedOn"]);
if (date > _refDate)
{
_refDate = date;
}
}
}
}
}
//SignalRHub hub = new SignalRHub();
//hub.OrderReceived(json, null);
}
private void dependency_OnChange(object sender, SqlNotificationEventArgs e)
{
if (e.Type == SqlNotificationType.Change)
{
CheckForNewOrders(_refDate);
}
else
{
//Do somthing here
//Console.WriteLine(e.Type);
}
}
}
}