Chore: 서비스 계층 트랜잭션 정책 정비 (class-level + checked rollback)

Author: lunarbae628

src/main/java/io/ejangs/docsa/domain/branch/app/BranchService.java

@@ -98,7 +98,7 @@ private BranchCreateContext prepareBranchCreateContext(Long documentId,
         );
     }
 
-    @Transactional
+    @Transactional(rollbackFor = Exception.class)
     public BranchRenameResponse renameBranch(Long documentId, Long branchId, String newName,
             Long userId) {
 
@@ -121,7 +121,7 @@ public BranchRenameResponse renameBranch(Long documentId, Long branchId, String
      * 삭제하려는 브랜치는 메인 브랜치가 아니며 파생된 서브브랜치 또한 가지고 있지 않아야 합니다. 삭제 가능한 브랜치임을 확인 후 오직 해당 브랜치에서만 존재하는 블록을
      * 삭제한 후 나머지 브랜치 관련 정보를 삭제합니다.
      */
-    @Transactional
+    @Transactional(rollbackFor = Exception.class)
     public void deleteBranch(Long documentId, Long branchId, Long userId) {
 
         // 1. 브랜치 검증

src/main/java/io/ejangs/docsa/domain/branch/app/create/BranchCreateMongoTxService.java

@@ -16,7 +16,7 @@ public class BranchCreateMongoTxService {
     private final CommitContentAssembler commitContentAssembler;
     private final SaveContentRepository saveContentRepository;
 
-    @Transactional(transactionManager = "mongoTransactionManager")
+    @Transactional(transactionManager = "mongoTransactionManager", rollbackFor = Exception.class)
     public String createSaveContentFromCommit(String commitMongoId) {
         List<Map<String, Object>> blockContents = commitContentAssembler.assemble(commitMongoId);
 
@@ -26,4 +26,4 @@ public String createSaveContentFromCommit(String commitMongoId) {
 
         return saveContentRepository.save(saveContent).getId();
     }
-}
+}

src/main/java/io/ejangs/docsa/domain/branch/app/create/BranchCreateMySqlTxService.java

@@ -18,7 +18,7 @@ public class BranchCreateMySqlTxService {
     private final BranchQueryService branchQueryService;
     private final SaveQueryService saveQueryService;
 
-    @Transactional
+    @Transactional(rollbackFor = Exception.class)
     public BranchCreateResponse createBranchOrSave(BranchCreateContext context, String saveContentId) {
         Branch targetBranch = context.fromBranch();
 

src/main/java/io/ejangs/docsa/domain/commit/app/CommitService.java

@@ -84,7 +84,7 @@ private List<Map<String, Object>> getWholeContent(Long commitId) {
         return assembler.assemble(commit.getCommitMongoId());
     }
 
-    @Transactional
+    @Transactional(rollbackFor = Exception.class)
     public CreateCommitResponse mergeCommit(Long docId, MergeCommitRequest mergeRequest,
             Long userId) {
         MergeBranches mergeBranches = prepareMergeBranches(docId, mergeRequest, userId);

src/main/java/io/ejangs/docsa/domain/commit/app/create/CommitMongoTxService.java

@@ -25,7 +25,7 @@ public class CommitMongoTxService {
     private final BlockService blockService;
     private final CommitBlockSequenceRepository cbsRepository;
 
-    @Transactional(transactionManager = "mongoTransactionManager")
+    @Transactional(transactionManager = "mongoTransactionManager", rollbackFor = Exception.class)
     public MongoIdsDto createMongoPart(CreateCommitRequest request, String baseCommitCbsMongoId) {
         // 이번 커밋에서 "새로 저장된" 블록들 (Mongo insert)
         List<Block> newBlocks = blockService.saveBlocks(request.blocks());

src/main/java/io/ejangs/docsa/domain/commit/app/create/CommitMySqlTxService.java

@@ -31,7 +31,7 @@ public class CommitMySqlTxService {
     private final EdgeService edgeService;
     private final MongoDeleteOutboxFactory mongoDeleteOutboxFactory;
 
-    @Transactional
+    @Transactional(rollbackFor = Exception.class)
     public Commit createMySqlPart(Doc doc, Branch branch, CreateCommitRequest request, String commitCbsMongoId) {
         Commit newCommit = CommitMapper.toEntity(branch, request);
         newCommit.initializeCommitMongoId(commitCbsMongoId);

src/main/java/io/ejangs/docsa/domain/commit/app/merge/MergeMongoTxService.java

@@ -19,7 +19,7 @@ public class MergeMongoTxService {
     private final BlockService blockService;
     private final CommitQueryService commitQueryService;
 
-    @Transactional(transactionManager = "mongoTransactionManager")
+    @Transactional(transactionManager = "mongoTransactionManager", rollbackFor = Exception.class)
     public CommitMongoIdsDto createMongoPart(List<BlockDto> blocks) {
         List<Block> savedBlocks = blockService.saveBlocks(blocks);
 

src/main/java/io/ejangs/docsa/domain/commit/app/merge/MergeMySqlTxService.java

@@ -26,6 +26,7 @@
 import org.springframework.transaction.annotation.Transactional;
 
 @Service
+@Transactional(rollbackFor = Exception.class)
 @RequiredArgsConstructor
 public class MergeMySqlTxService {
 
@@ -35,7 +36,6 @@ public class MergeMySqlTxService {
     private final BranchQueryService branchQueryService;
     private final MongoDeleteOutboxFactory mongoDeleteOutboxFactory;
 
-    @Transactional
     public Commit createMySqlPart(Doc doc, Branch baseBranch, Branch targetBranch,
             MergeCommitRequest request, String commitMongoId) {
         Commit commit = CommitMapper.toEntity(targetBranch, request);

src/main/java/io/ejangs/docsa/domain/doc/app/DocService.java

@@ -80,7 +80,7 @@ public Page<DocPageResponse> searchList(Long userId, String keyword, Pageable pa
         return docListAssembler.assembleDocList(docs);
     }
 
-    @Transactional
+    @Transactional(rollbackFor = Exception.class)
     public DocTitleUpdateResponse updateTitle(Long userId, Long docId, DocTitleRequest request) {
         String title = request.title();
 
@@ -114,7 +114,7 @@ public GraphResponse getGraph(Long userId, Long documentId) {
     }
 
 
-    @Transactional
+    @Transactional(rollbackFor = Exception.class)
     public void delete(Long docId, Long userId) {
         User user = docQueryService.getUserOrThrow(userId);
         Doc doc = docQueryService.getByIdAndUserId(docId, userId);

src/main/java/io/ejangs/docsa/domain/save/app/SaveService.java

@@ -26,6 +26,7 @@
 
 @Slf4j
 @Service
+@Transactional(rollbackFor = Exception.class)
 @RequiredArgsConstructor
 public class SaveService {
 
@@ -41,7 +42,6 @@ public SaveGetResponse getSave(SaveIdentifierDto dto) {
         return SaveMapper.toSaveGetResponse(findSave.getUpdatedAt(), saveContent.getContent());
     }
 
-    @Transactional(rollbackFor = Exception.class)
     public SaveUpdateResponse updateSave(SaveIdentifierDto dto, SaveUpdateRequest request) {
         Save findSave = getValidSave(dto);
 
@@ -66,7 +66,6 @@ public SaveUpdateResponse updateSave(SaveIdentifierDto dto, SaveUpdateRequest re
         return SaveMapper.toSaveUpdateResponse(findSave.getUpdatedAt());
     }
 
-    @Transactional
     public void deleteSave(SaveIdentifierDto dto) {
         Save findSave = getValidSave(dto);
         Branch branch = findSave.getBranch();