Hướng dẫn các bạn sử dụng SqlDependency để kiểm tra dữ liệu thay đổi trong sql server, Đơn giản bạn có thể hiểu, là khi dữ liệu trong sqlserver được thay đổi thì form của mình cũng tự động cập nhật theo mà không cần phải sử dụng thao tác refresh database.
Ví dụ: Bạn muốn viết chương trình quản lý nhà sách gồm có 2 tầng, nếu khi bạn thanh toán ở máy 2 ở trên tầng 2, thì xuống tầng 1 hệ thống cũng tự động cập nhật là biết đơn hàng này đã được thanh toán rồi, thông thường để giải quyết bài toán realtime này, các bạn thường sử dụng timer để tự động kiểm tra dữ liệu liên tục, xem dữ liệu có thay đổi hay không, để load dữ liệu lên hệ thống. Nhưng với các xử lý này với hệ thống 1 hay vài máy thì không sao, nhưng nếu sử dụng nhiều máy, cứ kiểm tra dữ liệu liên tục, sẽ làm rất tốn tài nguyên của sqlserver, v.v... Và để giải quyết vấn đề trên ta sử dụng giải pháp là sử dụng SqlDependency.
- Đầu tiên các bạn, cần phải sử dụng lệnh: ALTER DATABASE [TENDATABASE] SET ENABLE_BROKER
để kích hoạt dịch vụ broker trong sql server.
- Trong ví dụ trên mình sử dụng câu truy vấn: SELECT masv, tensv, khoa from dbo.tbl_sinhvien
Lưu ý:
1. Khi các bạn sử dụng SqlDependency thì khi truy vấn, các bạn không được select * mà phải select từng field mà các bạn muốn hiển thị.
2. Tên database phải thêm dbo.tenbang.
- Dưới đây là code của chương trình :
using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Linq;
using System.Text;
using System.Windows.Forms;
using System.Data.SqlClient;
namespace
DemoSQL
{
public
partial
class
Form1 : Form
{
public
string m_connect = @
"Data Source=.;Initial Catalog=STUDENT;Integrated Security=True"
;
SqlConnection con =
null
;
public
delegate
void
NewHome();
public
event NewHome OnNewHome;
public
Form1()
{
InitializeComponent();
try
{
SqlClientPermission ss =
new
SqlClientPermission(System.Security.Permissions.PermissionState.Unrestricted);
ss.Demand();
}
catch
(Exception)
{
throw
;
}
SqlDependency.Stop(m_connect);
SqlDependency.Start(m_connect);
con =
new
SqlConnection(m_connect);
}
private
void
Form1_Load(object sender, EventArgs e)
{
OnNewHome+=
new
NewHome(Form1_OnNewHome);
LoadData();
}
public
void
Form1_OnNewHome()
{
ISynchronizeInvoke i = (ISynchronizeInvoke)
this
;
if
(i.InvokeRequired)
{
NewHome dd =
new
NewHome(Form1_OnNewHome);
i.BeginInvoke(dd,
null
);
return
;
}
LoadData();
}
void
LoadData()
{
DataTable dt =
new
DataTable();
if
(con.State==ConnectionState.Closed)
{
con.Open();
}
SqlCommand cmd =
new
SqlCommand(
"SELECT masv, tensv, khoa from dbo.tbl_sinhvien"
, con);
cmd.Notification =
null
;
SqlDependency de =
new
SqlDependency(cmd);
de.OnChange +=
new
OnChangeEventHandler(de_OnChange);
dt.Load(cmd.ExecuteReader(CommandBehavior.CloseConnection));
dataGridView1.DataSource = dt;
}
public
void
de_OnChange(object sender, SqlNotificationEventArgs e)
{
SqlDependency de = sender
as
SqlDependency;
de.OnChange -= de_OnChange;
if
(OnNewHome!=
null
)
{
OnNewHome();
}
}
}
}