チュートリアル : 同時実行例外の処理

  • [アーティクル]

更新 : 2007 年 11 月

2 人のユーザーが同じデータベースの同じデータを同時に変更しようとすると、同時実行例外 (DBConcurrencyException) が発生します。このチュートリアルでは、DBConcurrencyException をキャッチし、エラーが発生した行を特定し、それに対処する方法の 1 つを示す、Windows アプリケーションを作成します。

ここでは次の手順を実行します。

  1. 新しい Windows アプリケーション プロジェクトを作成します。

  2. Northwind Customers テーブルに基づいて、新しいデータセットを作成します。

  3. データを表示する DataGridView を備えたフォームを作成します。

  4. Northwind データベースの Customers テーブルからデータセットにデータを読み込みます。

  5. データセットにデータを読み込んだ後で、Visual Studio の Visual Database Tools を使用して Customers データ テーブルに直接アクセスし、レコードを変更します。

  6. 次にフォームで、同じレコードを別の値に変更し、データセットを更新し、変更内容をデータベースに書き込もうとします。これにより、同時実行エラーが発生します。

  7. エラーをキャッチし、操作を継続してデータベースを更新するか、または更新をキャンセルするかを判断できるように、レコードの異なるバージョンを表示します。

前提条件

このチュートリアルを実行するための要件は次のとおりです。

ms171936.alert_note(ja-jp,VS.90).gifメモ :

使用している設定またはエディションによっては、表示されるダイアログ ボックスやメニュー コマンドがヘルプに記載されている内容と異なる場合があります。設定を変更するには、[ツール] メニューの [設定のインポートとエクスポート] をクリックします。詳細については、「Visual Studio の設定」を参照してください。

新規プロジェクトの作成

新しい Windows アプリケーションの作成からチュートリアルを開始します。

新しい Windows アプリケーション プロジェクトを作成するには

  1. [ファイル] メニューで新しいプロジェクトを作成します。

  2. [プロジェクトの種類] ペインでプログラミング言語を選択します。

  3. [テンプレート] ペインの [Windows アプリケーション] をクリックします。

  4. プロジェクトに ConcurrencyWalkthrough という名前を付け、[OK] をクリックします。

    Visual Studio によってソリューション エクスプローラにプロジェクトが追加され、デザイナに新しいフォームが表示されます。

Northwind データセットの作成

ここでは、NorthwindDataSet という名前のデータセットを作成します。

NorthwindDataSet を作成するには

  1. [データ] メニューの [新しいデータ ソースの追加] をクリックします。

    データ ソース構成ウィザード が表示されます。

  2. [データソースの種類を選択] ページで、[データベース] をクリックします。

  3. 利用可能な接続の一覧から Northwind サンプル データベースへの接続を選択するか、または接続の一覧に使用できる接続がない場合は [新しい接続] をクリックします。

    ms171936.alert_note(ja-jp,VS.90).gifメモ :

    ローカル データベース ファイルに接続する場合は、プロジェクトにファイルを追加するかどうかをたずねるメッセージが表示されたときに [いいえ] をクリックします。

  4. [アプリケーション構成ファイルに接続文字列を保存] ページで、[次へ] をクリックします。

  5. [テーブル] ノードを展開し、Customers テーブルを選択します。既定のデータセット名は、NorthwindDataSet です。

  6. [完了] をクリックして、プロジェクトにデータセットを追加します。

データ バインド DataGridView コントロールの作成

ここでは、[データ ソース] ウィンドウから Windows フォームに Customers 項目をドラッグして、DataGridView を作成します。

Customers テーブルにバインドする DataGridView コントロールを作成するには

  1. [データ] メニューの [データ ソースの表示] をクリックして [データ ソース] ウィンドウを開きます。

  2. [データ ソース] ウィンドウの [NorthwindDataSet] ノードを展開し、Customers テーブルを選択します。

  3. テーブル ノードの下向きの矢印をクリックし、ドロップダウン リストの [DataGridView] を選択します。

  4. テーブルをフォームの空の領域にドラッグします。

    CustomersDataGridView という名前の DataGridView コントロールと CustomersBindingNavigator という名前の BindingNavigator が、フォームに追加されます。このフォームは、BindingSource にバインドされ、さらに BindingSource は NorthwindDataSet 内の Customers テーブルにバインドされます。

チェックポイント

フォームをテストして、ここまでの設定が期待どおりに動作することを確認します。

フォームをテストするには

  1. F5 キーを押してアプリケーションを実行します。

    フォームは、Customers テーブルのデータが読み込まれた状態で DataGridView コントロールに表示されます。

  2. [デバッグ] メニューの [デバッグの停止] をクリックします。

同時実行エラーの処理

エラーを処理する方法は、アプリケーションを管理するそれぞれのビジネス ルールによって異なります。ここでは、同時実行違反が起きた後で、次の同時実行エラーの対処方法を例として実行します。

アプリケーションは、ユーザーに対してレコードのバージョンを 3 つ用意します。

  • データベース内の現在のレコード。

  • データセットに読み込まれた元のレコード。

  • データセット内の提案された変更。

