トランザクション処理

　トランザクション処理を行うにはConnectionクラスとCommandクラスを使います。トランザクション処理は次の手順で行います。

  1. Connectionオブジェクトを生成する
  2. データベースに接続する
  3. ConnectionオブジェクトのBeginTransactionメソッドでTransactionオブジェクトを取得する
  4. Commandオブジェクトを生成する
  5. CommandオブジェクトのTransactionプロパティに取得したTransactionオブジェクトを設定する
  6. SQLコマンドを実行する
  7. 確定(Commit)するか、取り消し(Rollback)をする
  8. データベースを切断する

○　プロジェクト

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

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

サンプルダウンロード

○　作成の準備

　「CommandTest」プロジェクトを修正して作成しましょう。CommandTestフォルダーをコピーして、作成するプロジェクト名にフォルダー名を変更してください。

○　プログラム

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

Program.cs

  1. static void Main(string[] args)
  2. {
  3. 　//接続文字列
  4. 　string constr = @"Data Source=(LocalDB)¥v11.0;AttachDbFilename=C:¥Work¥Books.mdf;Integrated Security=True;Connect Timeout=30";
  6. 　//SqlConnectionオブジェクトを生成
  7. 　SqlConnection con = new SqlConnection(constr);
  9. 　//追加する情報を入力
  10. 　Console.WriteLine("登録するユーザー情報を入力してください。");
  11. 　Console.Write("ID：");
  12. 　int id = Int32.Parse(Console.ReadLine());
  13. 　Console.Write("ユーザー名：");
  14. 　string username = Console.ReadLine();
  15. 　Console.Write("パスワード：");
  16. 　string password = Console.ReadLine();
  17. 　Console.Write("氏名：");
  18. 　string name = Console.ReadLine();
  20. 　//入力した情報をもとにSQL文を作成
  21. 　string sql = "INSERT INTO Users VALUES(" + id + ", '" + username + "', '" + password + "', N'" + name + "')";
  23. 　//SqlCommandオブジェクトを生成
  24. 　SqlCommand cmd = new SqlCommand(sql, con);
  26. 　//実行予定のSQL文を表示
  27. 　Console.WriteLine("実行するSQL文：{0}", cmd.CommandText);
  29. 　//データベースを開く
  30. 　con.Open();
  32. 　//SqlTransactionオブジェクトを取得
  33. 　SqlTransaction trans = con.BeginTransaction();
  35. 　//SqlCommandオブジェクトにSqlTransactionオブジェクトをセット
  36. 　cmd.Transaction = trans;
  38. 　//SQL文を実行する
  39. 　int ret = cmd.ExecuteNonQuery();
  41. 　//変更のあった行数を表示する
  42. 　Console.WriteLine("変更のあった件数：{0}", ret);
  44. 　//確定か取消しを入力
  45. 　Console.Write("1)確定 2)取消し(デフォルト)：");
  46. 　string input = Console.ReadLine();
  48. 　switch (input)
  49. 　{
  50. 　　case "1":
  51. 　　　//確定
  52. 　　　trans.Commit();
  53. 　　　Console.WriteLine("確定しました。");
  54. 　　　break;
  55. 　　default:
  56. 　　　//取消し
  57. 　　　trans.Rollback();
  58. 　　　Console.WriteLine("取り消しました。");
  59. 　　　break;
  60. 　}
  62. 　//データベースを閉じる
  63. 　con.Close();
  64. 　Console.ReadLine();
  65. }

○　実行結果

登録するユーザー情報を入力してください。
ID：5
ユーザー名：itou
パスワード：ipass
氏名：伊藤
実行するSQL文：INSERT INTO Users VALUES(5, 'itou', 'ipass', N'伊藤')
変更のあった件数：1
1)確定 2)取消し(デフォルト)：2
取り消しました。

Usersテーブルに追加されていない
Usersテーブルに追加されていない

登録するユーザー情報を入力してください。
ID：5
ユーザー名：itou
パスワード：ipass
氏名：伊藤
実行するSQL文：INSERT INTO Users VALUES(5, 'itou', 'ipass', N'伊藤')
変更のあった件数：1
1)確定 2)取消し(デフォルト)：1
確定しました。

Usersテーブルに追加された
Usersテーブルに追加された

○　解説

　44行目でTransactionオブジェクトを取得しています。ConnectionオブジェクトのOpenメソッドを呼び出した後に取得します。その後、47行目にあるように、CommandオブジェクトのTransactionプロパティに取得したTransactionオブジェクトをセットします。これにより、コマンドを実行するとトランザクションモードで実行され、すぐには確定されなくなります。

　59行目から、確定するか、取り消すかの処理が行われます。もし確定する場合は63行目にあるように、TransactionオブジェクトのCommitメソッドを呼び出して確定します。これによりデータベース上の変更が確定され、データベースに反映されます。取り消す場合は68行目にあるようにTransactionオブジェクトのRollbackメソッドを呼び出して取り消します。これによりデータベース上の変更が破棄され、SQL文実行前の状態に戻ります。確定か、取り消しかを指定した後、74行目にあるようにデータベースを閉じます。

前へ   次へ