BAEL-8140: add missing files

Author: etrandafir93

persistence-modules/spring-boot-persistence-5/src/main/java/com/baeldung/rollbackonly/Application.java

@@ -0,0 +1,15 @@
+package com.baeldung.rollbackonly;
+
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.data.jpa.repository.config.EnableJpaRepositories;
+
+@SpringBootApplication
+@EnableJpaRepositories
+public class Application {
+
+    public static void main(String[] args) {
+        SpringApplication.run(Application.class, args);
+    }
+
+}

persistence-modules/spring-boot-persistence-5/src/main/java/com/baeldung/rollbackonly/Blog.java

@@ -0,0 +1,73 @@
+package com.baeldung.rollbackonly;
+
+import java.util.Optional;
+
+import org.springframework.stereotype.Component;
+import org.springframework.transaction.annotation.Transactional;
+import org.springframework.transaction.support.TransactionTemplate;
+
+import com.baeldung.rollbackonly.article.Article;
+import com.baeldung.rollbackonly.article.ArticleRepo;
+import com.baeldung.rollbackonly.audit.Audit;
+import com.baeldung.rollbackonly.audit.AuditRepo;
+import com.baeldung.rollbackonly.audit.AuditService;
+
+@Component
+public class Blog {
+
+    private final ArticleRepo articleRepo;
+    private final AuditRepo auditRepo;
+    private final AuditService auditService;
+    private final TransactionTemplate transactionTemplate;
+
+    Blog(ArticleRepo articleRepo, AuditRepo auditRepo, AuditService auditService, TransactionTemplate transactionTemplate) {
+        this.articleRepo = articleRepo;
+        this.auditRepo = auditRepo;
+        this.auditService = auditService;
+        this.transactionTemplate = transactionTemplate;
+    }
+
+    @Transactional
+    public Optional<Long> publishArticle(Article article) {
+        try {
+            article = articleRepo.save(article);
+            auditRepo.save(new Audit("SAVE_ARTICLE", "SUCCESS", "saved: " + article.getTitle()));
+            return Optional.of(article.getId());
+
+        } catch (Exception e) {
+            String errMsg = "failed to save: %s, err: %s".formatted(article.getTitle(), e.getMessage());
+            auditRepo.save(new Audit("SAVE_ARTICLE", "FAILURE", errMsg));
+            return Optional.empty();
+        }
+    }
+
+    @Transactional
+    public Optional<Long> publishArticle_v2(Article article) {
+        try {
+            article = articleRepo.save(article);
+            auditService.saveAudit("SAVE_ARTICLE", "SUCCESS", "saved: " + article.getTitle());
+            return Optional.of(article.getId());
+
+        } catch (Exception e) {
+            auditService.saveAudit("SAVE_ARTICLE", "FAILURE", "failed to save: " + article.getTitle());
+            return Optional.empty();
+        }
+    }
+
+    public Optional<Long> publishArticle_v3(final Article article) {
+        try {
+            Article savedArticle = transactionTemplate.execute(txStatus -> {
+                Article saved = articleRepo.save(article);
+                auditRepo.save(new Audit("SAVE_ARTICLE", "SUCCESS", "saved: " + article.getTitle()));
+                return saved;
+            });
+            return Optional.of(savedArticle.getId());
+
+        } catch (Exception e) {
+            auditRepo.save(
+                new Audit("SAVE_ARTICLE", "FAILURE", "failed to save: " + article.getTitle()));
+            return Optional.empty();
+        }
+    }
+
+}

persistence-modules/spring-boot-persistence-5/src/main/java/com/baeldung/rollbackonly/audit/Audit.java

@@ -0,0 +1,37 @@
+package com.baeldung.rollbackonly.audit;
+
+import jakarta.persistence.Entity;
+import jakarta.persistence.GeneratedValue;
+import jakarta.persistence.GenerationType;
+import jakarta.persistence.Id;
+
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+import java.time.LocalDateTime;
+
+@Data
+@NoArgsConstructor
+@Entity
+public class Audit {
+
+    @Id
+    @GeneratedValue(strategy = GenerationType.SEQUENCE)
+    private Long id;
+
+    private String operation;
+
+    private String status;
+
+    private String description;
+
+    private LocalDateTime timestamp;
+
+    public Audit(String operation, String status, String description) {
+        this.operation = operation;
+        this.status = status;
+        this.description = description;
+        this.timestamp = LocalDateTime.now();
+    }
+
+}

persistence-modules/spring-boot-persistence-5/src/main/java/com/baeldung/rollbackonly/audit/AuditRepo.java

@@ -0,0 +1,8 @@
+package com.baeldung.rollbackonly.audit;
+
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.stereotype.Repository;
+
+@Repository
+public interface AuditRepo extends JpaRepository<Audit, Long> {
+}

persistence-modules/spring-boot-persistence-5/src/test/java/com/baeldung/rollbackonly/BlogIntegrationTest.java

@@ -0,0 +1,83 @@
+package com.baeldung.rollbackonly;
+
+import static org.assertj.core.api.Assertions.assertThat;
+import static org.assertj.core.api.Assertions.assertThatThrownBy;
+
+import java.util.Optional;
+
+import org.junit.jupiter.api.BeforeEach;
+import org.junit.jupiter.api.Test;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.test.context.SpringBootTest;
+import org.springframework.transaction.UnexpectedRollbackException;
+
+import com.baeldung.rollbackonly.article.Article;
+import com.baeldung.rollbackonly.article.ArticleRepo;
+import com.baeldung.rollbackonly.audit.AuditRepo;
+
+@SpringBootTest(classes = { Application.class })
+class BlogIntegrationTest {
+
+    @Autowired
+    private Blog articleService;
+
+    @Autowired
+    private ArticleRepo articleRepo;
+
+    @Autowired
+    private AuditRepo auditRepo;
+
+    @BeforeEach
+    void afterEach() {
+        articleRepo.deleteAll();
+        auditRepo.deleteAll();
+    }
+
+    @Test
+    void whenPublishingAnArticle_thenAlsoSaveSuccessAudit() {
+        articleService.publishArticle(new Article("Test Article", "John Doe"));
+
+        assertThat(articleRepo.findAll())
+            .extracting("title")
+            .containsExactly("Test Article");
+
+        assertThat(auditRepo.findAll())
+            .extracting("description")
+            .containsExactly("saved: Test Article");
+    }
+
+    @Test
+    void whenPublishingAnInvalidArticle_thenThrowsUnexpectedRollbackException() {
+        assertThatThrownBy(() -> articleService.publishArticle(
+                new Article("Test Article", null)))
+            .isInstanceOf(UnexpectedRollbackException.class)
+            .hasMessageContaining("Transaction silently rolled back because it has been marked as rollback-only");
+
+        assertThat(auditRepo.findAll())
+            .isEmpty();
+    }
+
+    @Test
+    void whenPublishingAnInvalidArticle_thenSavesFailureToAudit() {
+        assertThatThrownBy(() -> articleService.publishArticle_v2(
+                new Article("Test Article", null)))
+            .isInstanceOf(Exception.class);
+
+        assertThat(auditRepo.findAll())
+            .extracting("description")
+            .containsExactly("failed to save: Test Article");
+    }
+
+    @Test
+    void whenPublishingAnInvalidArticle_thenRecoverFromError_andSavesFailureToAudit() {
+        Optional<Long> id = articleService.publishArticle_v3(
+            new Article("Test Article", null));
+
+        assertThat(id)
+            .isEmpty();
+
+        assertThat(auditRepo.findAll())
+            .extracting("description")
+            .containsExactly("failed to save: Test Article");
+    }
+}