diff --git a/src/main/java/com/snp/batch/jobs/shipMovement/batch/reader/ShipMovementReader.java b/src/main/java/com/snp/batch/jobs/shipMovement/batch/reader/ShipMovementReader.java index cc1cca3..1277732 100644 --- a/src/main/java/com/snp/batch/jobs/shipMovement/batch/reader/ShipMovementReader.java +++ b/src/main/java/com/snp/batch/jobs/shipMovement/batch/reader/ShipMovementReader.java @@ -85,8 +85,8 @@ public class ShipMovementReader extends BaseApiReader { } 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"; diff --git a/src/main/java/com/snp/batch/jobs/shipMovementAnchorageCalls/batch/reader/AnchorageCallsReader.java b/src/main/java/com/snp/batch/jobs/shipMovementAnchorageCalls/batch/reader/AnchorageCallsReader.java index 9c3f782..60957d2 100644 --- a/src/main/java/com/snp/batch/jobs/shipMovementAnchorageCalls/batch/reader/AnchorageCallsReader.java +++ b/src/main/java/com/snp/batch/jobs/shipMovementAnchorageCalls/batch/reader/AnchorageCallsReader.java @@ -81,8 +81,8 @@ public class AnchorageCallsReader extends BaseApiReader { } 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"; diff --git a/src/main/java/com/snp/batch/jobs/shipMovementBerthCalls/batch/reader/BerthCallsReader.java b/src/main/java/com/snp/batch/jobs/shipMovementBerthCalls/batch/reader/BerthCallsReader.java index 38c8d8f..3d7f5c7 100644 --- a/src/main/java/com/snp/batch/jobs/shipMovementBerthCalls/batch/reader/BerthCallsReader.java +++ b/src/main/java/com/snp/batch/jobs/shipMovementBerthCalls/batch/reader/BerthCallsReader.java @@ -81,8 +81,8 @@ public class BerthCallsReader extends BaseApiReader { } 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 번호 전체 조회 diff --git a/src/main/java/com/snp/batch/jobs/shipMovementDarkActivity/batch/reader/DarkActivityReader.java b/src/main/java/com/snp/batch/jobs/shipMovementDarkActivity/batch/reader/DarkActivityReader.java index bb74cd0..7587fad 100644 --- a/src/main/java/com/snp/batch/jobs/shipMovementDarkActivity/batch/reader/DarkActivityReader.java +++ b/src/main/java/com/snp/batch/jobs/shipMovementDarkActivity/batch/reader/DarkActivityReader.java @@ -81,8 +81,8 @@ public class DarkActivityReader extends BaseApiReader { } 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 번호 전체 조회 diff --git a/src/main/java/com/snp/batch/jobs/shipMovementDestination/batch/reader/DestinationReader.java b/src/main/java/com/snp/batch/jobs/shipMovementDestination/batch/reader/DestinationReader.java index 3220826..a57adbe 100644 --- a/src/main/java/com/snp/batch/jobs/shipMovementDestination/batch/reader/DestinationReader.java +++ b/src/main/java/com/snp/batch/jobs/shipMovementDestination/batch/reader/DestinationReader.java @@ -79,8 +79,8 @@ public class DestinationReader extends BaseApiReader { } 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 번호 전체 조회 diff --git a/src/main/java/com/snp/batch/jobs/shipMovementStsOperations/batch/reader/StsOperationReader.java b/src/main/java/com/snp/batch/jobs/shipMovementStsOperations/batch/reader/StsOperationReader.java index a6c286c..5aff9b9 100644 --- a/src/main/java/com/snp/batch/jobs/shipMovementStsOperations/batch/reader/StsOperationReader.java +++ b/src/main/java/com/snp/batch/jobs/shipMovementStsOperations/batch/reader/StsOperationReader.java @@ -81,8 +81,8 @@ public class StsOperationReader extends BaseApiReader { } 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 번호 전체 조회 diff --git a/src/main/java/com/snp/batch/jobs/shipMovementTerminalCalls/batch/reader/TerminalCallsReader.java b/src/main/java/com/snp/batch/jobs/shipMovementTerminalCalls/batch/reader/TerminalCallsReader.java index 9018360..62a9061 100644 --- a/src/main/java/com/snp/batch/jobs/shipMovementTerminalCalls/batch/reader/TerminalCallsReader.java +++ b/src/main/java/com/snp/batch/jobs/shipMovementTerminalCalls/batch/reader/TerminalCallsReader.java @@ -81,8 +81,8 @@ public class TerminalCallsReader extends BaseApiReader { } 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 번호 전체 조회 diff --git a/src/main/java/com/snp/batch/jobs/shipMovementTransits/batch/reader/TransitsReader.java b/src/main/java/com/snp/batch/jobs/shipMovementTransits/batch/reader/TransitsReader.java index 375b14f..daf2b94 100644 --- a/src/main/java/com/snp/batch/jobs/shipMovementTransits/batch/reader/TransitsReader.java +++ b/src/main/java/com/snp/batch/jobs/shipMovementTransits/batch/reader/TransitsReader.java @@ -79,8 +79,8 @@ public class TransitsReader extends BaseApiReader { } 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 번호 전체 조회