gc/snp-batch-validation
1
0
포크 0
코드 이슈 풀 리퀘스트 위키 활동

🗃️ chunk size change

소스 검색
This commit is contained in:
hyojin kim 2025-12-23 11:28:17 +09:00
부모 bda2d812ff
커밋 bff4de17c7
2개의 변경된 파일과 8개의 추가작업 그리고 14개의 파일을 삭제
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/main/java/com/snp/batch/jobs/shipdetail/batch/config/ShipDetailUpdateJobConfig.java
파일 보기

@ -103,7 +103,7 @@ public class ShipDetailUpdateJobConfig extends BaseJobConfig<ShipDetailCompariso
@Override @Override
protected int getChunkSize() { protected int getChunkSize() {
return 1; // API에서 100개씩 가져오므로 chunk도 100으로 설정 return 20; // API에서 100개씩 가져오므로 chunk도 100으로 설정
} }
@Bean(name = "ShipDetailUpdateJob") @Bean(name = "ShipDetailUpdateJob")

20
src/main/java/com/snp/batch/jobs/shipdetail/batch/reader/ShipDetailUpdateDataReader.java
파일 보기

@ -47,7 +47,7 @@ public class ShipDetailUpdateDataReader extends BaseApiReader<ShipDetailComparis
// DB 해시값을 저장할 맵 // DB 해시값을 저장할 맵
private Map<String, String> dbMasterHashes; private Map<String, String> dbMasterHashes;
private int currentBatchIndex = 0; private int currentBatchIndex = 0;
private final int batchSize = 1; private final int batchSize = 20;
public ShipDetailUpdateDataReader(WebClient webClient, JdbcTemplate jdbcTemplate, ObjectMapper objectMapper,BatchDateService batchDateService) { public ShipDetailUpdateDataReader(WebClient webClient, JdbcTemplate jdbcTemplate, ObjectMapper objectMapper,BatchDateService batchDateService) {
super(webClient); super(webClient);
@ -261,18 +261,12 @@ public class ShipDetailUpdateDataReader extends BaseApiReader<ShipDetailComparis
.uri(url, uriBuilder -> uriBuilder .uri(url, uriBuilder -> uriBuilder
// 맵에서 파라미터 값을 동적으로 가져와 세팅 // 맵에서 파라미터 값을 동적으로 가져와 세팅
.queryParam("shipsCategory", params.get("shipsCategory")) .queryParam("shipsCategory", params.get("shipsCategory"))
// .queryParam("fromYear", params.get("fromYear")) .queryParam("fromYear", params.get("fromYear"))
// .queryParam("fromMonth", params.get("fromMonth")) .queryParam("fromMonth", params.get("fromMonth"))
// .queryParam("fromDay", params.get("fromDay")) .queryParam("fromDay", params.get("fromDay"))
// .queryParam("toYear", params.get("toYear")) .queryParam("toYear", params.get("toYear"))
// .queryParam("toMonth", params.get("toMonth")) .queryParam("toMonth", params.get("toMonth"))
// .queryParam("toDay", params.get("toDay")) .queryParam("toDay", params.get("toDay"))
.queryParam("fromYear", "2025")
.queryParam("fromMonth", "10")
.queryParam("fromDay", "15")
.queryParam("toYear", "2025")
.queryParam("toMonth", "12")
.queryParam("toDay", "17")
.build()) .build())
.retrieve() .retrieve()
.bodyToMono(ShipUpdateApiResponse.class) .bodyToMono(ShipUpdateApiResponse.class)