배치를 통한 트랜잭션 변경

개요

이 가이드에서 EF Core 제공자 애플리케이션에서 트랜잭션 을 사용하는 방법을 학습할 수 있습니다. 트랜잭션은 일련의 쓰기 작업을 래핑합니다. 트랜잭션의 작업 중 하나라도 실패하면 제공자가 트랜잭션의 모든 변경 사항을 롤백합니다. 이러한 동작은 데이터 일관성을 보장하는 데 도움을 줍니다.

EF Core Provider는 다음 트랜잭션 모드를 지원합니다.

• 암시적 트랜잭션: 제공자는 SaveChanges() 및 SaveChangesAsync() 메서드에 대한 호출을 트랜잭션에 자동으로 래핑합니다. 이 동작을 구성하거나 비활성화하는 방법을 알아보려면 암시적 트랜잭션 구성 을 참조하세요.

• 명시적 트랜잭션: Database.BeginTransaction() 메서드를 호출하여 수동으로 트랜잭션을 시작하고, 그러한 다음 Commit() 또는 Rollback()를 호출하여 트랜잭션을 커밋하거나 롤백합니다.

public class Planet
{
    public ObjectId _id { get; set; }
    public string name { get; set; } = null!;
    public int orderFromSun { get; set; }
    public bool hasRings { get; set; }
}

요구 사항 및 제한 사항

트랜잭션을 사용하기 전에 다음 요구 사항 및 제한 사항을 유의하세요.

• 트랜잭션에는 복제본 세트 또는 샤딩된 클러스터 와 같은 다중 문서 트랜잭션을 지원하는 MongoDB Server 배포서버 필요합니다. 애플리케이션 독립형 배포서버 에서 트랜잭션 시작하려고 하면 제공자 가 NotSupportedException을 발생시킵니다. 이를 방지하려면 암시적 트랜잭션 구성에 설명된 대로 AutoTransactionBehavior.Never 를 설정하다 .

• EF Core 제공자는 System.Transactions.TransactionScope에 의해 만들어진 것과 같은 .NET 애비언트 트랜잭션을 지원하지 않습니다. 애비언트 트랜잭션을 사용하려고 하면 제공자가 예외를 발생시킵니다. 대신 임플리시트 또는 명시적 트랜잭션을 사용하십시오.

임시적 트랜잭션

기본값으로 여러 루트 엔터티 가 영향을 받는 경우 EF Core Provider는 트랜잭션에서 SaveChanges() 및 SaveChangesAsync() 호출을 자동으로 래핑합니다. 루트 엔터티는 다른 문서 내에 저장되는 소유 유형 또는 내장된 유형과 달리 컬렉션 의 최상위 문서 입니다.

다음 예시에서는 단일 SaveChanges() 호출에서 두 개의 행성을 삽입합니다. 이 작업은 두 개 이상의 루트 개체에 영향을 주므로 제공자가 자동으로 트랜잭션으로 랩싹니다. 삽입 중 하나라도 실패하면 제공자가 두 개의 변경 사항을 모두 롤백합니다.

Synchronous 또는 Asynchronous 탭을 선택하여 해당 코드를 확인합니다.

dbContext.Planets.AddRange(
    new Planet { Name = "Mercury" },
    new Planet { Name = "Venus" }
);
// Both inserts succeed or both are rolled back
dbContext.SaveChanges();

dbContext.Planets.AddRange(
    new Planet { Name = "Mercury" },
    new Planet { Name = "Venus" }
);
// Both inserts succeed or both are rolled back
await dbContext.SaveChangesAsync();

dbContext.Database.AutoTransactionBehavior = AutoTransactionBehavior.Never;
// This SaveChanges() call will not use a transaction
dbContext.Planets.Add(new Planet { Name = "Mars" });
dbContext.SaveChanges();

dbContext.Database.AutoTransactionBehavior = AutoTransactionBehavior.Never;
// This SaveChangesAsync() call will not use a transaction
dbContext.Planets.Add(new Planet { Name = "Mars" });
await dbContext.SaveChangesAsync();

명시적 트랜잭션

명시적 트랜잭션을 사용하여 여러 SaveChanges() 호출 및 기타 작업을 단일 아토믹 작업 단위로 그룹할 수 있습니다. 명시적 트랜잭션을 시작하려면 Database.BeginTransaction() 또는 Database.BeginTransactionAsync() 메서드를 호출하세요. 작업을 수행한 후 Commit() 또는 CommitAsync() 를 호출하여 트랜잭션을 완료합니다.

