Merge pull request 'refactor(risk): RiskDetailImportJob IMO 조회 대상을 tb_ship_default_info로 변경' (#84) from feature/ISSUE-81-risk-detail-imo-source-change into develop

docs/RELEASE-NOTES.md

@@ -61,6 +61,7 @@
 - 실패 건 수동 재수집 시 414 Request-URI Too Long 오류 수정 (#71)
 
 ### 변경
+- RiskDetailImportJob IMO 조회 대상을 tb_ship_default_info로 변경 (#81)
 - 파티션 스텝 프로세스 공통 모듈화 (StringListPartitioner, BasePartitionedJobConfig, LastExecutionUpdateTasklet) (#73)
 - 13개 Job Config의 인라인 LastExecutionUpdateTasklet을 공통 모듈로 교체 (#74)
 - 재수집 실패건 추적 기준 sourceStepExecutionId → sourceJobExecutionId로 변경 (#64)

src/main/java/com/snp/batch/jobs/risk/batch/config/RiskDetailImoFetchTasklet.java

@@ -12,18 +12,18 @@ import java.util.List;
 
 /**
  * Risk 상세 데이터 수집을 위한 IMO 목록 조회 Tasklet.
- * std_snp_svc.tb_ship_risk_info 테이블에서 전체 imo_no를 오름차순으로 조회하여
+ * std_snp_data.tb_ship_default_info 테이블에서 전체 imo_no를 오름차순으로 조회하여
  * JobExecutionContext에 저장.
  */
 @Slf4j
 public class RiskDetailImoFetchTasklet implements Tasklet {
 
     private final JdbcTemplate jdbcTemplate;
-    private final String serviceSchema;
+    private final String targetSchema;
 
-    public RiskDetailImoFetchTasklet(JdbcTemplate jdbcTemplate, String serviceSchema) {
+    public RiskDetailImoFetchTasklet(JdbcTemplate jdbcTemplate, String targetSchema) {
         this.jdbcTemplate = jdbcTemplate;
-        this.serviceSchema = serviceSchema;
+        this.targetSchema = targetSchema;
     }
 
     @Override
@@ -32,8 +32,8 @@ public class RiskDetailImoFetchTasklet implements Tasklet {
                 .getStepExecution().getJobExecution();
 
         String sql = String.format(
-                "SELECT DISTINCT imo_no FROM %s.tb_ship_risk_info WHERE imo_no IS NOT NULL ORDER BY imo_no ASC",
+                "SELECT DISTINCT imo_no FROM %s.tb_ship_default_info WHERE imo_no IS NOT NULL ORDER BY imo_no ASC",
-                serviceSchema);
+                targetSchema);
 
         List<String> imoNumbers = jdbcTemplate.queryForList(sql, String.class);
 
@@ -42,8 +42,8 @@ public class RiskDetailImoFetchTasklet implements Tasklet {
             jobExecution.getExecutionContext().putString("allImoNumbers", String.join(",", imoNumbers));
         }
 
-        log.info("[RiskDetailImoFetchTasklet] IMO {} 건 조회 완료 (from {}.tb_ship_risk_info)",
+        log.info("[RiskDetailImoFetchTasklet] IMO {} 건 조회 완료 (from {}.tb_ship_default_info)",
-                imoNumbers.size(), serviceSchema);
+                imoNumbers.size(), targetSchema);
 
         return RepeatStatus.FINISHED;
     }

src/main/java/com/snp/batch/jobs/risk/batch/config/RiskDetailImportJobConfig.java

@@ -47,9 +47,6 @@ public class RiskDetailImportJobConfig extends BasePartitionedJobConfig<RiskDto,
     @Value("${app.batch.target-schema.name}")
     private String targetSchema;
 
-    @Value("${app.batch.service-schema.name}")
-    private String serviceSchema;
-
     @Value("${app.batch.risk-detail.partition-count:4}")
     private int partitionCount;
 
@@ -94,7 +91,7 @@ public class RiskDetailImportJobConfig extends BasePartitionedJobConfig<RiskDto,
 
     @Override
     protected int getChunkSize() {
-        return 100;
+        return 5000;
     }
 
     // ========================================
@@ -119,7 +116,7 @@ public class RiskDetailImportJobConfig extends BasePartitionedJobConfig<RiskDto,
 
     @Bean
     public Tasklet riskDetailImoFetchTasklet() {
-        return new RiskDetailImoFetchTasklet(jdbcTemplate, serviceSchema);
+        return new RiskDetailImoFetchTasklet(jdbcTemplate, targetSchema);
     }
 
     @Bean(name = "RiskDetailImoFetchStep")