트랜잭션

개요

이 가이드에서는 Node.js 드라이버를 사용하여 트랜잭션을 수행하는 방법을 배울 수 있습니다. 트랜잭션을 사용하면 전체 트랜잭션이 커밋될 때까지 데이터를 변경하지 않는 일련의 작업을 실행할 수 있습니다. 트랜잭션에서 작업이 실패하는 경우 드라이버는 트랜잭션을 종료하고 데이터 변경 사항이 표시되기 전에 모든 데이터 변경 사항을 삭제합니다. 이 특성을 원자성이라고 합니다.

MongoDB의 단일 문서에 대한 모든 쓰기 작업은 개별적으로 이뤄지므로 트랜잭션을 사용하여 여러 문서를 수정하는 원자(atomic) 변경을 수행해야 할 수 있습니다. 이 경우 다중 문서 트랜잭션이 필요합니다. MongoDB는 드라이버에 예기치 않은 오류가 발생하더라도 트랜잭션 작업과 관련된 데이터가 일관성을 유지하도록 보장하기 때문에 다중 문서 트랜잭션은 ACID를 준수합니다.

ACID 컴플라이언스 및 트랜잭션에 대한 자세한 내용은 ACID 트랜잭션 관련 문서를 참조하세요.

MongoDB에서 다중 문서 트랜잭션은 클라이언트 세션 내에서 실행됩니다. 클라이언트 세션은 순차적으로 실행하고자 하는 관련 읽기 또는 쓰기 작업을 그룹화한 것입니다. 매번 새 클라이언트를 인스턴스화하는 대신 여러 세션 및 트랜잭션에 클라이언트를 재사용할 것을 권장합니다.

majority 읽기 및 쓰기 고려와 결합하면 드라이버는 작업 간의 인과적 일관성을 보장합니다. 자세한 내용은 Server 매뉴얼의 클라이언트 세션 및 인과적 일관성 보장 페이지를 참조하세요.

이 가이드의 다음 섹션에서 드라이버를 사용하여 다중 문서 트랜잭션을 수행하는 방법에 대해 더욱 자세히 알아보세요.

• 트랜잭션 API

• 트랜잭션 옵션

• 트랜잭션 오류

트랜잭션 API

이 드라이버는 트랜잭션 수행을 위한 두 가지 API, 즉 Core API와 편리한 트랜잭션 API를 제공합니다.

Core API는 트랜잭션을 생성, 커밋, 종료할 수 있는 프레임워크입니다. 해당 API를 사용할 때 다음 조치를 명시적으로 수행해야 합니다.

• 트랜잭션 생성, 커밋, 종료.

• 트랜잭션을 실행하는 세션 생성 및 종료.

• 오류 처리 로직 구현.

편리한 트랜잭션 API는 트랜잭션을 커밋하거나 종료할 책임 없이 트랜잭션을 수행할 수 있는 프레임워크입니다. 해당 API는 서버에서 특정 오류 유형이 발생할 때 작업을 다시 시도하는 오류 처리 로직을 자동으로 통합합니다. 이 동작에 대해 자세히 알아보려면 본 가이드의 트랜잭션 오류 섹션을 참조하세요.

async function coreTest(client) {
  const session = client.startSession();
  try {
    session.startTransaction();
    const savingsColl = client.db("bank").collection("savings_accounts");
    await savingsColl.findOneAndUpdate(
      {account_id: "9876"}, 
      {$inc: {amount: -100 }}, 
      { session });
    const checkingColl = client.db("bank").collection("checking_accounts");
    await checkingColl.findOneAndUpdate(
      {account_id: "9876"}, 
      {$inc: {amount: 100 }}, 
      { session });
    // ... perform other operations
    await session.commitTransaction();
    console.log("Transaction committed.");
  } catch (error) {
    console.log("An error occurred during the transaction:" + error);
    await session.abortTransaction();
  } finally {
    await session.endSession();
  }
}

const session = client1.startSession();
client2.db('myDB').collection('myColl').insertOne({ name: 'Jane Eyre' }, { session });

async function convTest(client) {
  let txnRes = await client.withSession(async (session) =>
    session.withTransaction(async (session) => {
      const savingsColl = client.db("bank").collection("savings_accounts");
      await savingsColl.findOneAndUpdate(
        {account_id: "9876"}, 
        {$inc: {amount: -100 }}, 
        { session });
  
      const checkingColl = client.db("bank").collection("checking_accounts");
      await checkingColl.findOneAndUpdate(
        {account_id: "9876"}, 
        {$inc: {amount: 100 }}, 
        { session });
      // ... perform other operations
      return "Transaction committed.";
    }, null)
  );
  console.log(txnRes);
}

트랜잭션 옵션

TransactionOptions 인스턴스를 startTransaction() 및 withTransaction() 메서드에 전달하여 드라이버가 트랜잭션을 수행하는 방식을 구성할 수 있습니다. 옵션을 지정하면 MongoClient 인스턴스에 기존에 설정된 옵션 값이 재정의됩니다.

다음 표는 TransactionOptions 인스턴스에서 지정할 수 있는 옵션을 포함합니다.

전체 옵션 목록은 트랜잭션 옵션에 대한 API 설명서를 참조하세요.

다음 코드는 트랜잭션 옵션을 정의하고 startTransaction() 메서드에 전달하는 방법을 보여줍니다.

const txnOpts = {
  readPreference: 'primary',
  readConcern: { level: 'local' },
  writeConcern: { w: 'majority' },
  maxCommitTimeMS: 1000
};
session.startTransaction(txnOpts);

트랜잭션 오류

Core API를 사용하여 트랜잭션을 수행하는 경우 다음과 같은 오류에 대한 오류 처리 로직을 애플리케이션에 통합해야 합니다.

• TransientTransactionError: 드라이버가 트랜잭션을 커밋하기 전에 쓰기 작업에 오류가 발생하면 발생합니다. 이 오류에 대한 자세한 내용은 서버 매뉴얼의 드라이버 API 페이지에서 TransientTransactionError 설명을 참조하세요.

• UnknownTransactionCommitResult: 커밋 작업에 오류가 나면 발생합니다. 이 오류에 대한 자세한 내용은 서버 매뉴얼의 드라이버 API 페이지에서 UnknownTransactionCommitResult 설명을 참조하세요.

편리한 트랜잭션 API에는 이러한 오류 유형에 대한 재시도 로직이 통합되어 있으므로 드라이버는 성공적인 커밋이 있을 때까지 트랜잭션을 재시도합니다.