Django におけるトランザクション管理の主要なアプローチ

Web アプリケーション開発において、データの一貫性を保つことは極めて重要です。Django ORM では、データベースのトランザクションを制御するための複数の手段が用意されています。要件に応じて適切なレベルでトランザクションを適用することで、安全性とパフォーマンスのバランスを取ることができます。

1. グローバル設定による自動制御

プロジェクト全体で自動的にトランザクションを有効にする方法です。settings.py のデータベース設定において、ATOMIC_REQUESTS を True に設定します。これにより、各 HTTP リクエストの処理全体が単一のトランザクションとして扱われます。

# settings.py
DATABASES = {
    'default': {
        'ENGINE': 'django.db.backends.postgresql',
        'NAME': 'mydatabase',
        # リクエスト単位で自動的にトランザクションを張る
        'ATOMIC_REQUESTS': True,
    }
}

この設定は実装の手間を減らせますが、すべてのリクエストでオーバーヘッドが発生するため、パフォーマンスが敏感な箇所では注意が必要です。特定のビューでこの自動制御を無効化したい場合は、non_atomic_requests デコレータを使用します。

from django.http import HttpResponse
from django.db import transaction

# グローバル設定があってもこのビューではトランザクションを無効化
@transaction.non_atomic_requests
def status_check(request):
    return HttpResponse('System OK')

2. ビューレベルでの明示的な制御

特定の関数またはクラスベースのビューに対してのみトランザクションを適用する場合は、デコレータを用いるのが一般的です。この方法では、必要な処理のみをアトミックなブロックとして囲むことができます。

関数ベースビュー（FBV）の場合：

from django.db import transaction
from django.http import JsonResponse

@transaction.atomic
def handle_purchase(request):
    # 注文処理などのロジック
    # 例外が発生すれば自動的にロールバックされる
    return JsonResponse({'status': 'completed'})

クラスベースビュー（CBV）や DRF の APIView を使用する場合も同様に、メソッド単位でデコレータを適用します。

from rest_framework.views import APIView
from django.db import transaction

class OrderAPIView(APIView):
    @transaction.atomic
    def post(self, request):
        # 在庫更新などの処理
        pass

注意点として、デコレータとして使用する際は @transaction.atomic と記述し、括弧を付けないのが正しい用法です。@transaction.atomic() とすると呼び出しとなってしまうため注意が必要です。

3. 細粒度な制御と保存点（Savepoint）

より複雑なロジックにおいて、処理の一部のみをロールバックさせたい場合や、トランザクションの範囲を明示的に制御したい場合は、コンテキストマネージャまたは手動制御を使用します。

コンテキストマネージャの利用

with ステートメントを使用することで、ブロック内の処理がすべて成功した場合にのみコミットされ、例外発生時には自動的にロールバックされます。

from django.db import transaction
from django.http import HttpResponse

def process_inventory(request):
    try:
        with transaction.atomic():
            # このブロック内はすべて 1 つのトランザクションとして扱われる
            # 複数のモデル更新処理など
            pass
        return HttpResponse('Inventory Updated')
    except Exception:
        return HttpResponse('Failed', status=500)

保存点を用いた部分ロールバック

トランザクション内でさらに細かい制御が必要な場合、保存点（Savepoint）を設定できます。これにより、エラー発生時にトランザクション全体を巻き戻すのではなく、特定の時点まで戻すことが可能になります。

from django.db import transaction
from .models import InventoryItem

def complex_update(request):
    with transaction.atomic():
        # トランザクション開始後に保存点を設定
        sp_id = transaction.savepoint()
        
        try:
            item = InventoryItem.objects.get(pk=101)
            item.quantity -= 5
            item.save()
        except Exception:
            # 例外発生時は保存点までロールバック
            transaction.savepoint_rollback(sp_id)
            # エラーログ記録など
        else:
            # 正常時は保存点をコミット
            transaction.savepoint_commit(sp_id)
            
    return HttpResponse('Processing Done')

保存点の操作は、対応するデータベースバックエンド（PostgreSQL など）がサポートしている必要があります。savepoint で識別子を取得し、異常時には savepoint_rollback、正常時には savepoint_commit を呼び出すことで、処理の継続性を保ちながらデータ整合性を維持できます。