Method get_or_create

ormar/queryset/queryset.py:1196–1238

Combination of create and get methods. Tries to get a row meeting the criteria for kwargs and if `NoMatch` exception is raised it creates a new one with given kwargs and _defaults. If a concurrent caller wins the race and creates a matching row betw

(
        self,
        _defaults: Optional[dict[str, Any]] = None,
        *args: Any,
        **kwargs: Any,
    )

        return processed_rows[0]  # type: ignore

    async def get_or_create(
        self,
        _defaults: Optional[dict[str, Any]] = None,
        *args: Any,
        **kwargs: Any,
    ) -> tuple["T", bool]:
        """
        Combination of create and get methods.

        Tries to get a row meeting the criteria for kwargs
        and if `NoMatch` exception is raised
        it creates a new one with given kwargs and _defaults.

        If a concurrent caller wins the race and creates a matching row
        between this call's ``get`` and ``create``, the ``create`` raises
        ``sqlalchemy.exc.IntegrityError`` and ``get`` is retried once.
        If the retry still finds no row, the original ``IntegrityError`` is
        re-raised because the violation isn't a race but a legitimate
        constraint conflict (e.g. a different unique key).

        Passing a criteria is actually calling filter(*args, **kwargs) method described
        below.

        :param kwargs: fields names and proper value types
        :type kwargs: Any
        :param _defaults: default values for creating object
        :type _defaults: Optional[dict[str, Any]]
        :return: model instance and a boolean
        :rtype: tuple("T", bool)
        """
        try:
            return await self.get(*args, **kwargs), False
        except NoMatch:
            pass

        _defaults = _defaults or {}
        try:
            return await self.create(**{**kwargs, **_defaults}), True
        except sqlalchemy.exc.IntegrityError as integrity_error:
            try:
                return await self.get(*args, **kwargs), False
            except NoMatch:
                raise integrity_error from None

    async def update_or_create(self, **kwargs: Any) -> "T":
        """