c# - 如何通知其他用户对数据所做的更改

Question

我们有一个被许多用户使用的 ASP.NET 应用程序。此应用程序正在使用自定义数据库。每当一位用户进行更改时，我们都会将更改保存到自定义数据库的审计表中。

现在我们需要将此更改通知其他登录用户...如何完成？

我正在考虑这个解决方案，但它可能有点矫枉过正？

• 每当表更改时以某种方式创建一个 sql 触发器..在文件系统的文本文件中创建一条记录

• 创建一个网络服务来持续检查是否有任何新内容添加到文件系统以及它是否向其他用户显示通知。

我正在使用文件系统，因为我不想杀死 sql。

Answer 1

在这个例子中，我创建了一个非常简单的带有网格的 WPF 应用程序，模拟一些股票值(value)。

让我们开始假设以下数据库表:

CREATE TABLE [dbo].[Stocks]( [Code] [nvarchar](50) NULL, [Name] [nvarchar](50) NULL, [Price] [decimal](18, 0) NULL) GO INSERT [dbo].[Stocks] ([Code], [Name], [Price]) VALUES (N'MCD', N'McDonald Corp', CAST(333 AS Decimal(18, 0))) INSERT [dbo].[Stocks] ([Code], [Name], [Price]) VALUES (N'NKE', N'Nike Inc', CAST(240 AS Decimal(18, 0))) INSERT [dbo].[Stocks] ([Code], [Name], [Price]) VALUES (N'DIS', N'Walt Disney Co', CAST(130 AS Decimal(18, 0))) INSERT [dbo].[Stocks] ([Code], [Name], [Price]) VALUES (N'UTX', N'United Technologies Corp', CAST(130 AS Decimal(18, 0))) INSERT [dbo].[Stocks] ([Code], [Name], [Price]) VALUES (N'MSFT', N'Microsoft Corp', CAST(130 AS Decimal(18, 0))) INSERT [dbo].[Stocks] ([Code], [Name], [Price]) VALUES (N'PFE', N'Pfizer Inc', CAST(130 AS Decimal(18, 0))) INSERT [dbo].[Stocks] ([Code], [Name], [Price]) VALUES (N'INTC', N'Intel Corp', CAST(130 AS Decimal(18, 0))) INSERT [dbo].[Stocks] ([Code], [Name], [Price]) VALUES (N'KO', N'Coca Cola Co', CAST(130 AS Decimal(18, 0))) GO

此表会根据新的股票值(value)不断更新。我们希望在不使用任何轮询系统的情况下不断更新我们的网格。因此，我们需要的是每次表中的记录发生更改时来自数据库的通知。

我们使用以下命令从 visual studio 安装 SqlTableDependency 包:

PM> Install-Package SqlTableDependency

现在我们定义一个映射感兴趣的表列的 C# 模型。

public class Stock { public decimal Price { get; set; } public string Symbol { get; set; } public string Name { get; set; } }

如您所见，模型的属性名称可以具有不同的表列名称。在这种情况下，我们需要一个映射器来正确绑定(bind)值:

var mapper = new ModelToTableMapper<Stock>(); mapper.AddMapping(model => model.Symbol, "Code");

最后我们创建 SqlTableDependency:

_dependency = new SqlTableDependency<Stock>(_connectionString, "Stocks", mapper); _dependency.OnChanged += _dependency_OnChanged; _dependency.OnError += _dependency_OnError; _dependency.Start();

完整代码如下:

public partial class Window1 : Window { private IList<Stock> _stocks; private readonly string _connectionString = "data source=.;initial catalog=TableDependencyDB;integrated security=True"; private readonly SqlTableDependency<Stock> _dependency; public Window1() { this.InitializeComponent(); this.McDataGrid.ItemsSource = LoadCollectionData(); this.Closing += Window1_Closing; var mapper = new ModelToTableMapper<Stock>(); mapper.AddMapping(model => model.Symbol, "Code"); _dependency = new SqlTableDependency<Stock>(_connectionString, "Stocks", mapper); _dependency.OnChanged += _dependency_OnChanged; _dependency.OnError += _dependency_OnError; _dependency.Start(); } private void Window1_Closing(object sender, System.ComponentModel.CancelEventArgs e) { _dependency.Stop(); } private void _dependency_OnError(object sender, TableDependency.EventArgs.ErrorEventArgs e) { throw e.Error; } private void _dependency_OnChanged(object sender, TableDependency.EventArgs.RecordChangedEventArgs<Stock> e) { if (_stocks != null) { if (e.ChangeType != ChangeType.None) { switch (e.ChangeType) { case ChangeType.Delete: _stocks.Remove(_stocks.FirstOrDefault(c => c.Symbol == e.Entity.Symbol)); break; case ChangeType.Insert: _stocks.Add(e.Entity); break; case ChangeType.Update: var customerIndex = _stocks.IndexOf(_stocks.FirstOrDefault(c => c.Symbol == e.Entity.Symbol)); if (customerIndex >= 0) _stocks[customerIndex] = e.Entity; break; } this.McDataGrid.Dispatcher.Invoke(DispatcherPriority.Background, new Action(() => { this.McDataGrid.Items.Refresh(); })); } } } private IEnumerable<Stock> LoadCollectionData() { _stocks = new List<Stock>(); using (var sqlConnection = new SqlConnection(_connectionString)) { sqlConnection.Open(); using (var sqlCommand = sqlConnection.CreateCommand()) { sqlCommand.CommandText = "SELECT * FROM [Stocks]"; using (var sqlDataReader = sqlCommand.ExecuteReader()) { while (sqlDataReader.Read()) { var code = sqlDataReader.GetString(sqlDataReader.GetOrdinal("Code")); var name = sqlDataReader.GetString(sqlDataReader.GetOrdinal("Name")); var price = sqlDataReader.GetDecimal(sqlDataReader.GetOrdinal("Price")); _stocks.Add(new Stock { Symbol = code, Name = name, Price = price }); } } } } return _stocks; } }

正如您从代码中看到的那样，仅执行初始选择以检索和填充网格。随后的更新是使用 SqlTableDependency 事件处理程序完成的:它接收一个模型对象，其中包含有关我们用来更新缓存的记录更改的信息。

您还可以检查How can I notify my program when the database has been updated? .