연습: 동시성 예외 처리

아티클
08/09/2011

두 명의 사용자가 동시에 데이터베이스에 있는 동일한 데이터를 변경하려고 하면 동시성 예외(DBConcurrencyException)가 발생합니다. 이 연습에서는 DBConcurrencyException을 catch하고 오류가 발생한 행을 찾아서 이를 처리하는 한 가지 전략을 보여 주는 Windows 응용 프로그램을 만듭니다.

이 연습에서는 다음 과정을 안내합니다.

Windows 응용 프로그램 프로젝트를 새로 만듭니다.
Northwind Customers 테이블을 기반으로 새 데이터 집합을 만듭니다.
데이터를 표시할 수 있도록 DataGridView가 있는 폼을 만듭니다.
Northwind 데이터베이스의 Customers 테이블에 있는 데이터를 사용하여 데이터 집합을 채웁니다.
데이터 집합을 채운 후 Visual Studio에서 Visual Database Tools를 사용하여 Customers 데이터 테이블에 직접 액세스하고 레코드를 변경합니다.
그런 다음 폼에서 동일한 레코드를 다른 값으로 변경하고 데이터 집합을 업데이트한 다음 변경된 내용을 데이터베이스에 쓰려고 시도합니다. 이렇게 하면 동시성 오류가 발생합니다.
오류를 catch한 다음, 계속하여 데이터베이스를 업데이트할 것인지 아니면 업데이트를 취소할 것인지 결정할 수 있도록 서로 다른 레코드 버전을 표시합니다.

사전 요구 사항

이 연습을 완료하려면 다음과 같은 요건이 필요합니다.

업데이트를 수행할 수 있는 권한으로 Northwind 샘플 데이터베이스에 액세스합니다. 자세한 내용은 방법: 샘플 데이터베이스 설치를 참조하십시오.

참고

표시되는 대화 상자와 메뉴 명령은 활성 설정이나 버전에 따라 도움말에서 설명하는 것과 다를 수 있습니다. 설정을 변경하려면 도구 메뉴에서 설정 가져오기 및 내보내기를 선택합니다. 자세한 내용은 설정에 대한 작업을 참조하십시오.

새 프로젝트 만들기

연습을 시작하려면 먼저 새 Windows 응용 프로그램을 만듭니다.

새로운 Windows 응용 프로그램 프로젝트를 만들려면

파일 메뉴에서 새 프로젝트를 만듭니다.
프로젝트 형식 창에서 프로그래밍 언어를 선택합니다.
템플릿 창에서 Windows 응용 프로그램을 선택합니다.
프로젝트의 이름을 ConcurrencyWalkthrough로 지정한 다음 확인을 클릭합니다.

프로젝트가 솔루션 탐색기에 추가되고 새 폼이 디자이너에 표시됩니다.

Northwind 데이터 집합 만들기

이 단원에서는 NorthwindDataSet이라는 데이터 집합을 만듭니다.

NorthwindDataSet을 만들려면

데이터 메뉴에서 새 데이터 소스 추가를 선택합니다.

데이터 소스 구성 마법사가 열립니다.
데이터 소스 형식 선택 페이지에서 데이터베이스를 선택합니다.
사용할 수 있는 연결 목록에서 Northwind 샘플 데이터베이스에 대한 연결을 선택하거나, 연결 목록에 해당 연결이 없을 경우 새 연결을 클릭합니다.

참고

로컬 데이터베이스 파일에 연결할 경우 프로젝트에 파일을 추가할 것인지를 묻는 메시지가 표시되면 아니요를 선택합니다.
응용 프로그램 구성 파일에 연결 문자열 저장 페이지에서 다음을 클릭합니다.
테이블 노드를 확장하고 Customers 테이블을 선택합니다. 데이터 집합의 기본 이름은 NorthwindDataSet입니다.
마침을 클릭하여 프로젝트에 데이터 집합을 추가합니다.

데이터 바인딩된 DataGridView 컨트롤 만들기

이 단원에서는 데이터 소스 창에서 Windows Form으로 Customers 항목 개체를 끌어 DataGridView를 만듭니다.

Customers 테이블에 바인딩된 DataGridView를 만들려면

