update query

CDCgov · Oct 14, 2024 · 873ccf2 · 873ccf2
1 parent 641d03f
commit 873ccf2
Show file tree

Hide file tree

Showing 4 changed files with 7,525 additions and 2,621 deletions.
diff --git a/nnd-data-exchange-service/src/main/resources/query/create/generate_data_rdb.sql b/nnd-data-exchange-service/src/main/resources/query/create/generate_data_rdb.sql
@@ -426,7 +426,7 @@ VALUES
 INSERT INTO [RDB].[dbo].[data_sync_config]
 (table_name, source_db, query, query_with_null_timestamp, query_count, query_with_pagination)
 VALUES
-    ('JURISDICTION_CODE', 'RDB',
+    ('JURISDICTION_CODE', 'SRTE',
     'SELECT * FROM JURISDICTION_CODE;',
     NULL,
     'SELECT COUNT(*) FROM JURISDICTION_CODE;',
@@ -438,3 +438,68 @@ VALUES
     WHERE RowNum BETWEEN :startRow AND :endRow;')
 ;
 
+INSERT INTO [RDB].[dbo].[data_sync_config]
+(table_name, source_db, query, query_with_null_timestamp, query_count, query_with_pagination)
+VALUES
+    ('PERTUSSIS_SUSPECTED_SOURCE_GRP', 'RDB',
+    'SELECT PERTUSSIS_SUSPECTED_SOURCE_GRP.*
+     FROM PERTUSSIS_SUSPECTED_SOURCE_GRP
+     JOIN PERTUSSIS_CASE
+     ON PERTUSSIS_CASE.PERTUSSIS_SUSPECT_SRC_GRP_KEY = PERTUSSIS_SUSPECTED_SOURCE_GRP.PERTUSSIS_SUSPECT_SRC_GRP_KEY
+     JOIN INVESTIGATION
+     ON INVESTIGATION.INVESTIGATION_KEY = PERTUSSIS_CASE.INVESTIGATION_KEY
+     WHERE INVESTIGATION.LAST_CHG_TIME :operator :timestamp;',
+    NULL,
+    'SELECT COUNT(*)
+     FROM PERTUSSIS_SUSPECTED_SOURCE_GRP
+     JOIN PERTUSSIS_CASE
+     ON PERTUSSIS_CASE.PERTUSSIS_SUSPECT_SRC_GRP_KEY = PERTUSSIS_SUSPECTED_SOURCE_GRP.PERTUSSIS_SUSPECT_SRC_GRP_KEY
+     JOIN INVESTIGATION
+     ON INVESTIGATION.INVESTIGATION_KEY = PERTUSSIS_CASE.INVESTIGATION_KEY
+     WHERE INVESTIGATION.LAST_CHG_TIME :operator :timestamp;',
+    'WITH PaginatedResults AS (
+        SELECT PERTUSSIS_SUSPECTED_SOURCE_GRP.*, ROW_NUMBER() OVER (ORDER BY INVESTIGATION.LAST_CHG_TIME ASC) AS RowNum
+        FROM PERTUSSIS_SUSPECTED_SOURCE_GRP
+        JOIN PERTUSSIS_CASE
+        ON PERTUSSIS_CASE.PERTUSSIS_SUSPECT_SRC_GRP_KEY = PERTUSSIS_SUSPECTED_SOURCE_GRP.PERTUSSIS_SUSPECT_SRC_GRP_KEY
+        JOIN INVESTIGATION
+        ON INVESTIGATION.INVESTIGATION_KEY = PERTUSSIS_CASE.INVESTIGATION_KEY
+        WHERE INVESTIGATION.LAST_CHG_TIME :operator :timestamp
+    )
+    SELECT * FROM PaginatedResults
+    WHERE RowNum BETWEEN :startRow AND :endRow;')
+;
+
+
+INSERT INTO [RDB].[dbo].[data_sync_config]
+(table_name, source_db, query, query_with_null_timestamp, query_count, query_with_pagination)
+VALUES
+    ('PERTUSSIS_TREATMENT_GROUP', 'RDB',
+    'SELECT PERTUSSIS_TREATMENT_GROUP.*
+     FROM PERTUSSIS_TREATMENT_GROUP
+     JOIN PERTUSSIS_CASE
+     ON PERTUSSIS_CASE.PERTUSSIS_TREATMENT_GRP_KEY = PERTUSSIS_TREATMENT_GROUP.PERTUSSIS_TREATMENT_GRP_KEY
+     JOIN INVESTIGATION
+     ON INVESTIGATION.INVESTIGATION_KEY = PERTUSSIS_CASE.INVESTIGATION_KEY
+     WHERE INVESTIGATION.LAST_CHG_TIME :operator :timestamp;',
+    NULL,
+    'SELECT COUNT(*)
+     FROM PERTUSSIS_TREATMENT_GROUP
+     JOIN PERTUSSIS_CASE
+     ON PERTUSSIS_CASE.PERTUSSIS_TREATMENT_GRP_KEY = PERTUSSIS_TREATMENT_GROUP.PERTUSSIS_TREATMENT_GRP_KEY
+     JOIN INVESTIGATION
+     ON INVESTIGATION.INVESTIGATION_KEY = PERTUSSIS_CASE.INVESTIGATION_KEY
+     WHERE INVESTIGATION.LAST_CHG_TIME :operator :timestamp;',
+    'WITH PaginatedResults AS (
+        SELECT PERTUSSIS_TREATMENT_GROUP.*, ROW_NUMBER() OVER (ORDER BY INVESTIGATION.LAST_CHG_TIME ASC) AS RowNum
+        FROM PERTUSSIS_TREATMENT_GROUP
+        JOIN PERTUSSIS_CASE
+        ON PERTUSSIS_CASE.PERTUSSIS_TREATMENT_GRP_KEY = PERTUSSIS_TREATMENT_GROUP.PERTUSSIS_TREATMENT_GRP_KEY
+        JOIN INVESTIGATION
+        ON INVESTIGATION.INVESTIGATION_KEY = PERTUSSIS_CASE.INVESTIGATION_KEY
+        WHERE INVESTIGATION.LAST_CHG_TIME :operator :timestamp
+    )
+    SELECT * FROM PaginatedResults
+    WHERE RowNum BETWEEN :startRow AND :endRow;')
+;
+
diff --git a/nnd-data-poll-service/src/main/resources/sql/cleanup/clean_srte.sql b/nnd-data-poll-service/src/main/resources/sql/cleanup/clean_srte.sql
@@ -2,4 +2,3 @@ DELETE FROM  Condition_code;
 DELETE FROM  Code_to_condition;
 DELETE FROM  Jurisdiction_code;
 DELETE FROM  Program_area_code;
-DELETE FROM JURISDICTION_CODE;