C#_SqlDependency的使用

SqlDependency允許你在數據庫中的原始數據更改時接收通知，要接收通知，您需要訂閱OnChange事件。

SqlDependency有如下限制：

• SELECT語句中的投影列必須明確聲明，並且表名必須由兩部分組成。請注意，這意味着該語句中引用的所有表必須位於同一數據庫中。
• 該語句不能使用星號（*）或table_name。*語法指定列。
• 該語句不能使用未命名的列或重復的列名。
• 該語句必須引用基表。
• 該語句不能引用具有計算列的表。
• 除非該語句使用GROUP BY表達式，否則SELECT語句中的投影列可能不包含聚合表達式。提供GROUP BY表達式時，選擇列表可能包含聚合函數COUNT_BIG（）或SUM（）。但是，不能為可為空的列指定SUM（）。該語句可能未指定HAVING，CUBE或ROLLUP。
• SELECT語句中用作簡單表達式的投影列不得出現多次。
• 該聲明不能包含PIVOT或UNPIVOT運算符。
• 該語句不能包含UNION，INTERSECT或EXCEPT運算符。
• 該語句不能引用視圖。
• 該語句不得包含以下任何內容：DISTINCT，COMPUTE或COMPUTE BY或INTO。
• 該語句不能引用服務器全局變量（@@ variable_name）。
• 該語句不能引用派生表，臨時表或表變量。
• 該語句不得引用其他數據庫或服務器中的表或視圖。
• 該語句不能包含子查詢，外部聯接或自我聯接。
• 該語句不能引用大型對象類型：text，ntext和image。
• 該語句不得使用CONTAINS或FREETEXT全文謂詞。
• 該語句不得使用行集函數，包括OPENROWSET和OPENQUERY。
• 該語句不得使用以下任何聚合函數：AVG，COUNT（*），MAX，MIN，STDEV，STDEVP，VAR或VARP。
• 該語句不得使用任何不確定的函數，包括排名和窗口函數。
• 該語句不能包含用戶定義的聚合。
• 該語句不得引用系統表或視圖，包括目錄視圖和動態管理視圖。
• 該語句不能包含FOR BROWSE信息。
• 該語句不能引用隊列。
• 該語句不能包含不能更改且不能返回結果的條件語句（例如，WHERE 1 = 0）。
• 該語句不能指定READPAST鎖定提示。
• 該語句不能引用任何Service Broker QUEUE。
• 該語句不能引用同義詞。
• 該語句不能具有基於double / real數據類型的比較或表達式。
• 該語句不能使用TOP表達式。

在使用SqlDependency之前，首先需要啟用數據庫的服務器代理，默認情況下，SQL Server數據庫沒有啟用Service Broker。你可以使用SQL語句啟用Service Broker。

ALTER DATABASE DATABASE_NAME SET ENABLE_BROKER  

下面是使用SqlDependency的簡單示例：

        static string connectionString = @"your connect string";
        static void Main(string[] args)
        {
            SqlDependency.Start(connectionString);
            getDataWithSqlDependency();
            Console.WriteLine("Waiting for data changes");
            Console.WriteLine("Press enter to quit");
            Console.ReadLine();
            SqlDependency.Stop(connectionString);
            
        }

        static DataTable getDataWithSqlDependency()
        {
            using (var connection = new SqlConnection(connectionString))
            using (var cmd = new SqlCommand("SELECT productname FROM dbo.product;", connection))
            {
                var dt = new DataTable();
                var dependency = new SqlDependency(cmd);
                dependency.OnChange += new OnChangeEventHandler(onDependencyChange);
                connection.Open();
                dt.Load(cmd.ExecuteReader(CommandBehavior.CloseConnection));
                return dt;
            }
        }
        static void onDependencyChange(object sender,SqlNotificationEventArgs e)
        {
            Console.WriteLine($"OnChange Event fired. SqlNotificationEventArgs: Info={e.Info}, Source={e.Source}, Type={e.Type}.");

            if ((e.Info != SqlNotificationInfo.Invalid)
                && (e.Type != SqlNotificationType.Subscribe))
            {
                var dt = getDataWithSqlDependency();
                Console.WriteLine($"Data changed. {dt.Rows.Count} rows returned.");
            }
            else
            {
                Console.WriteLine("SqlDependency not restarted");
            }
            Console.ReadLine();
        }

 

參考:

https://stackoverflow.com/questions/7588572/what-are-the-limitations-of-sqldependency

https://www.c-sharpcorner.com/UploadFile/87b416/working-with-sql-notification/