DataTableのデータベース保存

　DataTableクラスを利用すると、メモリ上にテーブルを作成して扱うことができます。そのテーブルに対して選択したり、更新したりすることができます。ここでは、更新したテーブル(DataTableオブジェクト)の内容をデータベースに反映させる方法を見てみましょう。

　DataTableオブジェクトとデータベースの橋渡しをするDataAdapterクラスには、Updateメソッドがあります。このメソッドの引数にDataSetオブジェクトやDataTableオブジェクトを指定します。このメソッドは変更内容に応じてDataAdapterオブジェクトにセットされているInsertCommandやUpdateCommandやDeleteCommandを呼び出します。そのため更新するためにそれぞれのCommandオブジェクトを設定しておく必要があります。

　CommandBuilderクラスを使うと、変更に応じたCommandオブジェクトを自動的に生成してくれます。このクラスと、DataAdapterクラスを組み合わせて使います。DataAdapterオブジェクトをCommandBuilderオブジェクトの管理下に置き、変更内容を自動的に検知し、更新するための準備を整えてくれます。

CommandBuilderクラスとDataAdapterクラスの関係
CommandBuilderクラスとDataAdapterクラスの関係

■　データソースごとのクラス

接続の種類 クラス名
System.Data.SqlClient SqlCommandBuilderクラス
System.Data.OracleClient OracleCommandBuilderクラス
System.Data.OleDb OleDbCommandBuilderクラス
System.Data.Odbc OdbcCommandBuilderクラス
CommandBuilderオブジェクトの種類

■　主なプロパティ

プロパティ名 概要
DataAdapter SQL文を自動生成する対象のDataAdapterオブジェクトを取得・設定する
SqlCommandBuilderの主なプロパティ

■　主なメソッド

メソッド名 概要
GetDeleteCommand() データベースで削除処理をするための自動生成されたSqlCommandオブジェクトを取得する
GetInsertCommand() データベースで挿入処理をするための自動生成されたSqlCommandオブジェクトを取得する
GetUpdateCommand() データベースで更新処理をするための自動生成されたSqlCommandオブジェクトを取得する
SqlCommandBuilderの主なメソッド

○　プロジェクト

　プロジェクトを作成して確認してみましょう。

プロジェクトの種類 コンソール アプリケーション
プロジェクト名 CommandBuilderTest

サンプルダウンロード

○　プログラム

　Mainメソッドを次のように記述してください。

Program.cs

  1. using System;
  2. using System.Collections.Generic;
  3. using System.Linq;
  4. using System.Text;
  5. using System.Threading.Tasks;
  6. using System.Data.SqlClient;
  7. using System.Data;
  9. namespace CommandBuilderTest
  10. {
  11. 　class Program
  12. 　{
  13. 　　static void Main(string[] args)
  14. 　　{
  15. 　　　//接続文字列
  16. 　　　string constr = @"Data Source=(LocalDB)¥v11.0;AttachDbFilename=C:¥Work¥Books.mdf;Integrated Security=True;Connect Timeout=30";
  18. 　　　//SqlConnectionオブジェクトを生成
  19. 　　　SqlConnection con = new SqlConnection(constr);
  21. 　　　//Usersテーブルのデータを取得するSQL文を作成
  22. 　　　string sql = "SELECT * FROM Users;";
  24. 　　　//SqlDataAdapterオブジェクトを生成
  25. 　　　SqlDataAdapter da = new SqlDataAdapter(sql, con);
  27. 　　　//SqlCommandBuilderオブジェクトを生成
  28. 　　　SqlCommandBuilder cmdbuilder = new SqlCommandBuilder(da);
  30. 　　　//DataTableオブジェクトを生成
  31. 　　　DataTable dt = new DataTable();
  33. 　　　//DataTableとデータベースに同期させる
  34. 　　　da.Fill(dt);
  36. 　　　//データの一覧を表示する
  37. 　　　Console.WriteLine("次の一覧から変更するユーザーのIDを選択してください。");
  38. 　　　foreach (DataRow dr in dt.Rows)
  39. 　　　{
  40. 　　　　Console.WriteLine("ID:{0}　{1}", dr["Id"], dr["Name"]);
  41. 　　　}
  42. 　　　Console.WriteLine();
  44. 　　　//IDを入力
  45. 　　　Console.Write("ID：");
  46. 　　　int id = Int32.Parse(Console.ReadLine());
  48. 　　　//新しいパスワードを入力
  49. 　　　Console.Write("新しいパスワード：");
  50. 　　　string password = Console.ReadLine();
  52. 　　　//DataTableオブジェクトから入力したIDの行を取得
  53. 　　　DataRow[] updaterow = dt.Select("Id=" + id);
  55. 　　　//データを更新
  56. 　　　updaterow[0]["Password"] = password;
  58. 　　　//データベースに反映
  59. 　　　da.Update(dt);
  61. 　　　Console.WriteLine("変更しました。");
  62. 　　　Console.ReadLine();
  63. 　　}
  64. 　}
  65. }

○　実行結果

次の一覧から変更するユーザーのIDを選択してください。
ID:1　佐藤
ID:2　鈴木
ID:3　高橋
ID:4　田中
ID:5　伊藤
ID:6　山本

ID：1
新しいパスワード：csharp
変更しました。

パスワードが変更されている
パスワードが変更されている

○　解説

　28行目でCommandBuilderオブジェクトを生成しています。コンストラクターの引数にDataAdapterオブジェクトを指定しています。これによりDataAdapterを通して変更する内容に応じてSQL文が自動生成されるようになります。

　53行目ではDataTableオブジェクトのSelectメソッドを使って指定したIDのDataRowオブジェクトの配列を取り出しています。今回は検索結果が1件しかないので、56行目にあるようにDataRowオブジェクト配列の最初の要素のデータを変更しています。これによりDataTableオブジェクト内のデータを変更することができます。

　59行目でDataAdapterオブジェクトのUpdateメソッドを呼び出しています。引数に変更済みのDataTableオブジェクトを渡すことで、データベースに変更内容が反映されます。その際に、CommandBuilderオブジェクトが必要に応じたSQL文を生成して実行させる働きをします。

前へ   次へ