SqlDependency和 SQL Server例項間的查詢通知依賴關係
阿新 • • 發佈:2019-01-03
SqlDependency 物件表示應用程式和 SQL Server 2005 例項間的查詢通知依賴關係。應用程式可以建立一個 SqlDependency 物件並進行註冊以通過 事件處理程式接收通知。
快速上手可參見園友的下列文章
1.先建一個測試表
CREATE TABLE [dbo].[Messages]( [ID] [int] IDENTITY(1,1) NOT NULL, [UserID] [varchar](50) COLLATE Chinese_PRC_CI_AS NOT NULL, [Message] [nvarchar](256) COLLATE Chinese_PRC_CI_AS NOT NULL, CONSTRAINT [PK_Messages] PRIMARY KEY CLUSTERED ( [ID] ASC )WITH (PAD_INDEX = OFF, STATISTICS_NORECOMPUTE = OFF, IGNORE_DUP_KEY = OFF, ALLOW_ROW_LOCKS = ON, ALLOW_PAGE_LOCKS = ON) ON [PRIMARY] )
然後可以利用Sql2005的管理器,隨便輸入幾條資料
2.控制檯程式主要程式碼
using System; using System.Configuration; using System.Data; using System.Data.SqlClient; namespace SqlDependencyTest { class Program { private static string _connStr; static void Main(string[] args) { _connStr = ConfigurationManager.ConnectionStrings["ConnStr"].ToString(); SqlDependency.Start(_connStr);//傳入連線字串,啟動基於資料庫的監聽 UpdateGrid(); Console.Read(); } private static void UpdateGrid() { using (SqlConnection connection = new SqlConnection(_connStr)) { //依賴是基於某一張表的,而且查詢語句只能是簡單查詢語句,不能帶top或*,同時必須指定所有者,即類似[dbo].[] using (SqlCommand command = new SqlCommand("select ID,UserID,[Message] From [dbo].[Messages]", connection)) { command.CommandType = CommandType.Text; connection.Open(); SqlDependency dependency = new SqlDependency(command); dependency.OnChange += new OnChangeEventHandler(dependency_OnChange); SqlDataReader sdr = command.ExecuteReader(); Console.WriteLine(); while (sdr.Read()) { Console.WriteLine("Id:{0}\tUserId:{1}\tMessage:{2}",sdr["ID"].ToString(), sdr["UserId"].ToString(), sdr["Message"].ToString()); } sdr.Close(); } } } private static void dependency_OnChange(object sender, SqlNotificationEventArgs e) { UpdateGrid(); } } }
3.測試執行
執行該控制檯程式後,會輸出[Messages]表的所有資料,這時不要關閉控制檯程式,直接在Sql2005的管理器裡對[Messages]表的資料做些修改(比如新增/刪除等),再看一下控制檯,會發現自動重新輸出了新的資料.
注意:如果在web應用中,因為頁面必須通過瀏覽器請求才能啟用服務端的處理,所以頁面一旦處理完成並顯示到瀏覽器後,放著不動的情況下,OnChange事件始終是得不到觸發的.