ユーザーは、提案されたバージョンでデータベースを上書きするか、更新をキャンセルし、データベースから新しい値をデータセットに再読み込みできます。

同時実行エラーを処理できるようにするには

  1. カスタム エラー ハンドラの作成

  2. ユーザーに対する選択肢の表示

  3. ユーザーの応答の処理

  4. 更新の再送、またはデータセット内のデータのリセット

同時実行例外を処理するコードの追加

更新の実行を試みると例外が発生する場合、通常は、発生した例外によって提供される情報に対して何らかの対処を行います。

ここでは、データベースを更新しようとし、生成される可能性がある DBConcurrencyException およびその他の例外を処理するコードを追加します。

ms171936.alert_note(ja-jp,VS.90).gifメモ :

このチュートリアルの後半で、CreateMessage メソッドと ProcessDialogResults メソッドを追加します。

同時実行エラー用のエラー処理を追加するには

  1. Form1_Load メソッドの下に次のコードを追加します。

    Private Sub UpdateDatabase()

    Try
        Me.CustomersTableAdapter.Update(Me.NorthwindDataSet.Customers)
        MsgBox("Update successful")

    Catch dbcx As Data.DBConcurrencyException
        Dim response As Windows.Forms.DialogResult

        response = MessageBox.Show(CreateMessage(CType(dbcx.Row, NorthwindDataSet.CustomersRow)), _
            "Concurrency Exception", MessageBoxButtons.YesNo)

        ProcessDialogResult(response)

    Catch ex As Exception
        MsgBox("An error was thrown while attempting to update the database.")
    End Try
End Sub

    private void UpdateDatabase()
{
    try
    {
        this.customersTableAdapter.Update(this.northwindDataSet.Customers);
        MessageBox.Show("Update successful");
    }
    catch (DBConcurrencyException dbcx)
    {
        DialogResult response = MessageBox.Show(CreateMessage((NorthwindDataSet.CustomersRow)
            (dbcx.Row)), "Concurrency Exception", MessageBoxButtons.YesNo);

        ProcessDialogResult(response);
    }
    catch (Exception ex)
    {
        MessageBox.Show("An error was thrown while attempting to update the database.");
    }
}

  2. 次のように CustomersBindingNavigatorSaveItem_Click メソッドを UpdateDatabase メソッドの呼び出しに置き換えます。

    Private Sub CustomersBindingNavigatorSaveItem_Click(ByVal sender As System.Object, ByVal e As System.EventArgs) Handles CustomersBindingNavigatorSaveItem.Click
    UpdateDatabase()
End Sub

    private void customersBindingNavigatorSaveItem_Click(object sender, EventArgs e)
{
    UpdateDatabase();
}

ユーザーに対する選択肢の表示

上のコードにより CreateMessage プロシージャが呼び出され、ユーザーにエラー情報が表示されます。このチュートリアルでは、メッセージ ボックスを使って、異なるバージョンのレコードをユーザーに表示します。ユーザーは、変更内容でレコードを上書きするか、編集をキャンセルするかを選択できます。ユーザーがメッセージ ボックスのオプションを選択する (ボタンをクリックする) と、ProcessDialogResult メソッドに応答が渡されます。

ユーザーに表示するメッセージを作成するには

  • コード エディタに次のコードを追加して、メッセージを作成します。このコードは、UpdateDatabase メソッドの下に入力します。

    Private Function CreateMessage(ByVal cr As NorthwindDataSet.CustomersRow) As String
    Return _
        "Database: " & GetRowData(GetCurrentRowInDB(cr), Data.DataRowVersion.Default) & vbCrLf & _
        "Original: " & GetRowData(cr, Data.DataRowVersion.Original) & vbCrLf & _
        "Proposed: " & GetRowData(cr, Data.DataRowVersion.Current) & vbCrLf & _
        "Do you still want to update the database with the proposed value?"
End Function


'--------------------------------------------------------------------------
' This method loads a temporary table with current records from the database
' and returns the current values from the row that caused the exception.
'--------------------------------------------------------------------------
Private TempCustomersDataTable As New NorthwindDataSet.CustomersDataTable

Private Function GetCurrentRowInDB(ByVal RowWithError As NorthwindDataSet.CustomersRow) _
    As NorthwindDataSet.CustomersRow

    Me.CustomersTableAdapter.Fill(TempCustomersDataTable)

    Dim currentRowInDb As NorthwindDataSet.CustomersRow = _
        TempCustomersDataTable.FindByCustomerID(RowWithError.CustomerID)

    Return currentRowInDb
End Function


'--------------------------------------------------------------------------
' This method takes a CustomersRow and RowVersion 
' and returns a string of column values to display to the user.
'--------------------------------------------------------------------------
Private Function GetRowData(ByVal custRow As NorthwindDataSet.CustomersRow, _
    ByVal RowVersion As Data.DataRowVersion) As String

    Dim rowData As String = ""

    For i As Integer = 0 To custRow.ItemArray.Length - 1
        rowData += custRow.Item(i, RowVersion).ToString() & " "
    Next

    Return rowData