데이터 메뉴에서 데이터 소스 표시를 선택하여 데이터 소스 창을 엽니다.
데이터 소스 창에서 NorthwindDataSet 노드를 확장하고 Customers 테이블을 선택합니다.
테이블 노드에서 아래쪽 화살표를 클릭하고 드롭다운 목록에서 DataGridView를 선택합니다.
테이블을 폼의 빈 영역으로 끌어 옵니다.

CustomersDataGridView라는 DataGridView 컨트롤과 CustomersBindingNavigator라는 BindingNavigator가 BindingSource에 바인딩되고, 이는 다시 NorthwindDataSet의 Customers 테이블에 바인딩됩니다.

검사점

이제 폼을 테스트하여 이 지점까지 예상한 대로 동작하는지 확인할 수 있습니다.

폼을 테스트하려면

F5 키를 눌러 응용 프로그램을 실행합니다.

Customers 테이블의 데이터로 채워진 DataGridView 컨트롤이 있는 폼이 표시됩니다.
디버그 메뉴에서 디버깅 중지를 선택합니다.

동시성 오류 처리

오류를 처리하는 방법은 응용 프로그램의 기본이 되는 특정 비즈니스 규칙에 따라 달라집니다. 이 연습의 경우 동시성 오류가 발생한 후 다음과 같은 동시성 오류 처리 방법을 보여 줍니다.

이 응용 프로그램은 사용자에게 세 가지 버전의 레코드를 보여 줍니다.

데이터베이스의 현재 레코드
데이터 집합에 로드된 원래 레코드
데이터 집합에서 변경할 내용

따라서 사용자는 제안된 버전으로 데이터베이스를 덮어 쓰거나 업데이트를 취소한 다음 데이터베이스의 새 값으로 데이터 집합을 새로 고칠 수 있습니다.

동시성 오류를 처리할 수 있도록 하려면

사용자 지정 오류 처리기를 만듭니다.
사용자에게 선택 목록을 표시합니다.
사용자의 응답을 처리합니다.
업데이트를 다시 보내거나 데이터 집합의 데이터를 다시 설정합니다.

동시성 오류를 처리할 코드 추가

업데이트를 수행하는데 예외가 발생하면 일반적으로 예외에서 제공하는 정보를 바탕으로 조치를 취하게 됩니다.

이 단원에서는 데이터베이스를 업데이트하려고 시도하는 코드를 추가하고 DBConcurrencyException이 발생한 경우 이를 처리하고 다른 예외도 있으면 처리합니다.

참고

이 연습의 뒷부분에서 CreateMessage 및 ProcessDialogResults 메서드를 추가합니다.

동시성 오류에 대한 오류 처리를 추가하려면

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.");
    }
}

다음과 같이 되도록 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[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:
            northwindDataSet.Merge(tempCustomersDataTable, true, MissingSchemaAction.Ignore);
            UpdateDatabase();
            break;

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

테스트

이제 폼을 테스트하여 예상한 대로 동작하는지 확인할 수 있습니다. 동시성 위반을 시뮬레이션하려면 NorthwindDataSet을 채운 후 데이터베이스의 데이터를 변경해야 합니다.

폼을 테스트하려면

F5 키를 눌러 응용 프로그램을 실행합니다.
폼이 나타나면 계속 실행되도록 두고 Visual Studio IDE로 전환합니다.
보기 메뉴에서 서버 탐색기를 선택합니다.
서버 탐색기에서 응용 프로그램이 사용하고 있는 연결을 확장한 다음 테이블 노드를 확장합니다.
Customers 테이블을 마우스 오른쪽 단추로 클릭하고 테이블 데이터 표시를 선택합니다.
첫 번째 레코드(ALFKI)에서 ContactName을 Maria Anders2로 변경합니다.

참고

다른 행으로 이동하여 변경 내용을 커밋합니다.
실행 중인 ConcurrencyWalkthrough의 폼으로 전환합니다.
폼의 첫 번째 레코드(ALFKI)에서 ContactName을 Maria Anders1로 변경합니다.
Save 단추를 클릭합니다.

동시성 오류가 발생하고 메시지 상자가 표시됩니다.
No를 클릭하면 업데이트가 취소되고 데이터 집합이 현재 데이터베이스에 있는 값으로 업데이트되고, Yes를 클릭하면 변경된 값이 데이터베이스에 기록됩니다.