SqlDependency执行复杂SQL语句
参考：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 partialclass _Default : System.Web.UI.Page
{
privatestatic 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();
}
}
privatestring GetListenSQL()
{
return sql1
}
privatestring GetSelectSQL()
{
return sql2;
}
privatevoid 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;
}
}
}
privatevoid 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();
}
}
页:
[1]