トランザクション処理

　トランザクション処理を行うには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メソッドを次のように記述してください。

Module1.vb

  1. Sub Main()
  2. 　'接続文字列
  3. 　Dim constr As String = "Data Source=(LocalDB)\v11.0;AttachDbFilename=C:\Work\Books.mdf;Integrated Security=True;Connect Timeout=30"
  5. 　'SqlConnectionオブジェクトを生成
  6. 　Dim con As SqlConnection = New SqlConnection(constr)
  8. 　'追加する情報を入力
  9. 　Console.WriteLine("登録するユーザー情報を入力してください。")
  10. 　Console.Write("ID：")
  11. 　Dim id As Integer = Int32.Parse(Console.ReadLine())
  12. 　Console.Write("ユーザー名：")
  13. 　Dim username As String = Console.ReadLine()
  14. 　Console.Write("パスワード：")
  15. 　Dim password As String = Console.ReadLine()
  16. 　Console.Write("氏名：")
  17. 　Dim name As String = Console.ReadLine()
  19. 　'入力した情報をもとにSQL文を作成
  20. 　Dim sql As String = "INSERT INTO Users VALUES(" & id & ", '" & username & "', '" & password & "', N'" & name & "')"
  22. 　'SqlCommandオブジェクトを生成
  23. 　Dim cmd As New SqlCommand(sql, con)
  25. 　'実行予定のSQL文を表示
  26. 　Console.WriteLine("実行するSQL文：{0}", cmd.CommandText)
  28. 　'データベースを開く
  29. 　con.Open()
  31. 　'SqlTransactionオブジェクトを取得
  32. 　Dim trans As SqlTransaction = con.BeginTransaction()
  34. 　'SqlCommandオブジェクトにSqlTransactionオブジェクトをセット
  35. 　cmd.Transaction = trans
  37. 　'SQL文を実行する
  38. 　Dim ret As Integer = cmd.ExecuteNonQuery()
  39. 　'変更のあった行数を表示する
  40. 　Console.WriteLine("変更のあった件数：{0}", ret)
  42. 　'確定か取消しを入力
  43. 　Console.Write("1)確定 2)取消し(デフォルト)：")
  44. 　Dim input As String = Console.ReadLine()
  46. 　Select Case input
  47. 　　Case "1"
  48. 　　　'確定
  49. 　　　trans.Commit()
  50. 　　　Console.WriteLine("確定しました。")
  51. 　　Case Else
  52. 　　　'取消し
  53. 　　　trans.Rollback()
  54. 　　　Console.WriteLine("取り消しました。")
  55. 　End Select
  57. 　'データベースを閉じる
  58. 　con.Close()
  59. 　Console.ReadLine()
  60. End Sub

○　実行結果

登録するユーザー情報を入力してください。
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テーブルに追加された

○　解説

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

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

前へ   次へ