参考：
l http://msdn.microsoft.com/en-US/library/3ht3391b(v=vs.80).aspx
l http://msdn.microsoft.com/en-us/library/a52dhwx7(v=vs.80).aspx
l http://www.codeproject.com/Articles/144344/Query-Notification-using-SqlDependency-and-SqlCach
l http://blog.csdn.net/jinjazz/article/details/2739228
SqlDependency监听的SQL语句有很多限制。参考:http://msdn.microsoft.com/en-US/library/ms181122.aspx。
我有一个需求:用sql1监听table_A,但是需要的结果是sql2(table_A和table_B的outer join的sql语句)。
一直以为只要简单在OnChangeEventHandler托管函数中，不执行sql1，直接执行sql2。但是测试总是不成功。后来尝试了几次才发现:
SqlDependency启用监听sql1语句后，如果不执行被监听语句sql1，那么就不能执行其他sql语句。
下面是我的代码示例。
| 在global.asax Application_Start函数和Application_End函数中启用和停止服务的监听。 |
| void Application_Start(object sender, EventArgs e) { // Code that runs on application startup SqlDependency.Start(ConfigurationManager.ConnectionStrings["www.cngoldzone.com"].ConnectionString); }
void Application_End(object sender, EventArgs e) { // Code that runs on application shutdown SqlDependency.Stop(ConfigurationManager.ConnectionStrings["www.cngoldzone.com"].ConnectionString); } |
| 在 default.aspx中添加两个控件：GridView1, lblDate 对应的defualt.aspx.cs文件代码： |
| public partial class _Default : System.Web.UI.Page { private static DateTime updateTime = DateTime.Now;
protectedvoid Page_Load(object sender, EventArgs e) { if (!IsPostBack) { if (Cache["TableDate"]== null) { GetData(); } DataTable dt =(DataTable)Cache["TableDate"]; GridView1.DataSource= dt; GridView1.DataBind(); lblDate.Text= updateTime.ToString(); } }
private string GetListenSQL() { return sql1 }
private string GetSelectSQL() { return sql2; }
private void GetSelectData() { using (SqlConnection cn = new SqlConnection(ConfigurationManager.ConnectionStrings["www.cngoldzone.com"].ConnectionString)) { using (SqlCommand cmd = cn.CreateCommand()) { cn.Open(); cmd.CommandText= GetSelectSQL();
DataTable dt =new DataTable(); using(SqlDataReader rdr = cmd.ExecuteReader()) { dt.Load(rdr); } Cache["TableDate"]= dt;
updateTime = DateTime.Now; } } }
private void GetData() { using (SqlConnection cn = new SqlConnection(ConfigurationManager.ConnectionStrings["www.cngoldzone.com"].ConnectionString)) { using (SqlCommand cmd = cn.CreateCommand()) { cn.Open(); cmd.CommandText= GetListenSQL(); SqlDependency dep =new SqlDependency(cmd); //当有DML操作时，onChange事件会接收来自Sql Server通过sq_DispatcherProc存储过程发送给应用程序的消息。 dep.OnChange+= new OnChangeEventHandler(dep_OnChange); DataTable dt =new DataTable(); cmd.ExecuteScalar(); } }
GetSelectData(); }
void dep_OnChange(object sender, SqlNotificationEventArgs e) { /* 当取数据时间长时，有可能数据未取完，窗口就初关闭.所以先删除Cahce,在取数据。 */ Cache.Remove("Cache"); GetData(); } } |