From a68e64b600762fdf58c49cd3835a5123c483d5d8 Mon Sep 17 00:00:00 2001 From: Jayasudha Sundaram Date: Thu, 13 Mar 2025 17:18:05 -0400 Subject: [PATCH] added the topic and fix for wrong column name as per the payload --- .../service/InvestigationService.java | 3 ++- .../tables/042-create_nrt_treatment-001.sql | 18 +++--------------- 2 files changed, 5 insertions(+), 16 deletions(-) diff --git a/investigation-service/src/main/java/gov/cdc/etldatapipeline/investigation/service/InvestigationService.java b/investigation-service/src/main/java/gov/cdc/etldatapipeline/investigation/service/InvestigationService.java index 603af6e0..8d79c186 100644 --- a/investigation-service/src/main/java/gov/cdc/etldatapipeline/investigation/service/InvestigationService.java +++ b/investigation-service/src/main/java/gov/cdc/etldatapipeline/investigation/service/InvestigationService.java @@ -119,7 +119,8 @@ public class InvestigationService { "${spring.kafka.input.topic-name-ntf}", "${spring.kafka.input.topic-name-int}", "${spring.kafka.input.topic-name-ctr}", - "${spring.kafka.input.topic-name-vac}" + "${spring.kafka.input.topic-name-vac}", + "${spring.kafka.input.topic-name-tmt}" } ) public void processMessage(ConsumerRecord rec, diff --git a/liquibase-service/src/main/resources/db/rdb_modern/tables/042-create_nrt_treatment-001.sql b/liquibase-service/src/main/resources/db/rdb_modern/tables/042-create_nrt_treatment-001.sql index c08c83ab..24c07c37 100644 --- a/liquibase-service/src/main/resources/db/rdb_modern/tables/042-create_nrt_treatment-001.sql +++ b/liquibase-service/src/main/resources/db/rdb_modern/tables/042-create_nrt_treatment-001.sql @@ -214,35 +214,23 @@ IF EXISTS (SELECT 1 END; IF EXISTS(SELECT 1 FROM sys.columns WHERE name = N'LAST_CHG_TIME' AND Object_ID = Object_ID(N'nrt_treatment')) - AND NOT EXISTS(SELECT 1 - FROM sys.columns - WHERE name = N'last_chg_time' - AND Object_ID = Object_ID(N'nrt_treatment')) BEGIN - EXEC sp_rename 'nrt_treatment.LAST_CHG_TIME', 'last_chg_time', 'COLUMN'; + EXEC sp_rename 'nrt_treatment.LAST_CHG_TIME', 'last_change_time', 'COLUMN'; END; IF EXISTS(SELECT 1 FROM sys.columns WHERE name = N'LAST_CHG_USER_ID' AND Object_ID = Object_ID(N'nrt_treatment')) - AND NOT EXISTS(SELECT 1 - FROM sys.columns - WHERE name = N'last_chg_user_id' - AND Object_ID = Object_ID(N'nrt_treatment')) BEGIN - EXEC sp_rename 'nrt_treatment.LAST_CHG_USER_ID', 'last_chg_user_id', 'COLUMN'; + EXEC sp_rename 'nrt_treatment.LAST_CHG_USER_ID', 'last_change_user_id', 'COLUMN'; END; IF EXISTS(SELECT 1 FROM sys.columns WHERE name = N'VERSION_CTRL_NBR' AND Object_ID = Object_ID(N'nrt_treatment')) - AND NOT EXISTS(SELECT 1 - FROM sys.columns - WHERE name = N'version_ctrl_nbr' - AND Object_ID = Object_ID(N'nrt_treatment')) BEGIN - EXEC sp_rename 'nrt_treatment.VERSION_CTRL_NBR', 'version_ctrl_nbr', 'COLUMN'; + EXEC sp_rename 'nrt_treatment.VERSION_CTRL_NBR', 'version_control_number', 'COLUMN'; END; END;