; WITH valid_positions AS (
SELECT MMSI
, Message_ID
, "Time"
, Latitude
, Longitude
FROM dbo.DecodedCSVMessages_Staging
WHERE Latitude > 55
AND Latitude < 85
AND Longitude > 50
AND Longitude < 141
)
, positions AS (
SELECT MMSI
, Message_ID
, "Time"
, Latitude
, Longitude
FROM dbo.DecodedCSVMessages_Staging
WHERE Message_ID IN (1, 3)
AND EXISTS (
SELECT *
FROM valid_positions
WHERE valid_positions.MMSI = DecodedCSVMessages_Staging.MMSI
)
)
, details AS (
SELECT MMSI
, Ship_Type
, Vessel_Name
, Row_Number() OVER (PARTITION BY MMSI ORDER BY "Time" DESC) As row_num
FROM dbo.DecodedCSVMessages_Staging
WHERE Message_ID = 5
)
SELECT positions.MMSI
, positions.Message_ID
, positions."Time"
, details.Ship_Type
, details.Vessel_Name
, positions.Latitude
, positions.Longitude
FROM positions
INNER
JOIN details
ON details.MMSI = positions.MMSI
AND details.row_num = 1 -- Limit to "latest" ship details per MMSI
Hiện đã có CTE thứ 3 đang được sử dụng.
-
valid_positions
: bất kỳ ghi lại nơi các tiêu chí phối hợp của bạn, cho bất kỳMessage_ID
nào 2) -
positions
:tất cả các bản ghi trong đóMessage_ID
bằng 1 hoặc 3 và có một bản ghi trongMMSI
tương ứng trongvalid_positions
-
details
:không thay đổi so với trước. Hiển thị chi tiết tàu / tàu "mới nhất" (Message_ID
=5)