import uuid

import pytest

from django.db import models, transaction
from django.db.utils import IntegrityError

from psqlextra.query import ConflictAction

from ..fake_model import get_fake_model


@pytest.mark.benchmark()
def test_insert_nothing_traditional(benchmark):
    model = get_fake_model(
        {"field": models.CharField(max_length=255, unique=True)}
    )

    random_value = str(uuid.uuid4())[:8]
    model.objects.create(field=random_value)

    def _traditional_insert(model, random_value):
        """Performs a concurrency safe insert the traditional way."""

        try:
            with transaction.atomic():
                return model.objects.create(field=random_value)
        except IntegrityError:
            return model.objects.filter(field=random_value).first()

    benchmark(_traditional_insert, model, random_value)


@pytest.mark.benchmark()
def test_insert_nothing_native(benchmark):
    model = get_fake_model(
        {"field": models.CharField(max_length=255, unique=True)}
    )

    random_value = str(uuid.uuid4())[:8]
    model.objects.create(field=random_value)

    def _native_insert(model, random_value):
        """Performs a concurrency safeinsert using the native PostgreSQL
        conflict resolution."""

        return model.objects.on_conflict(
            ["field"], ConflictAction.NOTHING
        ).insert_and_get(field=random_value)

    benchmark(_native_insert, model, random_value)