トランザクション処理

　トランザクション処理を行うにはConnectionオブジェクトとCommandオブジェクトを使います。DataAdapterやDataSetではトランザクション処理を行いません。

　トランザクション処理は次の手順で行ないます。

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

○　プロジェクト

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

プロジェクトの種類 Windows フォーム アプリケーション
プロジェクト名 TransactionTest

サンプルダウンロード

○　フォームデザイン

　次の図のようにコントロールを配置してください。DataAdapter、DataSetも配置し、DataGridViewにM_ユーザーが表示されるようにしてください。

コントロールの配置例
コントロールの配置例

○　プログラム

　次のように各イベントプロシージャを記述してください。

Form1.vb

  1. 'Transactionオブジェクト
  2. Dim trans As SqlClient.SqlTransaction
  4. 'ボタンの有効・無効をセットするメソッド
  5. Private Sub AlterButton(ByVal flg As Boolean)
  6. 　Me.Button1.Enabled = flg
  7. 　Me.Button2.Enabled = flg
  8. 　Me.Button3.Enabled = Not flg
  9. 　Me.Button4.Enabled = Not flg
  10. 　Me.Button5.Enabled = Not flg
  11. End Sub
  13. Private Sub Button1_Click(ByVal sender As System.Object, ByVal e As System.EventArgs) Handles Button1.Click
  14. 　'データセットを一度クリアにする
  15. 　Me.DataSet11.Clear()
  17. 　'データセットを同期させる
  18. 　Me.SqlDataAdapter1.Fill(Me.DataSet11)
  19. End Sub
  21. Private Sub Button2_Click(ByVal sender As System.Object, ByVal e As System.EventArgs) Handles Button2.Click
  22. 　'データベースを開く
  23. 　Me.SqlConnection1.Open()
  25. 　'トランザクションの開始
  26. 　Me.trans = Me.SqlConnection1.BeginTransaction
  28. 　'ボタンの表示設定
  29. 　Me.AlterButton(False)
  30. End Sub
  32. Private Sub Button3_Click(ByVal sender As System.Object, ByVal e As System.EventArgs) Handles Button3.Click
  33. 　'トランザクションの確定
  34. 　Me.trans.Commit()
  36. 　'データベースを閉じる
  37. 　Me.SqlConnection1.Close()
  39. 　'ボタンの表示設定
  40. 　Me.AlterButton(True)
  41. End Sub
  43. Private Sub Button4_Click(ByVal sender As System.Object, ByVal e As System.EventArgs) Handles Button4.Click
  44. 　'トランザクションの取消
  45. 　Me.trans.Rollback()
  47. 　'データベースを閉じる
  48. 　Me.SqlConnection1.Close()
  50. 　'ボタンの表示設定
  51. 　Me.AlterButton(True)
  52. End Sub
  54. Private Sub Button5_Click(ByVal sender As System.Object, ByVal e As System.EventArgs) Handles Button5.Click
  55. 　'データを追加するSQL文生成
  56. 　Dim sql As String = "INSERT INTO M_ユーザー VALUES(@id, @user, @pass, @name)"
  57. 　System.Diagnostics.Debug.WriteLine("SQLステートメント:" & sql)
  59. 　'コマンドオブジェクトの生成
  60. 　Dim cmd As SqlClient.SqlCommand = New SqlClient.SqlCommand(sql, Me.SqlConnection1)
  62. 　'トランザクションのセット
  63. 　cmd.Transaction = Me.trans
  65. 　'パラメータのセット
  66. 　cmd.Parameters.Add("@id", SqlDbType.VarChar).Value = Me.TextBox1.Text
  67. 　cmd.Parameters.Add("@user", SqlDbType.VarChar).Value = Me.TextBox2.Text
  68. 　cmd.Parameters.Add("@pass", SqlDbType.VarChar).Value = Me.TextBox3.Text
  69. 　cmd.Parameters.Add("@name", SqlDbType.VarChar).Value = Me.TextBox4.Text
  70. 　cmd.ExecuteNonQuery()
  71. End Sub

○　実行結果

実行結果
実行結果

　「開始」でデータベースに接続します。そして、追加する項目を入力して、「追加」を押します。ここでは、追加する項目をパラメータを使用して設定しています。そして、確定するか、取消すか選択します。確定であれば、Commitメソッドを実行しますし、取消であればRollBackメソッドを実行します。

前へ   次へ