WPF如何监听数据库值变化触发事件 (wpf 改变数据库值触发事件)
WPF（Windows Presentation Foundation）是一种用于构建Windows应用程序的UI框架，它提供了许多强大的功能，其中一项重要的功能是能够在数据库值变化时触发事件。这种实现方式通常称为数据绑定，它可以使开发者更加方便地处理数据库中的数据，并在数据发生变化时及时更新UI。
本文将介绍WPF如何监听数据库值变化并触发事件的方法。
1.使用实时连接（Real-Time Connection）
实时连接是WPF中一种常用的数据库监听方式。它的原理是在应用程序和数据库之间建立一个持久的连接，在数据库发生变化时立即通知应用程序。这种方式虽然能够实现实时更新，但是会导致数据库的性能下降。
在WPF中使用实时连接需要安装相关的数据库驱动，并且在应用程序中编写相应的代码实现监听功能。以下是使用实时连接的代码示例：
“`
using System.Data.SqlClient;
using System.Data;
public partial class MnWindow : Window
{
private string connectionString = “Data Source=myServerAddress;Initial Catalog=myDataBase;Integrated Security=True”;
private SqlConnection connection;
private SqlCommand command;
private SqlDependency dependency;
public MnWindow()
{
InitializeComponent();
InitializeSQLDependency();
}
private void InitializeSQLDependency()
{
SqlDependency.Start(connectionString);
if(connection == null)
{
connection = new SqlConnection(connectionString);
connection.Open();
}
if(command == null)
{
command = new SqlCommand(“SELECT * FROM myTable”, connection);
}
if(dependency == null)
{
dependency = new SqlDependency(command);
dependency.OnChange += new OnChangeEventHandler(OnDataChange);
}
SqlDataReader reader = command.ExecuteReader();
DataTable data = new DataTable();
data.Load(reader);
myDataGrid.ItemsSource = data.DefaultView;
}
private void OnDataChange(object sender, SqlNotificationEventArgs e)
{
dependency.OnChange -= OnDataChange;
if (e.Type == SqlNotificationType.Change)
{
myDataGrid.Dispatcher.Invoke(() =>
{
InitializeSQLDependency();
});
}
}
private void Window_Closing(object sender, System.ComponentModel.CancelEventArgs e)
{
SqlDependency.Stop(connectionString);
if (connection != null)
{
connection.Dispose();
}
}
}
“`
以上代码创建了连接、命令、依赖项以及数据读取器，并在数据变化时通过OnDataChange方法重新初始化依赖项和数据项。在关闭窗口时需要关闭依赖项和连接。
2.使用轮询方式（Polling）
轮询方式是另一种WPF中常用的数据库监听方式。它的原理是在应用程序中定期查询数据库中的数据，判断是否有变化。轮询方式的优点是简单易用，但是会浪费大量的系统资源，尤其是在查询较为频繁时。
以下是使用轮询方式的代码示例：
“`
using System.Threading.Tasks;
using System.Data.SqlClient;
using System.Data;
using System.Linq;
public partial class MnWindow : Window
{
private string connectionString = “Data Source=myServerAddress;Initial Catalog=myDataBase;Integrated Security=True”;
private SqlConnection connection;
private SqlCommand command;
private bool hasChanges = false;
public MnWindow()
{
InitializeComponent();
StartPolling();
}
private async void StartPolling()
{
while (true)
{
awt CheckDatabaseChangesAsync();
if (hasChanges)
{
myDataGrid.Dispatcher.Invoke(() =>
{
myDataGrid.ItemsSource = GetDataFromDatabase().DefaultView;
});
}
awt Task.Delay(TimeSpan.FromSeconds(5));
}
}
private async Task CheckDatabaseChangesAsync()
{
string query = “SELECT COUNT(*) FROM myTable”;
using (SqlConnection connection = new SqlConnection(connectionString))
{
awt connection.OpenAsync();
using (SqlCommand command = new SqlCommand(query, connection))
{
int count = (int)awt command.ExecuteScalarAsync();
hasChanges = count != myDataGrid.Items.Count;
}
}
}
private DataTable GetDataFromDatabase()
{
string query = “SELECT * FROM myTable”;
SqlConnection connection = new SqlConnection(connectionString);
SqlCommand command = new SqlCommand(query, connection);
SqlDataAdapter adapter = new SqlDataAdapter(command);
DataTable data = new DataTable();
adapter.Fill(data);
return data;
}
private void Window_Closing(object sender, System.ComponentModel.CancelEventArgs e)
{
if (connection != null)
{
connection.Close();
}
}
}
“`
以上代码使用了异步编程模型（Async Programming Model），定期地检查数据库的数据变化并更新UI。在检查变化时使用计数方式，如果计数和当前表格中的行数不一致，则说明数据发生了变化。在数据发生变化时重新拉取数据并更新UI。
3.使用ORM框架
ORM（Object Relational Mapping）框架可以将数据库中的数据映射到应用程序中的对象中，从而实现更加灵活和方便的数据绑定。在WPF中使用ORM框架的方式通常包括以下步骤：
– 安装相关的ORM框架（如Entity Framework等）
– 创建对象模型，并利用ORM框架创建数据库表
– 在应用程序中编写代码实现数据绑定和监听
以下是使用Entity Framework实现数据绑定的代码示例：
“`
using System.ComponentModel;
using System.Data.Entity;
public class MyContext : DbContext
{
public DbSet MyModels { get; set; }
}
public class MyModel : INotifyPropertyChanged
{
private string name;
public int Id { get; set; }
public string Name
{
get { return name; }
set
{
name = value;
OnPropertyChanged(“Name”);
}
}
public event PropertyChangedEventHandler PropertyChanged;
protected void OnPropertyChanged(string propertyName)
{
PropertyChangedEventHandler handler = PropertyChanged;
if (handler != null)
{
handler(this, new PropertyChangedEventArgs(propertyName));
}
}
}
public partial class MnWindow : Window
{
private MyContext context;
public MnWindow()
{
InitializeComponent();
context = new MyContext();
context.MyModels.Load();
myDataGrid.ItemsSource = context.MyModels.Local.ToBindingList();
}
private void Window_Closing(object sender, System.ComponentModel.CancelEventArgs e)
{
if (context != null)
{
context.Dispose();
}
}
}
“`
以上代码创建了一个数据库上下文（MyContext）和一个实体（MyModel），并使用BindingList类实现数据绑定和监听。在窗口关闭时需要关闭上下文。
