트랜잭션 및 세션

개요

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

MongoDB 에서 트랜잭션은 논리적 세션 내에서 실행 . 세션은 순차적으로 실행 하려는 관련 읽기 또는 쓰기 (write) 작업을 그룹화한 것입니다. 세션을 사용하면 작업 그룹 에 인과적 일관성 활성화 원자성, 일관성, 격리 및 내구성에 대한 기대치를 충족하는 트랜잭션 인 ACID 호환 트랜잭션 에서 작업을 실행 수 있습니다.

장고의 네이티브 트랜잭션 API 지원되지 않지만, 장고 MongoDB 백엔드는 동일한 기능을 활성화하는 사용자 지정 트랜잭션 API 제공합니다. 트랜잭션 내에서 작업을 실행 하려면 원자적 코드 차단 내에서 정의합니다. Django MongoDB 백엔드는 세션 로직을 내부적으로 관리하므로 트랜잭션 실행 전에 세션을 수동으로 시작할 필요가 없습니다.

from django.db import models
from django_mongodb_backend.fields import ArrayField
class Movie(models.Model):
    title = models.CharField(max_length=200)
    plot = models.TextField(blank=True)
    runtime = models.IntegerField(default=0)
    released = models.DateTimeField("release date", null=True, blank=True)
    genres = ArrayField(models.CharField(max_length=100), null=True, blank=True)
    class Meta:
        db_table = "movies"
        managed = False
    
    def __str__(self):
        return self.title

python manage.py shell

from <your application name>.models import Movie
from django.utils import timezone
from datetime import datetime

트랜잭션 시작

데이터베이스 트랜잭션 시작하려면 django_mongodb_backend.transaction.atomic() 함수를 호출합니다. 이 함수를 데코레이터 또는 컨텍스트 관리자로 사용할 수 있습니다.

다음 가져오기 성명서 사용하여 transaction 모듈을 가져와야 합니다.

from django_mongodb_backend import transaction

@transaction.atomic
def insert_movie_transaction():
    Movie.objects.create(
        title="Poor Things",
        runtime=141,
        genres=["Comedy", "Romance"]
    )

def insert_movie_transaction():
    with transaction.atomic():
        Movie.objects.create(
            title="Poor Things",
            runtime=141,
            genres=["Comedy", "Romance"]
        )

트랜잭션 후 콜백 실행

트랜잭션 성공적으로 완료된 경우에만 특정 작업을 수행하려면 transaction.on_commit() 함수를 사용할 수 있습니다. 이 함수를 사용하면 트랜잭션 이 데이터베이스 에 커밋된 후 실행 콜백을 등록할 수 있습니다. 함수 또는 호출 가능한 객체 를 인수로 on_commit()에 전달합니다.

다음 예시 관련 데이터베이스 트랜잭션 완료된 후에만 genre 값이 ["Horror", "Comedy"] 인 영화를 쿼리합니다.

def get_horror_comedies():
    movies = Movie.objects.filter(genres=["Horror", "Comedy"])
    for m in movies:
        print(f"Title: {m.title}, runtime: {m.runtime}")
def insert_movie_with_callback():
    with transaction.atomic():
        Movie.objects.create(
            title="The Substance",
            runtime=140,
            genres=["Horror", "Comedy"]
        )
        transaction.on_commit(get_horror_comedies)

트랜잭션 오류 처리

트랜잭션 중에 발생하는 예외를 처리하다 하려면 원자성 코드 차단 주위에 오류 처리 로직을 추가합니다. 원자성 차단 내부의 오류를 처리하다 경우 Django에서 이러한 오류를 가릴 수 있습니다. 장고는 오류를 사용하여 트랜잭션 커밋 할지 아니면 롤백할지 결정하기 때문에 예기치 않은 동작이 발생할 수 있습니다.

트랜잭션 성공하지 못하면 Django는 모델 필드에 대한 변경 사항을 되돌리지 않습니다. 모델과 데이터베이스 문서 간의 불일치를 방지하려면 원래 필드 값을 수동으로 복원 해야 할 수 있습니다.

movie = Movie.objects.get(title="Jurassic Park")
movie.title = "Jurassic Park I"
try:
    with transaction.atomic():
        movie.save()
except DatabaseError:
    movie.title = "Jurassic Park"
if movie.title == "Jurassic Park I":
    movie.plot = "An industrialist invites experts to visit his theme park of cloned dinosaurs. After a power failure," \
    "   the creatures run loose, putting everyone's lives, including his grandchildren's, in danger."
    movie.save()

추가 정보

장고 트랜잭션 API 에 대해 자세히 학습 장고 문서에서 데이터베이스 트랜잭션을 참조하세요.