거래 수행

개요

이 가이드 에서는 MongoDB PHP 라이브러리를 사용하여 트랜잭션 을 수행하는 방법을 학습 수 있습니다. 트랜잭션을 사용하면 전체 트랜잭션 이 커밋된 경우에만 데이터를 변경하는 일련의 작업을 수행할 수 있습니다. 트랜잭션 의 작업이 성공하지 못하면 라이브러리는 트랜잭션 을 중지하고 데이터 변경 사항이 표시되기 전에 모든 데이터 변경 사항을 삭제합니다. 이 기능 을 원자성 이라고 합니다.

MongoDB에서 트랜잭션은 논리적 세션 내에서 실행됩니다. 세션은 순차적으로 실행하려는 관련 읽기 또는 쓰기 작업을 그룹화한 것입니다. 세션을 사용하면 작업 그룹에 인과적 일관성을 부여하고 원자성, 일관성, 격리 및 내구성에 대한 기대치를 충족하는 트랜잭션인 ACID 호환 트랜잭션에서 작업을 실행할 수 있습니다. MongoDB는 작업에 예기치 않은 오류가 발생하더라도 트랜잭션 작업과 관련된 데이터의 일관성을 보장합니다.

MongoDB PHP 라이브러리를 사용하는 경우 MongoDB\Client 인스턴스 에서 새 세션을 만들 수 있습니다. 그런 다음 결과 MongoDB\Driver\Session 인스턴스 를 사용하여 트랜잭션을 수행할 수 있습니다.

트랜잭션 API

이 섹션에서는 MongoDB PHP 라이브러리에서 제공하는 트랜잭션 API에 학습 수 있습니다. 트랜잭션 을 시작하기 전에 Client 인스턴스 에서 MongoDB\Client::startSession() 메서드를 사용하여 Session 를 만들어야 합니다. 그런 다음 다음 API 중 하나를 사용하여 트랜잭션 을 수행할 수 있습니다.

• Convenient API

• Core API

트랜잭션 예시

이 예시 에서는 은행 트랜잭션 를 위해 bank 데이터베이스 컬렉션의 데이터를 수정하는 콜백 함수를 정의합니다. 이 코드는 다음 조치를 수행합니다.

• 대상 컬렉션에 액세스 하기 위해 Collection 인스턴스를 만듭니다.

• 계정 간에 이체할 계정 번호와 금액을 지정합니다.

• Session 인스턴스 를 매개변수로 수신하는 콜백 함수를 정의합니다.

• 송금을 반영하도록 고객의 잔액을 업데이트합니다.

• 타임스탬프와 함께 트랜잭션 영수증을 기록합니다.

• 트랜잭션 이 성공적으로 커밋된 경우 메시지를 인쇄합니다.

$receipts = $client->bank->receipts;
$checking = $client->bank->checking_accounts;
$saving = $client->bank->saving_accounts;
$accountId = "5678";
$transferAmount = 1000.0;
$callback = function (MongoDB\Driver\Session $session) use (
    $checking,
    $saving,
    $receipts,
    $accountId,
    $transferAmount
): void {
    $checking->updateOne(
        ["account_id" => $accountId],
        ['$inc' => ["balance" => -$transferAmount]],
        ["session" => $session]
    );
    $saving->updateOne(
        ["account_id" => $accountId],
        ['$inc' => ["balance" => $transferAmount]],
        ["session" => $session]
    );
    $summary = sprintf('SAVINGS +%1$u CHECKING -%1$u', $transferAmount);
    $receipts->insertOne(
        [
            "account_id" => $accountId,
            "summary" => $summary,
            "timestamp" => new MongoDB\BSON\UTCDateTime(),
        ],
        ["session" => $session]
    );
    echo "Successfully performed transaction!", PHP_EOL;
    echo "Summary: ", $summary, PHP_EOL;
};

그런 다음 다음 코드를 실행 하여 트랜잭션 을 수행합니다. 이 코드는 다음 작업을 완료합니다.

1. startSession() 메서드를 사용하여 클라이언트에서 세션을 생성합니다.

2. with_transaction() 함수를 호출하여 트랜잭션 을 관리 하고 세션과 콜백 을 매개 변수로 전달합니다.

$session = $client->startSession();
try {
    MongoDB\with_transaction($session, $callback);
} catch (MongoDB\Driver\Exception\RuntimeException $e) {
    echo "Caught exception: ", $e->getMessage(), PHP_EOL;
}

Successfully performed transaction!
Summary: SAVINGS +1000 CHECKING -1000

추가 정보

이 가이드 에 언급된 개념에 학습 보려면 MongoDB Server 매뉴얼의 다음 페이지를 참조하세요.

• 트랜잭션

• 서버 세션

• 읽기 격리, 일관성 및 최신성

ACID compliance 에 학습 보려면 데이터베이스 관리 시스템의 ACID 속성이란 무엇인가요?를 참조하세요. 문서를 MongoDB 웹사이트 에서 확인하세요.

삽입 작업에 학습 보려면 문서 삽입 가이드 를 참조하세요.