Skip to content

Commit

Permalink
updated nrt_observation_coded query (#52)
Browse files Browse the repository at this point in the history
  • Loading branch information
ndduc01 authored Oct 3, 2024
1 parent b14cf89 commit 9aea3ea
Showing 1 changed file with 34 additions and 0 deletions.
Original file line number Diff line number Diff line change
@@ -0,0 +1,34 @@
-- Removing existing nrt_obs_coded query, which wasn't correct
DELETE
FROM [dbo].[data_sync_config]
WHERE table_name = 'NRT_OBSERVATION_CODED';

-- Inserting valid query back into the config
INSERT INTO [dbo].[data_sync_config]
(table_name, source_db, query, query_with_null_timestamp, query_count, query_with_pagination)
VALUES
('NRT_OBSERVATION_CODED', 'RDB_MODERN', 'SELECT rdb_modern.dbo.nrt_observation_coded.*
FROM rdb_modern.dbo.nrt_observation_coded
JOIN rdb_modern.dbo.nrt_observation
ON rdb_modern.dbo.nrt_observation_coded.observation_uid = rdb_modern.dbo.nrt_observation.observation_uid
WHERE rdb_modern.dbo.nrt_observation_coded.refresh_datetime :operator :timestamp
OR rdb_modern.dbo.nrt_observation.last_chg_time :operator :timestamp
OR rdb_modern.dbo.nrt_observation.refresh_datetime :operator :timestamp;', NULL, 'SELECT COUNT(*)
FROM rdb_modern.dbo.nrt_observation_coded
JOIN rdb_modern.dbo.nrt_observation
ON rdb_modern.dbo.nrt_observation_coded.observation_uid = rdb_modern.dbo.nrt_observation.observation_uid
WHERE rdb_modern.dbo.nrt_observation_coded.refresh_datetime :operator :timestamp
OR rdb_modern.dbo.nrt_observation.last_chg_time :operator :timestamp
OR rdb_modern.dbo.nrt_observation.refresh_datetime :operator :timestamp;', 'WITH PaginatedResults AS (
SELECT rdb_modern.dbo.nrt_observation_coded.*,
ROW_NUMBER() OVER (ORDER BY (SELECT NULL)) AS RowNum
FROM rdb_modern.dbo.nrt_observation_coded
JOIN rdb_modern.dbo.nrt_observation
ON rdb_modern.dbo.nrt_observation_coded.observation_uid = rdb_modern.dbo.nrt_observation.observation_uid
WHERE rdb_modern.dbo.nrt_observation_coded.refresh_datetime :operator :timestamp
OR rdb_modern.dbo.nrt_observation.last_chg_time :operator :timestamp
OR rdb_modern.dbo.nrt_observation.refresh_datetime :operator :timestamp
)
SELECT * FROM PaginatedResults
WHERE RowNum BETWEEN :startRow AND :endRow;')
;

0 comments on commit 9aea3ea

Please sign in to comment.