Quarkus: обновлять таблицу базы данных, даже если внешняя транзакция откатилась

JPA имеет возможность контролировать исключения, при которых транзакции необходимо откатить. Аннотация @Transactional имеет два атрибута: rollbackOn и dontRollbackOn.

Согласно документации:

Элемент dontRollbackOn может быть установлен для указания исключений, которые не должны приводить к тому, что перехватчик помечает транзакцию для отката. И наоборот, элемент rollbackOn может быть установлен для указания исключений, которые должны заставить перехватчик пометить транзакцию для отката. Если для любого из этих элементов указан класс, назначенное поведение применяется также к подклассам этого класса. Если указаны оба элемента, dontRollbackOn имеет приоритет.

В моем решении нет необходимости запускать транзакцию на уровне ресурсов, но она также работает с другими транзакциями.

@ApplicationScoped
public class DocumentGeneratorComponent {

    @Transactional(dontRollbackOn = DocumentException.class)
    public void generateDocument() {

        var trackingRecord = createTrackingRecord(DocGenStatus.STARTED);
        try {
            var input = getInputData(trackingRecord.id);
            // ...

            // It was missing in the question, but I assume it would be helpful 
            // to mark when the document generation finished successfully.
            trackingRecord.docGenStatus = DocGenStatus.FINISHED;
        } catch (DocumentException e) {
            trackingRecord.docGenStatus = DocGenStatus.EXCEPTION;
            throw e;
        }
    }

    @Transactional
    TrackingRecord createTrackingRecord(DocGenStatus status) {
        TrackingRecord record = new TrackingRecord();
        record.docGenStatus = status;
        record.persistAndFlush();
        return record;
    }

    String getInputDate(Long trackingRecordId) {
        if (null == trackingRecordId) {
            throw new DocumentException("Invalid tracking record (null).");
        }
        if (trackingRecordId % 2 == 0L) {
            return "FOO";
        }
        throw new DocumentException("Sometimes it is happen.");
    }

}

Пример сущности TrackingRecord:

@Entity
public class TrackingRecord extends PanacheEntity {
    @Enumerated(EnumType.STRING)
    public DocGenStatus docGenStatus;
}

Как видите, метод createTrackingRecord(...) возвращает сущность вместо ее идентификатора. Этот объект привязан к контексту сохранения.

Теперь аннотация @Transactional для метода ресурса больше не требуется.

@Path("/document")
public class DocumentResource {
    
    @Inject
    DocumentGeneratorComponent documentGeneratorComponent;

    @POST
    @Path("/generate")
    public void generateDocument() {
        documentGeneratorComponent.generateDocument();
    }
}

Хорошо, а как насчет других бизнес-услуг, которые

им также может потребоваться создать документы, и они могут сделать это в рамках своей транзакции.

Это также возможно.

@ApplicationScoped
public class OtherBusinessService {

    @Inject
    DocumentGeneratorComponent documentGeneratorComponent;

    @Transactional(value = Transactional.TxType.REQUIRES_NEW)
    public void whateverBusinessMethod() {
        var entity = new CustomBusinessEntity();
        entity.name = "John Doe";
        entity.persist();
        try {
            documentGeneratorComponent.generateDocument();
            entity.documentGenerated = true;
        } catch (DocumentException e) {
            entity.documentGenerated = false;
        }
    }
}

OtherBusinessService.whateverBusinessMethod() сохранится как для CustomBusinessEntity, так и для TrackingRecord сущностей.

Важно то, что OtherBusinessService или любой другой бизнес-метод, который обрабатывает собственную транзакцию, должен обрабатывать это определенное исключение следующими способами:

• Перехватывайте исключение во внешнем бизнес-методе и не выдавайте его повторно или
• если необходим повторный бросок, добавьте это исключение во внешний атрибут @Transactional аннотации dontRollbackOn.

Вы исследовали использование синхронизации транзакций? Метод обратного вызова Synchronization.afterCompletion будет вызван после завершения транзакции, поэтому блокировки базы данных будут сняты.