データベースの変更が通知できるのね

記録

おかわりありませんか？　−SqlDependency

今回の作品では、５秒ごとに更新されるデータベースの値に追随する必要がある。
じゃあちょいちょいコマンドを飛ばそうかと思っていたのだが、
有益な情報を得たのでメモメモ。

わんくまBBS


なんでも、SQLServer上で値が更新された事を、
クライアントに通知してくれる機能があるらしい。
（実際には、１プロセスを占有してクライアントが監視し続けるんだそうな）

さっそく試してみよう

msdnのチュートリアルを見つけ、さっそく書いてみることに。

かりかり。


動作させてみた

どれどれ。実行！

無題
NotSupportedException はハンドルされませんでした。
通知機能を使用するにはSQL Server 9.0以降が必要です。
がくり。

そうか・・・開発環境はSQL Server 2000だった。
本番環境は最新だったはずだけど、テストできないと辛いな・・・


使ったソースコード

msdnから拾ったコードを乗せとく。いつかまた見たくなるかも知れないので。
  1. using System;
  2. using System.Collections.Generic;
  3. using System.ComponentModel;
  4. using System.Data;
  5. using System.Drawing;
  6. using System.Linq;
  7. using System.Text;
  8. using System.Windows.Forms;
  9. using System.Data.SqlClient;
  10. using System.Security.Permissions;
  12. namespace SqlNotifyingTest
  13. {
  14. public partial class Form1 : Form
  15. {
  16. public Form1()
  17. {
  18. InitializeComponent();
  19. }
  21. // Following are the declarations used in this program.
  22. private string statusMessage;
  23. private DataSet myDataSet = null;
  24. private SqlConnection connection = null;
  25. private SqlCommand command = null;
  26. private string connstr;
  28. private void button1_Click(object sender, EventArgs e)
  29. {
  31. // Remove any existing dependency connection, then create a new one.
  32. connstr = "Data Source=MANHATTAN;Initial Catalog=SolarMonitorMobile;Persist Security Info=True;User ID=sa;Password=81at84;";
  33. string ssql = "select * from THATSUDEN_KIROKU ";
  35. SqlDependency.Stop(connstr);
  36. SqlDependency.Start(connstr);
  37. if (connection == null)
  38. connection = new SqlConnection(connstr);
  39. if (command == null)
  40. command = new SqlCommand(ssql, connection);
  41. if (myDataSet == null)
  42. myDataSet = new DataSet();
  43. GetAdvtData();
  44. }
  46. private void GetAdvtData()
  47. {
  48. myDataSet.Clear();
  49. // Ensure the command object does not have a notification object.
  50. command.Notification = null;
  51. // Create and bind the SqlDependency object to the command object.
  52. SqlDependency dependency = new SqlDependency(command);
  53. dependency.OnChange += new OnChangeEventHandler(dependency_OnChange);
  55. using (SqlDataAdapter adapter = new SqlDataAdapter(command))
  56. {
  57. adapter.Fill(myDataSet, "THATSUDEN_KIROKU");
  58. dataGridView1.DataSource = myDataSet;
  59. dataGridView1.DataMember = "THATSUDEN_KIROKU";
  60. }
  61. }
  63. private bool EnoughPermission()
  64. {
  65. SqlClientPermission perm = new SqlClientPermission(PermissionState.Unrestricted);
  66. try
  67. {
  68. perm.Demand();
  69. return true;
  70. }
  71. catch (System.Exception)
  72. {
  73. return false;
  74. }
  75. }
  77. private void Form1_Load(object sender, EventArgs e)
  78. {
  79. // TODO: このコード行はデータを 'solarMonitorMobileDataSet.THATSUDEN_KIROKU' テーブルに読み込みます。必要に応じて移動、または削除をしてください。
  80. this.tHATSUDEN_KIROKUTableAdapter.Fill(this.solarMonitorMobileDataSet.THATSUDEN_KIROKU);
  82. }
  85. delegate void UIDelegate();
  86. private void dependency_OnChange(object sender, SqlNotificationEventArgs e)
  87. {
  88. UIDelegate uidel = new UIDelegate(RefreshData);
  89. this.Invoke(uidel, null);
  91. //Remove the handler as it is used for a single notification.
  92. SqlDependency dependency = (SqlDependency)sender;
  93. dependency.OnChange -= dependency_OnChange;
  94. }
  95. private void RefreshData()
  96. {
  97. // Since the code is executing on the UI thread,it is safe to update the UI.
  99. label1.Text = "Database had some changes and are applied in the Grid";
  101. // Reload the dataset that is bound to the grid.
  102. GetAdvtData();
  103. }
  105. private void Form1_FormClosing(object sender, FormClosingEventArgs e)
  106. {
  107. SqlDependency.Stop(connstr);
  108. if (connection != null)
  109. connection.Close();
  110. }
  111. }
  112. }

Author: Balamurali Balaji MVP