一、sqldependency說明

sqlDependency 提供了一種能力：當監測的數據庫中的數據發生改變的時候，sqldependency會自動觸發onChange事件來通知應用程序，從而達到讓系統自動更新數據（或者緩存的）的目的(后期會將其同signalr進行結合，以滿足實時響應)

二、sqldependency方法調用（ASP.NET CORE 3.1）

首先，將數據庫（這里使用的是SQLserver，MySql 好像叫做MySqlDependency 后期再補充）

ALTER DATABASE ShengNong SET NEW_BROKER WITH ROLLBACK IMMEDIATE;（恢復初始設置） ALTER DATABASE ShengNong SET ENABLE_BROKER;（設置通知服務）

SELECT is_broker_enabled FROM sys.databases WHERE name = 'ShengNong ’ （可以用來查看是否已經開啟通知服務）

代碼實現

在startup.cs中添加一個初始化服務 services.AddHostedService();
在TEST中 添加一個Task 異步任務
調用方法

using System.Data.SqlClient;

public async Task WatchDevice(){await Task.Run(()=> {useSqlDependency();});}

啟用 SqlDependency.Start(conStr)來開啟間監聽

public void useSqlDependency() {string conStr = AppSetting.DbConnectionString; // 在應用程序啟動時運行的代碼SqlDependency.Start(conStr);//啟動監聽服務，ps：只需啟動一次_StockService.GetFourWayBusMessage();}

在服務關閉的時候要及時關閉監控

public Task StopAsync(CancellationToken cancellationToken){string conStr = AppSetting.DbConnectionString; // 在應用程序啟動時運行的代碼SqlDependency.Stop(conStr);//啟動監聽服務，ps：只需啟動一次return Task.CompletedTask;}

通過SQL語句進行監控
注意 ：這里必須使用規范的SQL語句，而且查詢的字段不可以用*代替。這個SQL的含義就是要監控該表的相應字段，當該字段發生改變的時候執行onchange，其余字段發生改變的時候不發生該改變

/// <summary>/// 實時監控庫存日志變化/// </summary>/// <returns></returns>public DataTable GetFourWayBusMessage(){string strSQL = "select C_Code,C_IsHaveGoods,C_CurrentRow,C_CurrentLayer,C_CurrentColumn,C_TaskNum,C_Status from [dbo].[T_Device_FourWayBus] ";SqlDataAdapter da = new SqlDataAdapter(strSQL, AppSetting.DbConnectionString);SqlDependency dep = new SqlDependency(da.SelectCommand);dep.OnChange += new OnChangeEventHandler(dep_OnFourWayBusChange);DataTable tbl = new DataTable();da.Fill(tbl);return tbl;} private void dep_OnFourWayBusChange(object sender, SqlNotificationEventArgs e){if (e.Type == SqlNotificationType.Change) //只有數據發生變化時,才重新獲取并數據{var tbl = GetFourWayBusMessage();}}

這樣一個簡單的sqldependency使用就完成了

寶劍鋒從磨礪出，梅花香自苦寒來。

總結

以上是生活随笔為你收集整理的sqldependency 的使用的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。