⚡ MarkSphere v1.0.17

데이터베이스 정리 스케줄러 통합

Author: son0307

src/main/java/com/sonkim/bookmarking/common/service/DataCleanupScheduler.java

@@ -0,0 +1,20 @@
+package com.sonkim.bookmarking.common.service;
+
+import lombok.RequiredArgsConstructor;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Component;
+
+@Component
+@RequiredArgsConstructor
+public class DataCleanupScheduler {
+
+    private final DatabaseCleanupService cleanupService;
+
+    @Scheduled(cron = "0 0 4 * * *")
+    public void scheduleDatabaseCleanup() {
+        cleanupService.runCleanup("CLEANUP_UNUSED_TAGS");
+        cleanupService.runCleanup("CLEANUP_PENDING_TEAMS");
+        cleanupService.runCleanup("CLEANUP_ORPHANED_TEAMS");
+    }
+
+}

src/main/java/com/sonkim/bookmarking/common/service/DatabaseCleanupService.java

@@ -0,0 +1,59 @@
+package com.sonkim.bookmarking.common.service;
+
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.jdbc.core.JdbcTemplate;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+@Service
+@RequiredArgsConstructor
+@Slf4j
+public class DatabaseCleanupService {
+
+    private final JdbcTemplate jdbcTemplate;
+
+    @Transactional
+    public void runCleanup(String taskType) {
+        log.info(">>>>> Scheduler Job Start: {}", taskType);
+        int deletedCount;
+
+        switch (taskType) {
+            case "CLEANUP_UNUSED_TAGS" -> deletedCount = deleteUnusedTags();
+            case "CLEANUP_PENDING_TEAMS" -> deletedCount = deletePendingTeams();
+            case "CLEANUP_ORPHANED_TEAMS" -> deletedCount = deleteOrphanedTeams();
+            default -> throw new IllegalArgumentException("Invalid taskType: " + taskType);
+        }
+
+        log.info("TaskType: {} Completed, Deleted: {}", taskType, deletedCount);
+    }
+
+    private int deleteUnusedTags() {
+        String sql = "DELETE t FROM tag t " +
+                "LEFT JOIN bookmark_tag bt ON t.id = bt.tag_id " +
+                "WHERE bt.tag_id IS NULL";
+
+        return jdbcTemplate.update(sql);
+    }
+
+    private int deletePendingTeams() {
+        String sql = "DELETE FROM team " +
+                "WHERE status = 'PENDING_DELETION' " +
+                "AND deletion_scheduled_at < NOW()";
+
+        return jdbcTemplate.update(sql);
+    }
+
+    private int deleteOrphanedTeams() {
+        String sql = "DELETE t FROM team t " +
+                "WHERE NOT EXISTS (" +
+                "  SELECT 1 " +
+                "  FROM team_member tm " +
+                "  JOIN user u ON tm.account_id = u.id " +
+                "  WHERE tm.team_id = t.id " +
+                "  AND u.user_status = 'ACTIVE'" +
+                ")";
+
+        return jdbcTemplate.update(sql);
+    }
+}