다음 예시는 단일 트랜잭션에 여러 작업을 래핑하여 이 패턴을 보여줍니다. 작업이 예외를 발생시키면 제공자는 트랜잭션의 모든 변경 사항을 자동으로 롤백합니다. Synchronous 또는 Asynchronous 탭을 선택하여 해당 코드를 확인합니다.

using var transaction = dbContext.Database.BeginTransaction();
var planet = dbContext.Planets.First(p => p.Name == "Mercury");
planet.Name = "Mercury (Updated)";
dbContext.SaveChanges();
dbContext.Planets.Add(new Planet { Name = "Venus" });
dbContext.SaveChanges();
transaction.Commit();

await using var transaction = await dbContext.Database.BeginTransactionAsync();
var planet = await dbContext.Planets.FirstAsync(p => p.Name == "Mercury");
planet.Name = "Mercury (Updated)";
await dbContext.SaveChangesAsync();
dbContext.Planets.Add(new Planet { Name = "Venus" });
await dbContext.SaveChangesAsync();
await transaction.CommitAsync();

var options = new TransactionOptions(
    readConcern: new Optional<ReadConcern>(ReadConcern.Majority)
);
using var transaction = dbContext.Database.BeginTransaction(options);
var planet = dbContext.Planets.First(p => p.Name == "Mercury");
planet.Name = "Mercury (Updated)";
dbContext.SaveChanges();
transaction.Commit();

var options = new TransactionOptions(
    readConcern: new Optional<ReadConcern>(ReadConcern.Majority)
);
await using var transaction = await dbContext.Database.BeginTransactionAsync(options);
var planet = await dbContext.Planets.FirstAsync(p => p.Name == "Mercury");
planet.Name = "Mercury (Updated)";
await dbContext.SaveChangesAsync();
await transaction.CommitAsync();

트랜잭션 제한

트랜잭션을 사용할 때는 다음과 같은 제한 사항 및 주의 사항이 적용됩니다.

• 배포서버가 자동 트랜잭션을 지원하지 않는 경우에만 비활성화합니다. 자동 트랜잭션을 비활성화하면 데이터 불일치가 발생할 수 있으며 낙관적 동시성을 사용할 수 없습니다.

• MongoDB Server는 중청 트랜잭션을 지원하지 않습니다. 트랜잭션이 이미 활성화되어 있는 동안 BeginTransaction() 또는 BeginTransactionAsync() 을 호출하면 제공자가 InvalidOperationException를 오류로 발생시킵니다.

• MongoDB Server는 트랜잭션 저장점을 지원하지 않습니다. 전체 트랜잭션을 커밋하거나 롤백해야 합니다.

• 기본적으로 MongoDB Server는 transactionLifetimeLimitSeconds 서버 매개변수에 의해 제어되는 데로 60 초 이상 실행되는 모든 트랜잭션을 중단합니다. 이 제한은 임시적 트랜잭션과 명시적 트랜잭션 모두에 적용됩니다. 트랜잭션이 이 시간 제한을 초과하면 MongoDB Server는 트랜잭션을 중단하고 제공자는 오류를 발생시킵니다. 트랜잭션 내에서 외부 API 호출과 같은 장기 실행 작업을 수행하지 마십시오.

• MongoDB Server에 네트워크 중단이 발생하거나 복제본 세트 투표를 수행해야 하는 경우 TransientTransactionError 오류가 반환될 수 있습니다. 이러한 경우 EF Core Provider는 트랜잭션을 자동으로 다시 시도하지 않습니다. 일시적 트랜잭션 오류와 다시 시도 전략에 대해 자세히 알아보려면 트랜잭션 오류 처리를 참조하십시오.

추가 정보

이 가이드의 개념에 대해 자세히 알아보려면 다음 리소스를 참조하세요.

• MongoDB에 데이터 쓰기
• 낙관적 동시성을 통한 데이터 일관성 보장
• 트랜잭션

이 가이드에서 사용되는 메서드에 대해 자세히 학습하려면 다음 .NET API 문서를 참조하십시오.

• BeginTransaction() 및 BeginTransactionAsync()

• CommitTransaction() 및 CommitTransactionAsync()

• RollbackTransaction() 및 RollbackTransactionAsync()

• SaveChanges() 및 SaveChangesAsync()