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

reader 수정

소스 검색
This commit is contained in:
Kim JiMyeung 2025-12-12 11:20:13 +09:00
부모 f2970872fd
커밋 c46a62268c
8개의 변경된 파일과 16개의 추가작업 그리고 16개의 파일을 삭제
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/main/java/com/snp/batch/jobs/shipMovement/batch/reader/ShipMovementReader.java
파일 보기

@ -85,8 +85,8 @@ public class ShipMovementReader extends BaseApiReader<PortCallsDto> {
}
private static final String GET_ALL_IMO_QUERY =
// "SELECT imo_number FROM ship_data ORDER BY id";
"SELECT imo_number FROM snp_data.ship_data where imo_number > (select max(imo) from snp_data.t_ship_stpov_info) ORDER BY imo_number";
"SELECT imo_number FROM ship_data ORDER BY id";
// "SELECT imo_number FROM snp_data.ship_data where imo_number > (select max(imo) from snp_data.t_ship_stpov_info) ORDER BY imo_number";
private static final String FETCH_ALL_HASHES_QUERY =
"SELECT imo_number, ship_detail_hash FROM ship_detail_hash_json ORDER BY imo_number";

4
src/main/java/com/snp/batch/jobs/shipMovementAnchorageCalls/batch/reader/AnchorageCallsReader.java
파일 보기

@ -81,8 +81,8 @@ public class AnchorageCallsReader extends BaseApiReader<AnchorageCallsDto> {
}
private static final String GET_ALL_IMO_QUERY =
// "SELECT imo_number FROM ship_data ORDER BY id";
"SELECT imo_number FROM snp_data.ship_data where imo_number > (select max(imo) from snp_data.t_anchoragecall) ORDER BY imo_number";
"SELECT imo_number FROM ship_data ORDER BY id";
// "SELECT imo_number FROM snp_data.ship_data where imo_number > (select max(imo) from snp_data.t_anchoragecall) ORDER BY imo_number";
private static final String FETCH_ALL_HASHES_QUERY =
"SELECT imo_number, ship_detail_hash FROM ship_detail_hash_json ORDER BY imo_number";

4
src/main/java/com/snp/batch/jobs/shipMovementBerthCalls/batch/reader/BerthCallsReader.java
파일 보기

@ -81,8 +81,8 @@ public class BerthCallsReader extends BaseApiReader<BerthCallsDto> {
}
private static final String GET_ALL_IMO_QUERY =
// "SELECT imo_number FROM ship_data ORDER BY id";
"SELECT imo_number FROM snp_data.ship_data where imo_number > (select max(imo) from snp_data.t_berthcall) ORDER BY imo_number";
"SELECT imo_number FROM ship_data ORDER BY id";
// "SELECT imo_number FROM snp_data.ship_data where imo_number > (select max(imo) from snp_data.t_berthcall) ORDER BY imo_number";
/**
* 최초 1회만 실행: ship_data 테이블에서 IMO 번호 전체 조회

4
src/main/java/com/snp/batch/jobs/shipMovementDarkActivity/batch/reader/DarkActivityReader.java
파일 보기

@ -81,8 +81,8 @@ public class DarkActivityReader extends BaseApiReader<DarkActivityDto> {
}
private static final String GET_ALL_IMO_QUERY =
// "SELECT imo_number FROM ship_data ORDER BY id";
"SELECT imo_number FROM snp_data.ship_data where imo_number > (select max(imo) from snp_data.t_darkactivity) ORDER BY imo_number";
"SELECT imo_number FROM ship_data ORDER BY id";
// "SELECT imo_number FROM snp_data.ship_data where imo_number > (select max(imo) from snp_data.t_darkactivity) ORDER BY imo_number";
/**
* 최초 1회만 실행: ship_data 테이블에서 IMO 번호 전체 조회

4
src/main/java/com/snp/batch/jobs/shipMovementDestination/batch/reader/DestinationReader.java
파일 보기

@ -79,8 +79,8 @@ public class DestinationReader extends BaseApiReader<DestinationDto> {
}
private static final String GET_ALL_IMO_QUERY =
// "SELECT imo_number FROM ship_data ORDER BY id";
"SELECT imo_number FROM snp_data.ship_data where imo_number > (select max(imo) from snp_data.t_destination) ORDER BY imo_number";
"SELECT imo_number FROM ship_data ORDER BY id";
// "SELECT imo_number FROM snp_data.ship_data where imo_number > (select max(imo) from snp_data.t_destination) ORDER BY imo_number";
/**
* 최초 1회만 실행: ship_data 테이블에서 IMO 번호 전체 조회

4
src/main/java/com/snp/batch/jobs/shipMovementStsOperations/batch/reader/StsOperationReader.java
파일 보기

@ -81,8 +81,8 @@ public class StsOperationReader extends BaseApiReader<StsOperationDto> {
}
private static final String GET_ALL_IMO_QUERY =
// "SELECT imo_number FROM ship_data ORDER BY id";
"SELECT imo_number FROM snp_data.ship_data where imo_number > (select max(imo) from snp_data.t_stsoperation) ORDER BY imo_number";
"SELECT imo_number FROM ship_data ORDER BY id";
// "SELECT imo_number FROM snp_data.ship_data where imo_number > (select max(imo) from snp_data.t_stsoperation) ORDER BY imo_number";
/**
* 최초 1회만 실행: ship_data 테이블에서 IMO 번호 전체 조회

4
src/main/java/com/snp/batch/jobs/shipMovementTerminalCalls/batch/reader/TerminalCallsReader.java
파일 보기

@ -81,8 +81,8 @@ public class TerminalCallsReader extends BaseApiReader<TerminalCallsDto> {
}
private static final String GET_ALL_IMO_QUERY =
// "SELECT imo_number FROM ship_data ORDER BY id";
"SELECT imo_number FROM snp_data.ship_data where imo_number > (select max(imo) from snp_data.t_terminalcall) ORDER BY imo_number";
"SELECT imo_number FROM ship_data ORDER BY id";
// "SELECT imo_number FROM snp_data.ship_data where imo_number > (select max(imo) from snp_data.t_terminalcall) ORDER BY imo_number";
/**
* 최초 1회만 실행: ship_data 테이블에서 IMO 번호 전체 조회

4
src/main/java/com/snp/batch/jobs/shipMovementTransits/batch/reader/TransitsReader.java
파일 보기

@ -79,8 +79,8 @@ public class TransitsReader extends BaseApiReader<TransitsDto> {
}
private static final String GET_ALL_IMO_QUERY =
// "SELECT imo_number FROM ship_data ORDER BY id";
"SELECT imo_number FROM snp_data.ship_data where imo_number > (select max(imo) from snp_data.t_transit) ORDER BY imo_number";
"SELECT imo_number FROM ship_data ORDER BY id";
// "SELECT imo_number FROM snp_data.ship_data where imo_number > (select max(imo) from snp_data.t_transit) ORDER BY imo_number";
/**
* 최초 1회만 실행: ship_data 테이블에서 IMO 번호 전체 조회