End Function

    private string CreateMessage(NorthwindDataSet.CustomersRow cr)
{
    return
        "Database: " + GetRowData(GetCurrentRowInDB(cr), DataRowVersion.Default) + "\n" +
        "Original: " + GetRowData(cr, DataRowVersion.Original) + "\n" +
        "Proposed: " + GetRowData(cr, DataRowVersion.Current) + "\n" +
        "Do you still want to update the database with the proposed value?";
}


//--------------------------------------------------------------------------
// This method loads a temporary table with current records from the database
// and returns the current values from the row that caused the exception.
//--------------------------------------------------------------------------
private NorthwindDataSet.CustomersDataTable tempCustomersDataTable = 
    new NorthwindDataSet.CustomersDataTable();

private NorthwindDataSet.CustomersRow GetCurrentRowInDB(NorthwindDataSet.CustomersRow RowWithError)
{
    this.customersTableAdapter.Fill(tempCustomersDataTable);

    NorthwindDataSet.CustomersRow currentRowInDb = 
        tempCustomersDataTable.FindByCustomerID(RowWithError.CustomerID);

    return currentRowInDb;
}


//--------------------------------------------------------------------------
// This method takes a CustomersRow and RowVersion 
// and returns a string of column values to display to the user.
//--------------------------------------------------------------------------
private string GetRowData(NorthwindDataSet.CustomersRow custRow, DataRowVersion RowVersion)
{
    string rowData = "";

    for (int i = 0; i < custRow.ItemArray.Length ; i++ )
    {
        rowData = rowData + custRow.Item(i, RowVersion).ToString() + " ";
    }
    return rowData;
}

ユーザーの応答の処理

メッセージ ボックスへのユーザーの応答を処理するコードも必要です。オプションは、データベースの現在のレコードを提案された変更内容で上書きするか、またはローカルの変更内容を破棄し、データベースの現在のレコードでデータ テーブルを更新するかのいずれかです。ユーザーが yes を選択した場合、preserveChanges 引数が true に設定された Merge メソッドが呼び出されます。この結果、レコードの元のバージョンがデータベースのレコードと一致するようになり、更新の試みは成功します。

メッセージ ボックスからのユーザーの入力を処理するには

  • 前の手順で追加したコードの下に次のコードを追加します。

    ' This method takes the DialogResult selected by the user and updates the database 
' with the new values or cancels the update and resets the Customers table 
' (in the dataset) with the values currently in the database.

Private Sub ProcessDialogResult(ByVal response As Windows.Forms.DialogResult)

    Select Case response

        Case Windows.Forms.DialogResult.Yes
            NorthwindDataSet.Customers.Merge(TempCustomersDataTable, True)
            UpdateDatabase()

        Case Windows.Forms.DialogResult.No
            NorthwindDataSet.Customers.Merge(TempCustomersDataTable)
            MsgBox("Update cancelled")
    End Select
End Sub

    // This method takes the DialogResult selected by the user and updates the database 
// with the new values or cancels the update and resets the Customers table 
// (in the dataset) with the values currently in the database.

private void ProcessDialogResult(DialogResult response)
{
    switch (response)
    {
        case DialogResult.Yes:
            UpdateDatabase();
            break;

        case DialogResult.No:
            northwindDataSet.Merge(tempCustomersDataTable);
            MessageBox.Show("Update cancelled");
            break;
    }
}

テスト

フォームをテストして、期待どおりに動作することを確認します。同時実行違反をシミュレートするには、NorthwindDataSet にデータを読み込んだ後で、データベースのデータを変更する必要があります。

フォームをテストするには

  1. F5 キーを押してアプリケーションを実行します。

  2. フォームが表示されたら、実行を継続したまま Visual Studio IDE に切り替えます。

  3. [表示] メニューの [サーバー エクスプローラ] をクリックします。

  4. サーバー エクスプローラで、アプリケーションで使用する接続を展開し、[テーブル] ノードを展開します。

  5. Customers テーブルを右クリックし、[テーブル データの表示] をクリックします。

  6. 最初のレコード (ALFKI) で、ContactName を Maria Anders2 に変更します。

    ms171936.alert_note(ja-jp,VS.90).gifメモ :

    別の行に移動し、変更をコミットします。

  7. ConcurrencyWalkthrough の実行中のフォームに切り替えます。

  8. フォームの最初のレコード (ALFKI) で、ContactName を Maria Anders1 に変更します。

  9. [データの保存] をクリックします。

    同時実行エラーが発生し、メッセージ ボックスが表示されます。

  10. [No] をクリックして更新をキャンセルし、データベースの現在の値でデータセットを更新するか、または [Yes] をクリックし、提案された値をデータベースに書き込みます。

参照

概念

データの新機能

データの表示の概要

その他の技術情報

データに関するチュートリアル

Visual Studio でのデータへの接続

アプリケーションでデータを受け取る準備

アプリケーションへのデータのフェッチ

Windows アプリケーションのフォームでのデータの表示

アプリケーションでのデータ編集

データの検証

データの保存