From 2cdb65c3e88b628377e5049142cd6014704cad17 Mon Sep 17 00:00:00 2001 From: Ravindran Seshadri <109151953+rseshadri99@users.noreply.github.com> Date: Sun, 9 Mar 2025 00:05:40 -0500 Subject: [PATCH 1/4] Add the dyn datamart procedure for investigation form data post processing. This procedure migrates the classic etl to rtr framework with event based Ids to be processed and removes any reference to odse Add the dyn datamart procedure for investigation form data post processing. This procedure migrates the classic etl to rtr framework with event based Ids to be processed and removes any reference to odse --- ...-sp_dyn_dm_invest_form_post_processing.sql | 469 ++++++++++++++++++ .../db.rdb_modern.changelog-16.1.yaml | 8 + ...dyn_dm_invest_form_post_processing-001.sql | 469 ++++++++++++++++++ 3 files changed, 946 insertions(+) create mode 100644 db/upgrade/rdb_modern/routines/115-sp_dyn_dm_invest_form_post_processing.sql create mode 100644 liquibase-service/src/main/resources/db/rdb_modern/routines/115-sp_dyn_dm_invest_form_post_processing-001.sql diff --git a/db/upgrade/rdb_modern/routines/115-sp_dyn_dm_invest_form_post_processing.sql b/db/upgrade/rdb_modern/routines/115-sp_dyn_dm_invest_form_post_processing.sql new file mode 100644 index 00000000..747b0272 --- /dev/null +++ b/db/upgrade/rdb_modern/routines/115-sp_dyn_dm_invest_form_post_processing.sql @@ -0,0 +1,469 @@ + + +CREATE or alter PROCEDURE [dbo].sp_dyn_dm_invest_form_post_processing +-- call this after populating <> + + @batch_id BIGINT, + @DATAMART_NAME VARCHAR(100), + @phc_id_list nvarchar(max) + AS +BEGIN + BEGIN TRY + + -- DECLARE @batch_id BIGINT = 999; DECLARE @DATAMART_NAME VARCHAR(100) = 'CONG_SYPHILIS'; + DECLARE @RowCount_no INT ; + DECLARE @Proc_Step_no FLOAT = 0 ; + DECLARE @Proc_Step_Name VARCHAR(200) = '' ; + DECLARE @batch_start_time datetime = null ; + DECLARE @batch_end_time datetime = null ; + DECLARE @nbs_page_form_cd varchar(200)='' + + SET @Proc_Step_no = 1; + SET @Proc_Step_Name = 'SP_Start'; + + + + + BEGIN TRANSACTION; + + INSERT INTO dbo.job_flow_log ( + batch_id + ,[Dataflow_Name] + ,[package_Name] + ,[Status_Type] + ,[step_number] + ,[step_name] + ,[row_count] + ) + VALUES + ( + @batch_id + ,'DYNAMIC_DATAMART' + ,'RDB.DBO.DynDM_INVEST_FORM_PROC '+@DATAMART_NAME + ,'START' + ,@Proc_Step_no + ,@Proc_Step_Name + ,0 + ); + + COMMIT TRANSACTION ; + + + + BEGIN TRANSACTION; + + + SET @Proc_Step_no = @Proc_Step_no + 1; + SET @Proc_Step_Name = 'GENERATING tmp_DynDm_SUMM_DATAMART'; + + + + + + --DROP TABLE RDB.DBO.dbo.tmp_DynDm_SUMM_DATAMART; + + +/*Creates a summ_datamart with patient key, investigation key and disease group code*/ + --CREATE TABLE dbo.SUMM_DATAMART AS + + /*IF OBJECT_ID('#tmp_DynDm_SUMM_DATAMART', 'U') IS NOT NULL + drop table #tmp_DynDm_SUMM_DATAMART; + */ + +SET @nbs_page_form_cd = (SELECT FORM_CD FROM dbo.v_nbs_page WHERE DATAMART_NM=@DATAMART_NAME) + + SELECT isd.PATIENT_KEY AS PATIENT_KEY, isd.INVESTIGATION_KEY, c.DISEASE_GRP_CD + into #tmp_DynDm_SUMM_DATAMART + FROM dbo.INV_SUMM_DATAMART isd with ( nolock) + INNER JOIN dbo.v_condition_dim c with ( nolock) ON isd.DISEASE_CD = c.CONDITION_CD and c.DISEASE_GRP_CD = @nbs_page_form_cd + INNER JOIN dbo.nrt_investigation_key nrt_inv_key with (nolock) ON isd.investigation_key = nrt_inv_key.d_investigation_key + and nrt_inv_key.case_uid in (SELECT value FROM STRING_SPLIT(@phc_id_list, ',')); + + + + SELECT @ROWCOUNT_NO = @@ROWCOUNT; + + + INSERT INTO dbo.job_flow_log ( batch_id ,[Dataflow_Name] ,[package_Name] ,[Status_Type] ,[step_number] ,[step_name] ,[row_count] ) + VALUES ( @batch_id ,'DYNAMIC_DATAMART' ,'RDB.DBO.DynDM_INVEST_FORM_PROC '+@DATAMART_NAME ,'START' ,@Proc_Step_no ,@Proc_Step_Name ,@ROWCOUNT_NO ); + + + + COMMIT TRANSACTION; + + + + + + BEGIN TRANSACTION; + + SET @Proc_Step_no = @Proc_Step_no + 1; + SET @Proc_Step_Name = 'GENERATING tmp_DynDm_Investigation_Data'; + + +/*Make a list of rdb_column_nm separated by ,*/ + +--DX select * from #tmp_DynDm_INV_METADATA ; + + DECLARE @listStr VARCHAR(MAX) +/* + + +SELECT @listStr = COALESCE(@listStr+',' ,'') + RDB_COLUMN_NM + ' '+ coalesce(USER_DEFINED_COLUMN_NM,'') +FROM #tmp_DynDm_INV_METADATA; +*/ + + +/*It creates a new table with a list of all the rdb column name plus the investigation key*/ +-- CREATE TABLE INVESTIGATION_DATA AS + +/* +select DISTINCT FORM_CD, DATAMART_NM, RDB_TABLE_NM, RDB_COLUMN_NM,USER_DEFINED_COLUMN_NM , rdb_column_nm_list + -- into #tmp_DynDm_INV_METADATA +FROM dbo.v_nrt_nbs_investigation_rdb_table_metadata inv_meta +where inv_meta.INVESTIGATION_FORM_CD=@nbs_page_form_cd; + +*/ + IF OBJECT_ID('#tmp_DynDm_Investigation_Data', 'U') IS NOT NULL + drop table #tmp_DynDm_Investigation_Data; + + + + -- declare @SQL varchar(MAX); + + + SELECT rdb_column_nm_list , isd.INVESTIGATION_KEY + into #tmp_DynDm_Investigation_Data + FROM dbo.INVESTIGATION inv with ( nolock) + INNER JOIN #tmp_DynDm_SUMM_DATAMART isd ON isd.INVESTIGATION_KEY =inv.INVESTIGATION_KEY + inner join dbo.v_nrt_nbs_investigation_rdb_table_metadata inv_meta on isd.DISEASE_GRP_CD = inv_meta.INVESTIGATION_FORM_CD + and inv_meta.INVESTIGATION_FORM_CD = @nbs_page_form_cd and isd.DISEASE_GRP_CD = @nbs_page_form_cd + ; + + SELECT @ROWCOUNT_NO = @@ROWCOUNT; + + + INSERT INTO dbo.job_flow_log ( batch_id ,[Dataflow_Name] ,[package_Name] ,[Status_Type] ,[step_number] ,[step_name] ,[row_count] ) + VALUES ( @batch_id ,'DYNAMIC_DATAMART' ,'RDB.DBO.DynDM_INVEST_FORM_PROC '+@DATAMART_NAME ,'START' ,@Proc_Step_no ,@Proc_Step_Name ,@ROWCOUNT_NO ); + + + + COMMIT TRANSACTION; + +/* + BEGIN TRANSACTION; + + SET @Proc_Step_no = @Proc_Step_no + 1; + SET @Proc_Step_Name = 'GENERATING tmp_DynDm_Case_Management_Metadata'; + + + --DX select * from #tmp_DynDm_Investigation_Data; + +/*-------INVESTIGATION ENDS----------*/ +/*CMData data*/ + + +/*it creates a new table with all the metadata associated to that investigation for the specific datamart name*/ +-- CREATE TABLE CASE_MANAGEMENT_METADATA AS + + + IF OBJECT_ID('#tmp_DynDm_Case_Management_Metadata', 'U') IS NOT NULL + drop table #tmp_DynDm_Case_Management_Metadata; + + + + + SELECT DISTINCT INIT.FORM_CD, INIT.DATAMART_NM, NBS_RDB_METADATA.RDB_TABLE_NM, + NBS_RDB_METADATA.RDB_COLUMN_NM,NBS_RDB_METADATA.USER_DEFINED_COLUMN_NM + into #tmp_DynDm_Case_Management_Metadata + FROM dbo.v_nbs_page INIT + INNER JOIN NBS_ODSE..NBS_UI_METADATA with ( nolock) ON NBS_UI_METADATA.INVESTIGATION_FORM_CD = INIT.FORM_CD + INNER JOIN NBS_ODSE..NBS_RDB_METADATA with ( nolock) ON NBS_UI_METADATA.NBS_UI_METADATA_UID = NBS_RDB_METADATA.NBS_UI_METADATA_UID + WHERE RDB_TABLE_NM='D_CASE_MANAGEMENT' + AND NBS_UI_METADATA.INVESTIGATION_FORM_CD=(SELECT FORM_CD FROM dbo.NBS_PAGE WHERE DATAMART_NM=@DATAMART_NAME) + AND NBS_RDB_METADATA.USER_DEFINED_COLUMN_NM <> '' + and NBS_RDB_METADATA.USER_DEFINED_COLUMN_NM IS NOT NULL + --ORDER BY INIT.FORM_CD, NBS_RDB_METADATA.RDB_COLUMN_NM + ; + + --DX select * from #tmp_DynDm_Case_Management_Metadata; + + -- RAVI -- why set FORM_CD here + update #tmp_DynDm_Case_Management_Metadata + set FORM_CD =(SELECT FORM_CD FROM dbo.NBS_PAGE WHERE DATAMART_NM=@DATAMART_NAME), + RDB_TABLE_NM='D_CASE_MANAGEMENT' + ; + + + + + SELECT @ROWCOUNT_NO = @@ROWCOUNT; + + + INSERT INTO dbo.job_flow_log ( batch_id ,[Dataflow_Name] ,[package_Name] ,[Status_Type] ,[step_number] ,[step_name] ,[row_count] ) + VALUES ( @batch_id ,'DYNAMIC_DATAMART' ,'RDB.DBO.DynDM_INVEST_FORM_PROC '+@DATAMART_NAME ,'START' ,@Proc_Step_no ,@Proc_Step_Name ,@ROWCOUNT_NO ); + + + + COMMIT TRANSACTION; + + */ + + + + SELECT DISTINCT FORM_CD, DATAMART_NM, RDB_TABLE_NM, RDB_COLUMN_NM,USER_DEFINED_COLUMN_NM ,INVESTIGATION_FORM_CD,rdb_column_nm_list + into #tmp_DynDm_Case_Management_Metadata + FROM dbo.v_nrt_nbs_d_case_mgmt_rdb_table_metadata case_meta + where case_meta.INVESTIGATION_FORM_CD=@nbs_page_form_cd ; + + + BEGIN TRANSACTION; + + SET @Proc_Step_no = @Proc_Step_no + 1; + SET @Proc_Step_Name = 'GENERATING tmp_DynDm_INV_SUMM_DATAMART'; + + + + + +/*New table with some columns of the investigation summary datamart*/ + + +--CREATE TABLE INV_SUMM_DATAMART AS + + + + IF OBJECT_ID('#tmp_DynDm_INV_SUMM_DATAMART', 'U') IS NOT NULL + drop table #tmp_DynDm_INV_SUMM_DATAMART; + + + SELECT INV_SUMM_DATAMART.PROGRAM_JURISDICTION_OID, + INV_SUMM_DATAMART.INVESTIGATION_KEY, + INV_SUMM_DATAMART.PATIENT_KEY, + INV_SUMM_DATAMART.PATIENT_LOCAL_ID, + INV_SUMM_DATAMART.INVESTIGATION_CREATE_DATE, + INV_SUMM_DATAMART.INVESTIGATION_CREATED_BY, + INV_SUMM_DATAMART.INVESTIGATION_LAST_UPDTD_DATE, + INV_SUMM_DATAMART.INVESTIGATION_LAST_UPDTD_BY, + INV_SUMM_DATAMART.EVENT_DATE, + INV_SUMM_DATAMART.EVENT_DATE_TYPE, + INV_SUMM_DATAMART.LABORATORY_INFORMATION, + INV_SUMM_DATAMART.EARLIEST_SPECIMEN_COLLECT_DATE, + INV_SUMM_DATAMART.NOTIFICATION_STATUS, + INV_SUMM_DATAMART.CONFIRMATION_METHOD, + INV_SUMM_DATAMART.CONFIRMATION_DT, + INV_SUMM_DATAMART.DISEASE_CD, + INV_SUMM_DATAMART.DISEASE, + INV_SUMM_DATAMART.NOTIFICATION_LAST_UPDATED_DATE, + INV_SUMM_DATAMART.NOTIFICATION_LOCAL_ID, + INV_SUMM_DATAMART.PROGRAM_AREA, + --INV_SUMM_DATAMART.INVESTIGATION_LAST_UPDTD_BY, + INV_SUMM_DATAMART.PATIENT_COUNTY_CODE, + INV_SUMM_DATAMART.JURISDICTION_NM + into #tmp_DynDm_INV_SUMM_DATAMART + FROM dbo.INV_SUMM_DATAMART with ( nolock) + INNER JOIN #tmp_DynDm_Investigation_Data ON tmp_DynDm_Investigation_Data.INVESTIGATION_KEY = INV_SUMM_DATAMART.INVESTIGATION_KEY + inner join dbo.nrt_investigation_key nrt_inv on nrt_inv.INVESTIGATION_KEY = tmp_DynDm_Investigation_Data.INVESTIGATION_KEY + and nrt_inv_key.case_uid in (SELECT value FROM STRING_SPLIT(@phc_id_list, ',')); + + ; + + + +/*Patient data*/ + + --CREATE TABLE PAT_METADATA AS + + + + SELECT @ROWCOUNT_NO = @@ROWCOUNT; + + + INSERT INTO dbo.job_flow_log ( batch_id ,[Dataflow_Name] ,[package_Name] ,[Status_Type] ,[step_number] ,[step_name] ,[row_count] ) + VALUES ( @batch_id ,'DYNAMIC_DATAMART' ,'RDB.DBO.DynDM_INVEST_FORM_PROC '+@DATAMART_NAME ,'START' ,@Proc_Step_no ,@Proc_Step_Name ,@ROWCOUNT_NO ); + + + + COMMIT TRANSACTION; + + /* + BEGIN TRANSACTION; + + SET @Proc_Step_no = @Proc_Step_no + 1; + SET @Proc_Step_Name = 'GENERATING tmp_DynDm_PAT_METADATA'; + + + + IF OBJECT_ID('#tmp_DynDm_PAT_METADATA', 'U') IS NOT NULL + drop table #tmp_DynDm_PAT_METADATA; + + */ + +/* + + SELECT DISTINCT INIT.FORM_CD, INIT.DATAMART_NM, NBS_RDB_METADATA.RDB_TABLE_NM, NBS_RDB_METADATA.RDB_COLUMN_NM,NBS_RDB_METADATA.USER_DEFINED_COLUMN_NM + into #tmp_DynDm_PAT_METADATA + FROM dbo.TMP_INIT INIT + INNER JOIN NBS_ODSE..NBS_UI_METADATA with ( nolock) ON NBS_UI_METADATA.INVESTIGATION_FORM_CD = INIT.FORM_CD + INNER JOIN NBS_ODSE..NBS_RDB_METADATA with ( nolock) ON NBS_UI_METADATA.NBS_UI_METADATA_UID = NBS_RDB_METADATA.NBS_UI_METADATA_UID + WHERE RDB_TABLE_NM='D_PATIENT' + AND NBS_UI_METADATA.INVESTIGATION_FORM_CD=(SELECT FORM_CD FROM dbo.NBS_PAGE WHERE DATAMART_NM=@DATAMART_NAME) + AND RDB_COLUMN_NM NOT IN ('PATIENT_WORK_STREET_ADDRESS_1', 'PATIENT_WORK_STREET_ADDRESS_2') + AND NBS_RDB_METADATA.USER_DEFINED_COLUMN_NM <> '' + and NBS_RDB_METADATA.USER_DEFINED_COLUMN_NM IS NOT NULL + ; + +*/ + + /* + SELECT DISTINCT FORM_CD, DATAMART_NM, RDB_TABLE_NM, RDB_COLUMN_NM,USER_DEFINED_COLUMN_NM ,INVESTIGATION_FORM_CD,rdb_column_nm_list + into #tmp_DynDm_PAT_METADATA + FROM dbo.v_nrt_nbs_d_patient_rdb_table_metadata pat_meta + where pat_meta.INVESTIGATION_FORM_CD=@nbs_page_form_cd ; +*/ + +--DECLARE @listStr VARCHAR(MAX), @SQL VARCHAR(MAX) + +/* +SET @listStr =null; + +SELECT @listStr = COALESCE(@listStr+',' ,'') + RDB_COLUMN_NM + ' '+ coalesce(USER_DEFINED_COLUMN_NM,'') +FROM #tmp_DynDm_PAT_METADATA; + +*/ + + /* SELECT @ROWCOUNT_NO = @@ROWCOUNT; + + + INSERT INTO dbo.job_flow_log ( batch_id ,[Dataflow_Name] ,[package_Name] ,[Status_Type] ,[step_number] ,[step_name] ,[row_count] ) + VALUES ( @batch_id ,'DYNAMIC_DATAMART' ,'RDB.DBO.DynDM_INVEST_FORM_PROC '+@DATAMART_NAME ,'START' ,@Proc_Step_no ,@Proc_Step_Name ,@ROWCOUNT_NO ); + + + + COMMIT TRANSACTION; + */ + + BEGIN TRANSACTION; + + SET @Proc_Step_no = @Proc_Step_no + 1; + SET @Proc_Step_Name = 'GENERATING tmp_DynDm_Patient_Data'; + + + IF OBJECT_ID('dbo.tmp_DynDm_Patient_Data', 'U') IS NOT NULL + drop table dbo.tmp_DynDm_Patient_Data; + + /* + SET @SQL = ' SELECT '+@listStr +' , tmp_DynDm_SUMM_DATAMART.INVESTIGATION_KEY ' + + ' into dbo.tmp_DynDm_Patient_Data ' + + ' FROM dbo.D_PATIENT with ( nolock) ' + + ' INNER JOIN #tmp_DynDm_SUMM_DATAMART ON D_PATIENT.PATIENT_KEY = tmp_DynDm_SUMM_DATAMART.PATIENT_KEY ' + ; +--select 'PATIENT DATA',@SQL; + + EXEC (@SQL); + +*/ + SELECT pat_meta.rdb_column_nm_list , isd.INVESTIGATION_KEY + into dbo.tmp_DynDm_Patient_Data + FROM dbo.D_PATIENT pat with ( nolock) + INNER JOIN #tmp_DynDm_SUMM_DATAMART isd ON pat.PATIENT_KEY = isd.PATIENT_KEY + inner join dbo.v_nrt_nbs_d_patient_rdb_table_metadata pat_meta on isd.DISEASE_GRP_CD = pat_meta.INVESTIGATION_FORM_CD + and pat_meta.INVESTIGATION_FORM_CD = @nbs_page_form_cd and isd.DISEASE_GRP_CD = @nbs_page_form_cd + + ; + + SELECT @ROWCOUNT_NO = @@ROWCOUNT; + + + INSERT INTO dbo.job_flow_log ( batch_id ,[Dataflow_Name] ,[package_Name] ,[Status_Type] ,[step_number] ,[step_name] ,[row_count] ) + VALUES ( @batch_id ,'DYNAMIC_DATAMART' ,'RDB.DBO.DynDM_INVEST_FORM_PROC '+@DATAMART_NAME ,'START' ,@Proc_Step_no ,@Proc_Step_Name ,@ROWCOUNT_NO ); + + + + + +--DX select * from dbo.tmp_DynDm_Patient_Data ; + + +--%mend INVEST_FORM_PROC; + COMMIT TRANSACTION ; + + + BEGIN TRANSACTION; + + SET @Proc_Step_no = @Proc_Step_no + 1; + SET @Proc_Step_Name = 'SP_COMPLETE'; + + + INSERT INTO dbo.job_flow_log ( + batch_id + ,[Dataflow_Name] + ,[package_Name] + ,[Status_Type] + ,[step_number] + ,[step_name] + ,[row_count] + ) + VALUES + ( + @batch_id, + 'DYNAMIC_DATAMART' + ,'RDB.DBO.DynDM_INVEST_FORM_PROC '+@DATAMART_NAME + ,'COMPLETE' + ,@Proc_Step_no + ,@Proc_Step_name + ,@RowCount_no + ); + + + COMMIT TRANSACTION ; + END TRY + + BEGIN CATCH + + + IF @@TRANCOUNT > 0 ROLLBACK TRANSACTION; + + + + DECLARE @ErrorNumber INT = ERROR_NUMBER(); + DECLARE @ErrorLine INT = ERROR_LINE(); + DECLARE @ErrorMessage NVARCHAR(4000) = ERROR_MESSAGE(); + DECLARE @ErrorSeverity INT = ERROR_SEVERITY(); + DECLARE @ErrorState INT = ERROR_STATE(); + + + INSERT INTO dbo.job_flow_log ( + batch_id + ,[Dataflow_Name] + ,[package_Name] + ,[Status_Type] + ,[step_number] + ,[step_name] + ,[Error_Description] + ,[row_count] + ) + VALUES + ( + @batch_id + ,'DYNAMIC_DATAMART' + ,'RDB.DBO.DynDM_INVEST_FORM_PROC' +@DATAMART_NAME + ,'ERROR' + ,@Proc_Step_no + ,'ERROR - '+ @Proc_Step_name + , 'Step -' +CAST(@Proc_Step_no AS VARCHAR(3))+' -' +CAST(@ErrorMessage AS VARCHAR(500)) + ,0 + ); + + + return -1 ; + + END CATCH + +END + +; + + + + diff --git a/liquibase-service/src/main/resources/db/changelog/db.rdb_modern.changelog-16.1.yaml b/liquibase-service/src/main/resources/db/changelog/db.rdb_modern.changelog-16.1.yaml index 736174ee..6218aabb 100644 --- a/liquibase-service/src/main/resources/db/changelog/db.rdb_modern.changelog-16.1.yaml +++ b/liquibase-service/src/main/resources/db/changelog/db.rdb_modern.changelog-16.1.yaml @@ -1054,4 +1054,12 @@ databaseChangeLog: changes: - sqlFile: path: 060-create-summary-report-case-001.sql + splitStatements: false + - changeSet: + id: 148 + author: liquibase + runOnChange: true + changes: + - sqlFile: + path: 115-sp_dyn_dm_invest_form_post_processing-001.sql splitStatements: false \ No newline at end of file diff --git a/liquibase-service/src/main/resources/db/rdb_modern/routines/115-sp_dyn_dm_invest_form_post_processing-001.sql b/liquibase-service/src/main/resources/db/rdb_modern/routines/115-sp_dyn_dm_invest_form_post_processing-001.sql new file mode 100644 index 00000000..747b0272 --- /dev/null +++ b/liquibase-service/src/main/resources/db/rdb_modern/routines/115-sp_dyn_dm_invest_form_post_processing-001.sql @@ -0,0 +1,469 @@ + + +CREATE or alter PROCEDURE [dbo].sp_dyn_dm_invest_form_post_processing +-- call this after populating <> + + @batch_id BIGINT, + @DATAMART_NAME VARCHAR(100), + @phc_id_list nvarchar(max) + AS +BEGIN + BEGIN TRY + + -- DECLARE @batch_id BIGINT = 999; DECLARE @DATAMART_NAME VARCHAR(100) = 'CONG_SYPHILIS'; + DECLARE @RowCount_no INT ; + DECLARE @Proc_Step_no FLOAT = 0 ; + DECLARE @Proc_Step_Name VARCHAR(200) = '' ; + DECLARE @batch_start_time datetime = null ; + DECLARE @batch_end_time datetime = null ; + DECLARE @nbs_page_form_cd varchar(200)='' + + SET @Proc_Step_no = 1; + SET @Proc_Step_Name = 'SP_Start'; + + + + + BEGIN TRANSACTION; + + INSERT INTO dbo.job_flow_log ( + batch_id + ,[Dataflow_Name] + ,[package_Name] + ,[Status_Type] + ,[step_number] + ,[step_name] + ,[row_count] + ) + VALUES + ( + @batch_id + ,'DYNAMIC_DATAMART' + ,'RDB.DBO.DynDM_INVEST_FORM_PROC '+@DATAMART_NAME + ,'START' + ,@Proc_Step_no + ,@Proc_Step_Name + ,0 + ); + + COMMIT TRANSACTION ; + + + + BEGIN TRANSACTION; + + + SET @Proc_Step_no = @Proc_Step_no + 1; + SET @Proc_Step_Name = 'GENERATING tmp_DynDm_SUMM_DATAMART'; + + + + + + --DROP TABLE RDB.DBO.dbo.tmp_DynDm_SUMM_DATAMART; + + +/*Creates a summ_datamart with patient key, investigation key and disease group code*/ + --CREATE TABLE dbo.SUMM_DATAMART AS + + /*IF OBJECT_ID('#tmp_DynDm_SUMM_DATAMART', 'U') IS NOT NULL + drop table #tmp_DynDm_SUMM_DATAMART; + */ + +SET @nbs_page_form_cd = (SELECT FORM_CD FROM dbo.v_nbs_page WHERE DATAMART_NM=@DATAMART_NAME) + + SELECT isd.PATIENT_KEY AS PATIENT_KEY, isd.INVESTIGATION_KEY, c.DISEASE_GRP_CD + into #tmp_DynDm_SUMM_DATAMART + FROM dbo.INV_SUMM_DATAMART isd with ( nolock) + INNER JOIN dbo.v_condition_dim c with ( nolock) ON isd.DISEASE_CD = c.CONDITION_CD and c.DISEASE_GRP_CD = @nbs_page_form_cd + INNER JOIN dbo.nrt_investigation_key nrt_inv_key with (nolock) ON isd.investigation_key = nrt_inv_key.d_investigation_key + and nrt_inv_key.case_uid in (SELECT value FROM STRING_SPLIT(@phc_id_list, ',')); + + + + SELECT @ROWCOUNT_NO = @@ROWCOUNT; + + + INSERT INTO dbo.job_flow_log ( batch_id ,[Dataflow_Name] ,[package_Name] ,[Status_Type] ,[step_number] ,[step_name] ,[row_count] ) + VALUES ( @batch_id ,'DYNAMIC_DATAMART' ,'RDB.DBO.DynDM_INVEST_FORM_PROC '+@DATAMART_NAME ,'START' ,@Proc_Step_no ,@Proc_Step_Name ,@ROWCOUNT_NO ); + + + + COMMIT TRANSACTION; + + + + + + BEGIN TRANSACTION; + + SET @Proc_Step_no = @Proc_Step_no + 1; + SET @Proc_Step_Name = 'GENERATING tmp_DynDm_Investigation_Data'; + + +/*Make a list of rdb_column_nm separated by ,*/ + +--DX select * from #tmp_DynDm_INV_METADATA ; + + DECLARE @listStr VARCHAR(MAX) +/* + + +SELECT @listStr = COALESCE(@listStr+',' ,'') + RDB_COLUMN_NM + ' '+ coalesce(USER_DEFINED_COLUMN_NM,'') +FROM #tmp_DynDm_INV_METADATA; +*/ + + +/*It creates a new table with a list of all the rdb column name plus the investigation key*/ +-- CREATE TABLE INVESTIGATION_DATA AS + +/* +select DISTINCT FORM_CD, DATAMART_NM, RDB_TABLE_NM, RDB_COLUMN_NM,USER_DEFINED_COLUMN_NM , rdb_column_nm_list + -- into #tmp_DynDm_INV_METADATA +FROM dbo.v_nrt_nbs_investigation_rdb_table_metadata inv_meta +where inv_meta.INVESTIGATION_FORM_CD=@nbs_page_form_cd; + +*/ + IF OBJECT_ID('#tmp_DynDm_Investigation_Data', 'U') IS NOT NULL + drop table #tmp_DynDm_Investigation_Data; + + + + -- declare @SQL varchar(MAX); + + + SELECT rdb_column_nm_list , isd.INVESTIGATION_KEY + into #tmp_DynDm_Investigation_Data + FROM dbo.INVESTIGATION inv with ( nolock) + INNER JOIN #tmp_DynDm_SUMM_DATAMART isd ON isd.INVESTIGATION_KEY =inv.INVESTIGATION_KEY + inner join dbo.v_nrt_nbs_investigation_rdb_table_metadata inv_meta on isd.DISEASE_GRP_CD = inv_meta.INVESTIGATION_FORM_CD + and inv_meta.INVESTIGATION_FORM_CD = @nbs_page_form_cd and isd.DISEASE_GRP_CD = @nbs_page_form_cd + ; + + SELECT @ROWCOUNT_NO = @@ROWCOUNT; + + + INSERT INTO dbo.job_flow_log ( batch_id ,[Dataflow_Name] ,[package_Name] ,[Status_Type] ,[step_number] ,[step_name] ,[row_count] ) + VALUES ( @batch_id ,'DYNAMIC_DATAMART' ,'RDB.DBO.DynDM_INVEST_FORM_PROC '+@DATAMART_NAME ,'START' ,@Proc_Step_no ,@Proc_Step_Name ,@ROWCOUNT_NO ); + + + + COMMIT TRANSACTION; + +/* + BEGIN TRANSACTION; + + SET @Proc_Step_no = @Proc_Step_no + 1; + SET @Proc_Step_Name = 'GENERATING tmp_DynDm_Case_Management_Metadata'; + + + --DX select * from #tmp_DynDm_Investigation_Data; + +/*-------INVESTIGATION ENDS----------*/ +/*CMData data*/ + + +/*it creates a new table with all the metadata associated to that investigation for the specific datamart name*/ +-- CREATE TABLE CASE_MANAGEMENT_METADATA AS + + + IF OBJECT_ID('#tmp_DynDm_Case_Management_Metadata', 'U') IS NOT NULL + drop table #tmp_DynDm_Case_Management_Metadata; + + + + + SELECT DISTINCT INIT.FORM_CD, INIT.DATAMART_NM, NBS_RDB_METADATA.RDB_TABLE_NM, + NBS_RDB_METADATA.RDB_COLUMN_NM,NBS_RDB_METADATA.USER_DEFINED_COLUMN_NM + into #tmp_DynDm_Case_Management_Metadata + FROM dbo.v_nbs_page INIT + INNER JOIN NBS_ODSE..NBS_UI_METADATA with ( nolock) ON NBS_UI_METADATA.INVESTIGATION_FORM_CD = INIT.FORM_CD + INNER JOIN NBS_ODSE..NBS_RDB_METADATA with ( nolock) ON NBS_UI_METADATA.NBS_UI_METADATA_UID = NBS_RDB_METADATA.NBS_UI_METADATA_UID + WHERE RDB_TABLE_NM='D_CASE_MANAGEMENT' + AND NBS_UI_METADATA.INVESTIGATION_FORM_CD=(SELECT FORM_CD FROM dbo.NBS_PAGE WHERE DATAMART_NM=@DATAMART_NAME) + AND NBS_RDB_METADATA.USER_DEFINED_COLUMN_NM <> '' + and NBS_RDB_METADATA.USER_DEFINED_COLUMN_NM IS NOT NULL + --ORDER BY INIT.FORM_CD, NBS_RDB_METADATA.RDB_COLUMN_NM + ; + + --DX select * from #tmp_DynDm_Case_Management_Metadata; + + -- RAVI -- why set FORM_CD here + update #tmp_DynDm_Case_Management_Metadata + set FORM_CD =(SELECT FORM_CD FROM dbo.NBS_PAGE WHERE DATAMART_NM=@DATAMART_NAME), + RDB_TABLE_NM='D_CASE_MANAGEMENT' + ; + + + + + SELECT @ROWCOUNT_NO = @@ROWCOUNT; + + + INSERT INTO dbo.job_flow_log ( batch_id ,[Dataflow_Name] ,[package_Name] ,[Status_Type] ,[step_number] ,[step_name] ,[row_count] ) + VALUES ( @batch_id ,'DYNAMIC_DATAMART' ,'RDB.DBO.DynDM_INVEST_FORM_PROC '+@DATAMART_NAME ,'START' ,@Proc_Step_no ,@Proc_Step_Name ,@ROWCOUNT_NO ); + + + + COMMIT TRANSACTION; + + */ + + + + SELECT DISTINCT FORM_CD, DATAMART_NM, RDB_TABLE_NM, RDB_COLUMN_NM,USER_DEFINED_COLUMN_NM ,INVESTIGATION_FORM_CD,rdb_column_nm_list + into #tmp_DynDm_Case_Management_Metadata + FROM dbo.v_nrt_nbs_d_case_mgmt_rdb_table_metadata case_meta + where case_meta.INVESTIGATION_FORM_CD=@nbs_page_form_cd ; + + + BEGIN TRANSACTION; + + SET @Proc_Step_no = @Proc_Step_no + 1; + SET @Proc_Step_Name = 'GENERATING tmp_DynDm_INV_SUMM_DATAMART'; + + + + + +/*New table with some columns of the investigation summary datamart*/ + + +--CREATE TABLE INV_SUMM_DATAMART AS + + + + IF OBJECT_ID('#tmp_DynDm_INV_SUMM_DATAMART', 'U') IS NOT NULL + drop table #tmp_DynDm_INV_SUMM_DATAMART; + + + SELECT INV_SUMM_DATAMART.PROGRAM_JURISDICTION_OID, + INV_SUMM_DATAMART.INVESTIGATION_KEY, + INV_SUMM_DATAMART.PATIENT_KEY, + INV_SUMM_DATAMART.PATIENT_LOCAL_ID, + INV_SUMM_DATAMART.INVESTIGATION_CREATE_DATE, + INV_SUMM_DATAMART.INVESTIGATION_CREATED_BY, + INV_SUMM_DATAMART.INVESTIGATION_LAST_UPDTD_DATE, + INV_SUMM_DATAMART.INVESTIGATION_LAST_UPDTD_BY, + INV_SUMM_DATAMART.EVENT_DATE, + INV_SUMM_DATAMART.EVENT_DATE_TYPE, + INV_SUMM_DATAMART.LABORATORY_INFORMATION, + INV_SUMM_DATAMART.EARLIEST_SPECIMEN_COLLECT_DATE, + INV_SUMM_DATAMART.NOTIFICATION_STATUS, + INV_SUMM_DATAMART.CONFIRMATION_METHOD, + INV_SUMM_DATAMART.CONFIRMATION_DT, + INV_SUMM_DATAMART.DISEASE_CD, + INV_SUMM_DATAMART.DISEASE, + INV_SUMM_DATAMART.NOTIFICATION_LAST_UPDATED_DATE, + INV_SUMM_DATAMART.NOTIFICATION_LOCAL_ID, + INV_SUMM_DATAMART.PROGRAM_AREA, + --INV_SUMM_DATAMART.INVESTIGATION_LAST_UPDTD_BY, + INV_SUMM_DATAMART.PATIENT_COUNTY_CODE, + INV_SUMM_DATAMART.JURISDICTION_NM + into #tmp_DynDm_INV_SUMM_DATAMART + FROM dbo.INV_SUMM_DATAMART with ( nolock) + INNER JOIN #tmp_DynDm_Investigation_Data ON tmp_DynDm_Investigation_Data.INVESTIGATION_KEY = INV_SUMM_DATAMART.INVESTIGATION_KEY + inner join dbo.nrt_investigation_key nrt_inv on nrt_inv.INVESTIGATION_KEY = tmp_DynDm_Investigation_Data.INVESTIGATION_KEY + and nrt_inv_key.case_uid in (SELECT value FROM STRING_SPLIT(@phc_id_list, ',')); + + ; + + + +/*Patient data*/ + + --CREATE TABLE PAT_METADATA AS + + + + SELECT @ROWCOUNT_NO = @@ROWCOUNT; + + + INSERT INTO dbo.job_flow_log ( batch_id ,[Dataflow_Name] ,[package_Name] ,[Status_Type] ,[step_number] ,[step_name] ,[row_count] ) + VALUES ( @batch_id ,'DYNAMIC_DATAMART' ,'RDB.DBO.DynDM_INVEST_FORM_PROC '+@DATAMART_NAME ,'START' ,@Proc_Step_no ,@Proc_Step_Name ,@ROWCOUNT_NO ); + + + + COMMIT TRANSACTION; + + /* + BEGIN TRANSACTION; + + SET @Proc_Step_no = @Proc_Step_no + 1; + SET @Proc_Step_Name = 'GENERATING tmp_DynDm_PAT_METADATA'; + + + + IF OBJECT_ID('#tmp_DynDm_PAT_METADATA', 'U') IS NOT NULL + drop table #tmp_DynDm_PAT_METADATA; + + */ + +/* + + SELECT DISTINCT INIT.FORM_CD, INIT.DATAMART_NM, NBS_RDB_METADATA.RDB_TABLE_NM, NBS_RDB_METADATA.RDB_COLUMN_NM,NBS_RDB_METADATA.USER_DEFINED_COLUMN_NM + into #tmp_DynDm_PAT_METADATA + FROM dbo.TMP_INIT INIT + INNER JOIN NBS_ODSE..NBS_UI_METADATA with ( nolock) ON NBS_UI_METADATA.INVESTIGATION_FORM_CD = INIT.FORM_CD + INNER JOIN NBS_ODSE..NBS_RDB_METADATA with ( nolock) ON NBS_UI_METADATA.NBS_UI_METADATA_UID = NBS_RDB_METADATA.NBS_UI_METADATA_UID + WHERE RDB_TABLE_NM='D_PATIENT' + AND NBS_UI_METADATA.INVESTIGATION_FORM_CD=(SELECT FORM_CD FROM dbo.NBS_PAGE WHERE DATAMART_NM=@DATAMART_NAME) + AND RDB_COLUMN_NM NOT IN ('PATIENT_WORK_STREET_ADDRESS_1', 'PATIENT_WORK_STREET_ADDRESS_2') + AND NBS_RDB_METADATA.USER_DEFINED_COLUMN_NM <> '' + and NBS_RDB_METADATA.USER_DEFINED_COLUMN_NM IS NOT NULL + ; + +*/ + + /* + SELECT DISTINCT FORM_CD, DATAMART_NM, RDB_TABLE_NM, RDB_COLUMN_NM,USER_DEFINED_COLUMN_NM ,INVESTIGATION_FORM_CD,rdb_column_nm_list + into #tmp_DynDm_PAT_METADATA + FROM dbo.v_nrt_nbs_d_patient_rdb_table_metadata pat_meta + where pat_meta.INVESTIGATION_FORM_CD=@nbs_page_form_cd ; +*/ + +--DECLARE @listStr VARCHAR(MAX), @SQL VARCHAR(MAX) + +/* +SET @listStr =null; + +SELECT @listStr = COALESCE(@listStr+',' ,'') + RDB_COLUMN_NM + ' '+ coalesce(USER_DEFINED_COLUMN_NM,'') +FROM #tmp_DynDm_PAT_METADATA; + +*/ + + /* SELECT @ROWCOUNT_NO = @@ROWCOUNT; + + + INSERT INTO dbo.job_flow_log ( batch_id ,[Dataflow_Name] ,[package_Name] ,[Status_Type] ,[step_number] ,[step_name] ,[row_count] ) + VALUES ( @batch_id ,'DYNAMIC_DATAMART' ,'RDB.DBO.DynDM_INVEST_FORM_PROC '+@DATAMART_NAME ,'START' ,@Proc_Step_no ,@Proc_Step_Name ,@ROWCOUNT_NO ); + + + + COMMIT TRANSACTION; + */ + + BEGIN TRANSACTION; + + SET @Proc_Step_no = @Proc_Step_no + 1; + SET @Proc_Step_Name = 'GENERATING tmp_DynDm_Patient_Data'; + + + IF OBJECT_ID('dbo.tmp_DynDm_Patient_Data', 'U') IS NOT NULL + drop table dbo.tmp_DynDm_Patient_Data; + + /* + SET @SQL = ' SELECT '+@listStr +' , tmp_DynDm_SUMM_DATAMART.INVESTIGATION_KEY ' + + ' into dbo.tmp_DynDm_Patient_Data ' + + ' FROM dbo.D_PATIENT with ( nolock) ' + + ' INNER JOIN #tmp_DynDm_SUMM_DATAMART ON D_PATIENT.PATIENT_KEY = tmp_DynDm_SUMM_DATAMART.PATIENT_KEY ' + ; +--select 'PATIENT DATA',@SQL; + + EXEC (@SQL); + +*/ + SELECT pat_meta.rdb_column_nm_list , isd.INVESTIGATION_KEY + into dbo.tmp_DynDm_Patient_Data + FROM dbo.D_PATIENT pat with ( nolock) + INNER JOIN #tmp_DynDm_SUMM_DATAMART isd ON pat.PATIENT_KEY = isd.PATIENT_KEY + inner join dbo.v_nrt_nbs_d_patient_rdb_table_metadata pat_meta on isd.DISEASE_GRP_CD = pat_meta.INVESTIGATION_FORM_CD + and pat_meta.INVESTIGATION_FORM_CD = @nbs_page_form_cd and isd.DISEASE_GRP_CD = @nbs_page_form_cd + + ; + + SELECT @ROWCOUNT_NO = @@ROWCOUNT; + + + INSERT INTO dbo.job_flow_log ( batch_id ,[Dataflow_Name] ,[package_Name] ,[Status_Type] ,[step_number] ,[step_name] ,[row_count] ) + VALUES ( @batch_id ,'DYNAMIC_DATAMART' ,'RDB.DBO.DynDM_INVEST_FORM_PROC '+@DATAMART_NAME ,'START' ,@Proc_Step_no ,@Proc_Step_Name ,@ROWCOUNT_NO ); + + + + + +--DX select * from dbo.tmp_DynDm_Patient_Data ; + + +--%mend INVEST_FORM_PROC; + COMMIT TRANSACTION ; + + + BEGIN TRANSACTION; + + SET @Proc_Step_no = @Proc_Step_no + 1; + SET @Proc_Step_Name = 'SP_COMPLETE'; + + + INSERT INTO dbo.job_flow_log ( + batch_id + ,[Dataflow_Name] + ,[package_Name] + ,[Status_Type] + ,[step_number] + ,[step_name] + ,[row_count] + ) + VALUES + ( + @batch_id, + 'DYNAMIC_DATAMART' + ,'RDB.DBO.DynDM_INVEST_FORM_PROC '+@DATAMART_NAME + ,'COMPLETE' + ,@Proc_Step_no + ,@Proc_Step_name + ,@RowCount_no + ); + + + COMMIT TRANSACTION ; + END TRY + + BEGIN CATCH + + + IF @@TRANCOUNT > 0 ROLLBACK TRANSACTION; + + + + DECLARE @ErrorNumber INT = ERROR_NUMBER(); + DECLARE @ErrorLine INT = ERROR_LINE(); + DECLARE @ErrorMessage NVARCHAR(4000) = ERROR_MESSAGE(); + DECLARE @ErrorSeverity INT = ERROR_SEVERITY(); + DECLARE @ErrorState INT = ERROR_STATE(); + + + INSERT INTO dbo.job_flow_log ( + batch_id + ,[Dataflow_Name] + ,[package_Name] + ,[Status_Type] + ,[step_number] + ,[step_name] + ,[Error_Description] + ,[row_count] + ) + VALUES + ( + @batch_id + ,'DYNAMIC_DATAMART' + ,'RDB.DBO.DynDM_INVEST_FORM_PROC' +@DATAMART_NAME + ,'ERROR' + ,@Proc_Step_no + ,'ERROR - '+ @Proc_Step_name + , 'Step -' +CAST(@Proc_Step_no AS VARCHAR(3))+' -' +CAST(@ErrorMessage AS VARCHAR(500)) + ,0 + ); + + + return -1 ; + + END CATCH + +END + +; + + + + From d424fb47a3f39d7060ad44c128da259b92afbc91 Mon Sep 17 00:00:00 2001 From: Ravindran Seshadri <109151953+rseshadri99@users.noreply.github.com> Date: Sun, 9 Mar 2025 00:06:35 -0500 Subject: [PATCH 2/4] Update db.rdb_modern.changelog-16.1.yaml --- .../resources/db/changelog/db.rdb_modern.changelog-16.1.yaml | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/liquibase-service/src/main/resources/db/changelog/db.rdb_modern.changelog-16.1.yaml b/liquibase-service/src/main/resources/db/changelog/db.rdb_modern.changelog-16.1.yaml index 6218aabb..7d9b23df 100644 --- a/liquibase-service/src/main/resources/db/changelog/db.rdb_modern.changelog-16.1.yaml +++ b/liquibase-service/src/main/resources/db/changelog/db.rdb_modern.changelog-16.1.yaml @@ -1056,7 +1056,7 @@ databaseChangeLog: path: 060-create-summary-report-case-001.sql splitStatements: false - changeSet: - id: 148 + id: 152 author: liquibase runOnChange: true changes: From 82a4e410fb63f80c227caeb1a0c26d7b673b6d09 Mon Sep 17 00:00:00 2001 From: Ravindran Seshadri <109151953+rseshadri99@users.noreply.github.com> Date: Sun, 9 Mar 2025 01:02:26 -0500 Subject: [PATCH 3/4] Update db.rdb_modern.changelog-16.1.yaml liquibase change log update --- .../resources/db/changelog/db.rdb_modern.changelog-16.1.yaml | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/liquibase-service/src/main/resources/db/changelog/db.rdb_modern.changelog-16.1.yaml b/liquibase-service/src/main/resources/db/changelog/db.rdb_modern.changelog-16.1.yaml index 7d9b23df..cb71cc7d 100644 --- a/liquibase-service/src/main/resources/db/changelog/db.rdb_modern.changelog-16.1.yaml +++ b/liquibase-service/src/main/resources/db/changelog/db.rdb_modern.changelog-16.1.yaml @@ -1056,7 +1056,7 @@ databaseChangeLog: path: 060-create-summary-report-case-001.sql splitStatements: false - changeSet: - id: 152 + id: 159 author: liquibase runOnChange: true changes: From 20ac1f14c96e6557164092cab8e5c6e0205e8ea2 Mon Sep 17 00:00:00 2001 From: Ravindran Seshadri <109151953+rseshadri99@users.noreply.github.com> Date: Mon, 10 Mar 2025 23:56:57 -0400 Subject: [PATCH 4/4] proc name change proc name change --- ...cessing.sql => 115-sp_dyn_dm_invest_form_postprocessing.sql} | 2 +- .../resources/db/changelog/db.rdb_modern.changelog-16.1.yaml | 2 +- ...001.sql => 115-sp_dyn_dm_invest_form_postprocessing-001.sql} | 2 +- 3 files changed, 3 insertions(+), 3 deletions(-) rename db/upgrade/rdb_modern/routines/{115-sp_dyn_dm_invest_form_post_processing.sql => 115-sp_dyn_dm_invest_form_postprocessing.sql} (99%) rename liquibase-service/src/main/resources/db/rdb_modern/routines/{115-sp_dyn_dm_invest_form_post_processing-001.sql => 115-sp_dyn_dm_invest_form_postprocessing-001.sql} (99%) diff --git a/db/upgrade/rdb_modern/routines/115-sp_dyn_dm_invest_form_post_processing.sql b/db/upgrade/rdb_modern/routines/115-sp_dyn_dm_invest_form_postprocessing.sql similarity index 99% rename from db/upgrade/rdb_modern/routines/115-sp_dyn_dm_invest_form_post_processing.sql rename to db/upgrade/rdb_modern/routines/115-sp_dyn_dm_invest_form_postprocessing.sql index 747b0272..72361639 100644 --- a/db/upgrade/rdb_modern/routines/115-sp_dyn_dm_invest_form_post_processing.sql +++ b/db/upgrade/rdb_modern/routines/115-sp_dyn_dm_invest_form_postprocessing.sql @@ -1,6 +1,6 @@ -CREATE or alter PROCEDURE [dbo].sp_dyn_dm_invest_form_post_processing +CREATE or alter PROCEDURE [dbo].sp_dyn_dm_invest_form_postprocessing -- call this after populating <> @batch_id BIGINT, diff --git a/liquibase-service/src/main/resources/db/changelog/db.rdb_modern.changelog-16.1.yaml b/liquibase-service/src/main/resources/db/changelog/db.rdb_modern.changelog-16.1.yaml index cb71cc7d..be1ca9ee 100644 --- a/liquibase-service/src/main/resources/db/changelog/db.rdb_modern.changelog-16.1.yaml +++ b/liquibase-service/src/main/resources/db/changelog/db.rdb_modern.changelog-16.1.yaml @@ -1061,5 +1061,5 @@ databaseChangeLog: runOnChange: true changes: - sqlFile: - path: 115-sp_dyn_dm_invest_form_post_processing-001.sql + path: 115-sp_dyn_dm_invest_form_postprocessing-001.sql splitStatements: false \ No newline at end of file diff --git a/liquibase-service/src/main/resources/db/rdb_modern/routines/115-sp_dyn_dm_invest_form_post_processing-001.sql b/liquibase-service/src/main/resources/db/rdb_modern/routines/115-sp_dyn_dm_invest_form_postprocessing-001.sql similarity index 99% rename from liquibase-service/src/main/resources/db/rdb_modern/routines/115-sp_dyn_dm_invest_form_post_processing-001.sql rename to liquibase-service/src/main/resources/db/rdb_modern/routines/115-sp_dyn_dm_invest_form_postprocessing-001.sql index 747b0272..72361639 100644 --- a/liquibase-service/src/main/resources/db/rdb_modern/routines/115-sp_dyn_dm_invest_form_post_processing-001.sql +++ b/liquibase-service/src/main/resources/db/rdb_modern/routines/115-sp_dyn_dm_invest_form_postprocessing-001.sql @@ -1,6 +1,6 @@ -CREATE or alter PROCEDURE [dbo].sp_dyn_dm_invest_form_post_processing +CREATE or alter PROCEDURE [dbo].sp_dyn_dm_invest_form_postprocessing -- call this after populating <> @batch_id BIGINT,