mindol1004/Oneul
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

batch delete posts in query db

Browse Source
This commit is contained in:
jinho jeong
2022-06-05 15:10:32 +09:00
parent d2f1602cd6
commit 004d4bf5b7
2 changed files with 12 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
src/main/java/com/example/oneul/global/config/BatchConfig.java
View File

@@ -2,9 +2,7 @@ package com.example.oneul.global.config;
import java.time.LocalDateTime;
import java.util.List;
import com.example.oneul.domain.post.dao.command.PostCommandRepository;
import com.example.oneul.domain.post.domain.Post;
import java.util.stream.Collectors;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -17,6 +15,10 @@ import org.springframework.batch.repeat.RepeatStatus;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import com.example.oneul.domain.post.dao.command.PostCommandRepository;
import com.example.oneul.domain.post.dao.query.PostQueryRepository;
import com.example.oneul.domain.post.domain.Post;
@Configuration
@EnableBatchProcessing
public class BatchConfig {
@@ -26,6 +28,7 @@ public class BatchConfig {
private final Logger log = LoggerFactory.getLogger(BatchConfig.class);
private PostCommandRepository postCommandRepository;
private PostQueryRepository postQueryRepository;
public BatchConfig(JobBuilderFactory jobBuilderFactory, StepBuilderFactory stepBuilderFactory, PostCommandRepository postCommandRepository){
this.jobBuilderFactory = jobBuilderFactory;
@@ -51,8 +54,12 @@ public class BatchConfig {
posts.stream().forEach(post -> {
post.setDeletedAt(expiredAt);
});
// TODO: Query DB 한테 알려줘야함
postCommandRepository.saveAll(posts);
// TODO: Message Queue로 전환
postQueryRepository.deleteAllById(posts.stream()
.map(post -> post.getId())
.collect(Collectors.toList()));
log.info(expiredAt + " posts(" + posts.size() + ") are deleted.");
return RepeatStatus.FINISHED;
}).build();

2
src/main/java/com/example/oneul/global/config/MongoConfig.java
View File

@@ -19,7 +19,7 @@ public class MongoConfig {
@Value("${spring.data.mongodb.host}")
private String host;
@Value("${spring.data.mongodb.port}")
private Integer port;
private int port;
@Value("${spring.data.mongodb.database}")
private String database;