Adding script for data exchange config

liquibase-service/src/main/resources/db/rdb/036-create_data_exchange_config-001.sql

@@ -0,0 +1,29 @@
+IF
+NOT EXISTS(SELECT *
+              FROM sys.databases
+              WHERE name = 'RDB')
+BEGIN
+    CREATE
+DATABASE RDB;
+END
+GO
+
+USE RDB;
+GO
+
+IF NOT EXISTS(
+    SELECT 'X'
+    FROM INFORMATION_SCHEMA.TABLES
+    WHERE TABLE_NAME = 'data_sync_config')
+BEGIN
+CREATE TABLE data_sync_config
+(
+    table_name       NVARCHAR(255) NOT NULL PRIMARY KEY,
+    source_db        NVARCHAR(255) NOT NULL,
+    query            NVARCHAR( MAX) NOT NULL,
+    query_with_limit NVARCHAR( MAX) NULL,
+    created_at       DATETIME2 DEFAULT GETDATE(),
+    updated_at       DATETIME2 DEFAULT GETDATE()
+);
+END
+GO

liquibase-service/src/main/resources/db/rdb/037-generate_data_for_data_exchange_config-001.sql

@@ -0,0 +1,3 @@
+INSERT INTO [RDB].[dbo].[data_sync_config] (table_name, source_db, query, query_with_limit)
+VALUES
+    ('CONDITION', 'RDB', 'SELECT * FROM CONDITION;', NULL), ('Rdb_Date', 'RDB', 'SELECT * FROM Rdb_Date;', NULL), ('D_PATIENT', 'RDB', 'SELECT * FROM D_PATIENT WHERE D_PATIENT.PATIENT_LAST_CHANGE_TIME >= :timestamp;', 'SELECT TOP(:limit) * FROM D_PATIENT WHERE D_PATIENT.PATIENT_LAST_CHANGE_TIME >= :timestamp ORDER BY D_PATIENT.PATIENT_LAST_CHANGE_TIME ASC;'), ('INVESTIGATION', 'RDB', 'SELECT * FROM INVESTIGATION WHERE INVESTIGATION.LAST_CHG_TIME >= :timestamp;', 'SELECT TOP(:limit) * FROM INVESTIGATION WHERE INVESTIGATION.LAST_CHG_TIME >= :timestamp ORDER BY INVESTIGATION.LAST_CHG_TIME ASC;'), ('CASE_COUNT', 'RDB', 'SELECT A.* FROM CASE_COUNT as A INNER JOIN INVESTIGATION as B ON A.INVESTIGATION_KEY = B.INVESTIGATION_KEY WHERE B.ADD_TIME >= :timestamp OR B.LAST_CHG_TIME >= :timestamp;', 'SELECT TOP(:limit) A.* FROM CASE_COUNT as A INNER JOIN INVESTIGATION as B ON A.INVESTIGATION_KEY = B.INVESTIGATION_KEY WHERE B.ADD_TIME >= :timestamp OR B.LAST_CHG_TIME >= :timestamp ORDER BY CASE WHEN B.ADD_TIME >= :timestamp THEN B.ADD_TIME ELSE B.LAST_CHG_TIME END ASC;'), ('BMIRD_CASE', 'RDB', 'SELECT BMIRD_CASE.* FROM BMIRD_CASE JOIN INVESTIGATION ON BMIRD_CASE.INVESTIGATION_KEY = INVESTIGATION.INVESTIGATION_KEY WHERE INVESTIGATION.LAST_CHG_TIME >= :timestamp;', 'SELECT TOP(:limit) BMIRD_CASE.* FROM BMIRD_CASE JOIN INVESTIGATION ON BMIRD_CASE.INVESTIGATION_KEY = INVESTIGATION.INVESTIGATION_KEY WHERE INVESTIGATION.LAST_CHG_TIME >= :timestamp ORDER BY INVESTIGATION.LAST_CHG_TIME ASC;'), ('RUBELLA_CASE', 'RDB', 'SELECT RUBELLA_CASE.* FROM RUBELLA_CASE JOIN INVESTIGATION ON RUBELLA_CASE.INVESTIGATION_KEY = INVESTIGATION.INVESTIGATION_KEY WHERE INVESTIGATION.LAST_CHG_TIME >= :timestamp;', 'SELECT TOP(:limit) RUBELLA_CASE.* FROM RUBELLA_CASE JOIN INVESTIGATION ON RUBELLA_CASE.INVESTIGATION_KEY = INVESTIGATION.INVESTIGATION_KEY WHERE INVESTIGATION.LAST_CHG_TIME >= :timestamp ORDER BY INVESTIGATION.LAST_CHG_TIME ASC;'), ('PERTUSSIS_CASE', 'RDB', 'SELECT PERTUSSIS_CASE.* FROM PERTUSSIS_CASE JOIN INVESTIGATION ON PERTUSSIS_CASE.INVESTIGATION_KEY = INVESTIGATION.INVESTIGATION_KEY WHERE INVESTIGATION.LAST_CHG_TIME >= :timestamp;', 'SELECT TOP(:limit) PERTUSSIS_CASE.* FROM PERTUSSIS_CASE JOIN INVESTIGATION ON PERTUSSIS_CASE.INVESTIGATION_KEY = INVESTIGATION.INVESTIGATION_KEY WHERE INVESTIGATION.LAST_CHG_TIME >= :timestamp ORDER BY INVESTIGATION.LAST_CHG_TIME ASC;'), ('HEPATITIS_CASE', 'RDB', 'SELECT HEPATITIS_CASE.* FROM HEPATITIS_CASE JOIN INVESTIGATION ON HEPATITIS_CASE.INVESTIGATION_KEY = INVESTIGATION.INVESTIGATION_KEY WHERE INVESTIGATION.LAST_CHG_TIME >= :timestamp;', 'SELECT TOP(:limit) HEPATITIS_CASE.* FROM HEPATITIS_CASE JOIN INVESTIGATION ON HEPATITIS_CASE.INVESTIGATION_KEY = INVESTIGATION.INVESTIGATION_KEY WHERE INVESTIGATION.LAST_CHG_TIME >= :timestamp ORDER BY INVESTIGATION.LAST_CHG_TIME ASC;'), ('GENERIC_CASE', 'RDB', 'SELECT GENERIC_CASE.* FROM GENERIC_CASE JOIN INVESTIGATION ON GENERIC_CASE.INVESTIGATION_KEY = INVESTIGATION.INVESTIGATION_KEY WHERE INVESTIGATION.LAST_CHG_TIME >= :timestamp;', 'SELECT TOP(:limit) GENERIC_CASE.* FROM GENERIC_CASE JOIN INVESTIGATION ON GENERIC_CASE.INVESTIGATION_KEY = INVESTIGATION.INVESTIGATION_KEY WHERE INVESTIGATION.LAST_CHG_TIME >= :timestamp ORDER BY INVESTIGATION.LAST_CHG_TIME ASC;'), ('MEASLES_CASE', 'RDB', 'SELECT MEASLES_CASE.* FROM MEASLES_CASE JOIN INVESTIGATION ON MEASLES_CASE.INVESTIGATION_KEY = INVESTIGATION.INVESTIGATION_KEY WHERE INVESTIGATION.LAST_CHG_TIME >= :timestamp;', 'SELECT TOP(:limit) MEASLES_CASE.* FROM MEASLES_CASE JOIN INVESTIGATION ON MEASLES_CASE.INVESTIGATION_KEY = INVESTIGATION.INVESTIGATION_KEY WHERE INVESTIGATION.LAST_CHG_TIME >= :timestamp ORDER BY INVESTIGATION.LAST_CHG_TIME ASC;'), ('HEPATITIS_DATAMART', 'RDB', 'SELECT * FROM HEPATITIS_DATAMART WHERE REFRESH_DATETIME >= :timestamp;', 'SELECT TOP(:limit) * FROM HEPATITIS_DATAMART WHERE REFRESH_DATETIME >= :timestamp ORDER BY REFRESH_DATETIME ASC;'), ('CONFIRMATION_METHOD', 'RDB', 'SELECT * FROM CONFIRMATION_METHOD;', NULL), ('CONFIRMATION_METHOD_GROUP', 'RDB', 'SELECT CONFIRMATION_METHOD_GROUP.* FROM CONFIRMATION_METHOD_GROUP JOIN INVESTIGATION ON CONFIRMATION_METHOD_GROUP.INVESTIGATION_KEY = INVESTIGATION.INVESTIGATION_KEY WHERE INVESTIGATION.LAST_CHG_TIME >= :timestamp;', 'SELECT TOP(:limit) CONFIRMATION_METHOD_GROUP.* FROM CONFIRMATION_METHOD_GROUP JOIN INVESTIGATION ON CONFIRMATION_METHOD_GROUP.INVESTIGATION_KEY = INVESTIGATION.INVESTIGATION_KEY WHERE INVESTIGATION.LAST_CHG_TIME >= :timestamp ORDER BY INVESTIGATION.LAST_CHG_TIME ASC;'), ('D_INTERVIEW', 'RDB', 'SELECT D_INTERVIEW.* FROM D_INTERVIEW WHERE D_INTERVIEW.ADD_TIME >= :timestamp OR D_INTERVIEW.LAST_CHG_TIME >= :timestamp;', 'SELECT TOP(:limit) D_INTERVIEW.* FROM D_INTERVIEW WHERE D_INTERVIEW.ADD_TIME >= :timestamp OR D_INTERVIEW.LAST_CHG_TIME >= :timestamp ORDER BY CASE WHEN D_INTERVIEW.ADD_TIME >= :timestamp THEN D_INTERVIEW.ADD_TIME ELSE D_INTERVIEW.LAST_CHG_TIME END ASC;'), ('D_CASE_MANAGEMENT', 'RDB', 'SELECT D_CASE_MANAGEMENT.* FROM D_CASE_MANAGEMENT JOIN INVESTIGATION ON D_CASE_MANAGEMENT.INVESTIGATION_KEY = INVESTIGATION.INVESTIGATION_KEY WHERE INVESTIGATION.LAST_CHG_TIME >= :timestamp;', 'SELECT TOP(:limit) D_CASE_MANAGEMENT.* FROM D_CASE_MANAGEMENT JOIN INVESTIGATION ON D_CASE_MANAGEMENT.INVESTIGATION_KEY = INVESTIGATION.INVESTIGATION_KEY WHERE INVESTIGATION.LAST_CHG_TIME >= :timestamp ORDER BY INVESTIGATION.LAST_CHG_TIME ASC;'), ('VAR_PAM_LDF', 'RDB', 'SELECT VAR_PAM_LDF.* FROM VAR_PAM_LDF JOIN INVESTIGATION ON VAR_PAM_LDF.INVESTIGATION_KEY = INVESTIGATION.INVESTIGATION_KEY WHERE VAR_PAM_LDF.add_time >= :timestamp OR INVESTIGATION.LAST_CHG_TIME >= :timestamp;', 'SELECT TOP(:limit) VAR_PAM_LDF.* FROM VAR_PAM_LDF JOIN INVESTIGATION ON VAR_PAM_LDF.INVESTIGATION_KEY = INVESTIGATION.INVESTIGATION_KEY WHERE VAR_PAM_LDF.add_time >= :timestamp OR INVESTIGATION.LAST_CHG_TIME >= :timestamp ORDER BY CASE WHEN VAR_PAM_LDF.add_time >= :timestamp THEN VAR_PAM_LDF.add_time ELSE INVESTIGATION.LAST_CHG_TIME END ASC;'), ('F_VAR_PAM', 'RDB', 'SELECT F_VAR_PAM.* FROM F_VAR_PAM JOIN INVESTIGATION ON F_VAR_PAM.INVESTIGATION_KEY = INVESTIGATION.INVESTIGATION_KEY WHERE INVESTIGATION.ADD_TIME >= :timestamp OR INVESTIGATION.LAST_CHG_TIME >= :timestamp;', 'SELECT TOP(:limit) F_VAR_PAM.* FROM F_VAR_PAM JOIN INVESTIGATION ON F_VAR_PAM.INVESTIGATION_KEY = INVESTIGATION.INVESTIGATION_KEY WHERE INVESTIGATION.ADD_TIME >= :timestamp OR INVESTIGATION.LAST_CHG_TIME >= :timestamp ORDER BY CASE WHEN INVESTIGATION.ADD_TIME >= :timestamp THEN INVESTIGATION.ADD_TIME ELSE INVESTIGATION.LAST_CHG_TIME END ASC;'), ('LDF_DATA', 'RDB', 'SELECT LDF_DATA.* FROM LDF_DATA JOIN LDF_GROUP ON LDF_DATA.LDF_GROUP_KEY = LDF_GROUP.LDF_GROUP_KEY JOIN INVESTIGATION ON LDF_GROUP.BUSINESS_OBJECT_UID = INVESTIGATION.CASE_UID WHERE INVESTIGATION.LAST_CHG_TIME >= :timestamp;', 'SELECT TOP(:limit) LDF_DATA.* FROM LDF_DATA JOIN LDF_GROUP ON LDF_DATA.LDF_GROUP_KEY = LDF_GROUP.LDF_GROUP_KEY JOIN INVESTIGATION ON LDF_GROUP.BUSINESS_OBJECT_UID = INVESTIGATION.CASE_UID WHERE INVESTIGATION.LAST_CHG_TIME >= :timestamp ORDER BY INVESTIGATION.LAST_CHG_TIME ASC;'), ('LDF_FOODBORNE', 'RDB', 'SELECT LDF_FOODBORNE.* FROM LDF_FOODBORNE JOIN INVESTIGATION ON LDF_FOODBORNE.INVESTIGATION_KEY = INVESTIGATION.INVESTIGATION_KEY WHERE INVESTIGATION.LAST_CHG_TIME >= :timestamp;', 'SELECT TOP(:limit) LDF_FOODBORNE.* FROM LDF_FOODBORNE JOIN INVESTIGATION ON LDF_FOODBORNE.INVESTIGATION_KEY = INVESTIGATION.INVESTIGATION_KEY WHERE INVESTIGATION.LAST_CHG_TIME >= :timestamp ORDER BY INVESTIGATION.LAST_CHG_TIME ASC;'), ('NOTIFICATION_EVENT', 'RDB', 'SELECT NOTIFICATION_EVENT.* FROM NOTIFICATION_EVENT JOIN INVESTIGATION ON NOTIFICATION_EVENT.INVESTIGATION_KEY = INVESTIGATION.INVESTIGATION_KEY WHERE INVESTIGATION.LAST_CHG_TIME >= :timestamp;', 'SELECT TOP(:limit) NOTIFICATION_EVENT.* FROM NOTIFICATION_EVENT JOIN INVESTIGATION ON NOTIFICATION_EVENT.INVESTIGATION_KEY = INVESTIGATION.INVESTIGATION_KEY WHERE INVESTIGATION.LAST_CHG_TIME >= :timestamp ORDER BY INVESTIGATION.LAST_CHG_TIME ASC;'), ('D_INV_ADMINISTRATIVE', 'RDB', 'SELECT D_INV_ADMINISTRATIVE.* FROM D_INV_ADMINISTRATIVE JOIN F_PAGE_CASE ON D_INV_ADMINISTRATIVE.D_INV_ADMINISTRATIVE_KEY = F_PAGE_CASE.INVESTIGATION_KEY JOIN INVESTIGATION ON F_PAGE_CASE.INVESTIGATION_KEY = INVESTIGATION.INVESTIGATION_KEY WHERE INVESTIGATION.LAST_CHG_TIME >= :timestamp;', 'SELECT TOP(:limit) D_INV_ADMINISTRATIVE.* FROM D_INV_ADMINISTRATIVE JOIN F_PAGE_CASE ON D_INV_ADMINISTRATIVE.D_INV_ADMINISTRATIVE_KEY = F_PAGE_CASE.INVESTIGATION_KEY JOIN INVESTIGATION ON F_PAGE_CASE.INVESTIGATION_KEY = INVESTIGATION.INVESTIGATION_KEY WHERE INVESTIGATION.LAST_CHG_TIME >= :timestamp ORDER BY INVESTIGATION.LAST_CHG_TIME ASC;'), ('D_INV_EPIDEMIOLOGY', 'RDB', 'SELECT D_INV_EPIDEMIOLOGY.* FROM D_INV_EPIDEMIOLOGY JOIN F_PAGE_CASE ON D_INV_EPIDEMIOLOGY.D_INV_EPIDEMIOLOGY_KEY = F_PAGE_CASE.INVESTIGATION_KEY JOIN INVESTIGATION ON F_PAGE_CASE.INVESTIGATION_KEY = INVESTIGATION.INVESTIGATION_KEY WHERE INVESTIGATION.LAST_CHG_TIME >= :timestamp;', 'SELECT TOP(:limit) D_INV_EPIDEMIOLOGY.* FROM D_INV_EPIDEMIOLOGY JOIN F_PAGE_CASE ON D_INV_EPIDEMIOLOGY.D_INV_EPIDEMIOLOGY_KEY = F_PAGE_CASE.INVESTIGATION_KEY JOIN INVESTIGATION ON F_PAGE_CASE.INVESTIGATION_KEY = INVESTIGATION.INVESTIGATION_KEY WHERE INVESTIGATION.LAST_CHG_TIME >= :timestamp ORDER BY INVESTIGATION.LAST_CHG_TIME ASC;'), ('D_INV_HIV', 'RDB', 'SELECT D_INV_HIV.* FROM D_INV_HIV JOIN F_PAGE_CASE ON D_INV_HIV.D_INV_HIV_KEY = F_PAGE_CASE.INVESTIGATION_KEY JOIN INVESTIGATION ON F_PAGE_CASE.INVESTIGATION_KEY = INVESTIGATION.INVESTIGATION_KEY WHERE INVESTIGATION.LAST_CHG_TIME >= :timestamp;', 'SELECT TOP(:limit) D_INV_HIV.* FROM D_INV_HIV JOIN F_PAGE_CASE ON D_INV_HIV.D_INV_HIV_KEY = F_PAGE_CASE.INVESTIGATION_KEY JOIN INVESTIGATION ON F_PAGE_CASE.INVESTIGATION_KEY = INVESTIGATION.INVESTIGATION_KEY WHERE INVESTIGATION.LAST_CHG_TIME >= :timestamp ORDER BY INVESTIGATION.LAST_CHG_TIME ASC;'), ('D_INV_LAB_FINDING', 'RDB', 'SELECT D_INV_LAB_FINDING.* FROM D_INV_LAB_FINDING JOIN F_PAGE_CASE ON D_INV_LAB_FINDING.D_INV_LAB_FINDING_KEY = F_PAGE_CASE.INVESTIGATION_KEY JOIN INVESTIGATION ON F_PAGE_CASE.INVESTIGATION_KEY = INVESTIGATION.INVESTIGATION_KEY WHERE INVESTIGATION.LAST_CHG_TIME >= :timestamp;', 'SELECT TOP(:limit) D_INV_LAB_FINDING.* FROM D_INV_LAB_FINDING JOIN F_PAGE_CASE ON D_INV_LAB_FINDING.D_INV_LAB_FINDING_KEY = F_PAGE_CASE.INVESTIGATION_KEY JOIN INVESTIGATION ON F_PAGE_CASE.INVESTIGATION_KEY = INVESTIGATION.INVESTIGATION_KEY WHERE INVESTIGATION.LAST_CHG_TIME >= :timestamp ORDER BY INVESTIGATION.LAST_CHG_TIME ASC;'), ('D_INV_MEDICAL_HISTORY', 'RDB', 'SELECT D_INV_MEDICAL_HISTORY.* FROM D_INV_MEDICAL_HISTORY JOIN F_PAGE_CASE ON D_INV_MEDICAL_HISTORY.D_INV_MEDICAL_HISTORY_KEY = F_PAGE_CASE.INVESTIGATION_KEY JOIN INVESTIGATION ON F_PAGE_CASE.INVESTIGATION_KEY = INVESTIGATION.INVESTIGATION_KEY WHERE INVESTIGATION.LAST_CHG_TIME >= :timestamp;', 'SELECT TOP(:limit) D_INV_MEDICAL_HISTORY.* FROM D_INV_MEDICAL_HISTORY JOIN F_PAGE_CASE ON D_INV_MEDICAL_HISTORY.D_INV_MEDICAL_HISTORY_KEY = F_PAGE_CASE.INVESTIGATION_KEY JOIN INVESTIGATION ON F_PAGE_CASE.INVESTIGATION_KEY = INVESTIGATION.INVESTIGATION_KEY WHERE INVESTIGATION.LAST_CHG_TIME >= :timestamp ORDER BY INVESTIGATION.LAST_CHG_TIME ASC;'), ('D_INV_RISK_FACTOR', 'RDB', 'SELECT D_INV_RISK_FACTOR.* FROM D_INV_RISK_FACTOR JOIN F_PAGE_CASE ON D_INV_RISK_FACTOR.D_INV_RISK_FACTOR_KEY = F_PAGE_CASE.INVESTIGATION_KEY JOIN INVESTIGATION ON F_PAGE_CASE.INVESTIGATION_KEY = INVESTIGATION.INVESTIGATION_KEY WHERE INVESTIGATION.LAST_CHG_TIME >= :timestamp;', 'SELECT TOP(:limit) D_INV_RISK_FACTOR.* FROM D_INV_RISK_FACTOR JOIN F_PAGE_CASE ON D_INV_RISK_FACTOR.D_INV_RISK_FACTOR_KEY = F_PAGE_CASE.INVESTIGATION_KEY JOIN INVESTIGATION ON F_PAGE_CASE.INVESTIGATION_KEY = INVESTIGATION.INVESTIGATION_KEY WHERE INVESTIGATION.LAST_CHG_TIME >= :timestamp ORDER BY INVESTIGATION.LAST_CHG_TIME ASC;'), ('D_INV_TREATMENT', 'RDB', 'SELECT D_INV_TREATMENT.* FROM D_INV_TREATMENT JOIN F_PAGE_CASE ON D_INV_TREATMENT.D_INV_TREATMENT_KEY = F_PAGE_CASE.INVESTIGATION_KEY JOIN INVESTIGATION ON F_PAGE_CASE.INVESTIGATION_KEY = INVESTIGATION.INVESTIGATION_KEY WHERE INVESTIGATION.LAST_CHG_TIME >= :timestamp;', 'SELECT TOP(:limit) D_INV_TREATMENT.* FROM D_INV_TREATMENT JOIN F_PAGE_CASE ON D_INV_TREATMENT.D_INV_TREATMENT_KEY = F_PAGE_CASE.INVESTIGATION_KEY JOIN INVESTIGATION ON F_PAGE_CASE.INVESTIGATION_KEY = INVESTIGATION.INVESTIGATION_KEY WHERE INVESTIGATION.LAST_CHG_TIME >= :timestamp ORDER BY INVESTIGATION.LAST_CHG_TIME ASC;'), ('D_INV_VACCINATION', 'RDB', 'SELECT D_INV_VACCINATION.* FROM D_INV_VACCINATION JOIN F_PAGE_CASE ON D_INV_VACCINATION.D_INV_VACCINATION_KEY = F_PAGE_CASE.INVESTIGATION_KEY JOIN INVESTIGATION ON F_PAGE_CASE.INVESTIGATION_KEY = INVESTIGATION.INVESTIGATION_KEY WHERE INVESTIGATION.LAST_CHG_TIME >= :timestamp;', 'SELECT TOP(:limit) D_INV_VACCINATION.* FROM D_INV_VACCINATION JOIN F_PAGE_CASE ON D_INV_VACCINATION.D_INV_VACCINATION_KEY = F_PAGE_CASE.INVESTIGATION_KEY JOIN INVESTIGATION ON F_PAGE_CASE.INVESTIGATION_KEY = INVESTIGATION.INVESTIGATION_KEY WHERE INVESTIGATION.LAST_CHG_TIME >= :timestamp ORDER BY INVESTIGATION.LAST_CHG_TIME ASC;'), ('F_INTERVIEW_CASE', 'RDB', 'SELECT F_INTERVIEW_CASE.* FROM F_INTERVIEW_CASE JOIN INVESTIGATION ON F_INTERVIEW_CASE.INVESTIGATION_KEY = INVESTIGATION.INVESTIGATION_KEY JOIN D_INTERVIEW ON F_INTERVIEW_CASE.D_INTERVIEW_KEY = D_INTERVIEW.D_INTERVIEW_KEY WHERE INVESTIGATION.LAST_CHG_TIME >= :timestamp OR D_INTERVIEW.ADD_TIME >= :timestamp OR D_INTERVIEW.LAST_CHG_TIME >= :timestamp;', 'SELECT TOP(:limit) F_INTERVIEW_CASE.* FROM F_INTERVIEW_CASE JOIN INVESTIGATION ON F_INTERVIEW_CASE.INVESTIGATION_KEY = INVESTIGATION.INVESTIGATION_KEY JOIN D_INTERVIEW ON F_INTERVIEW_CASE.D_INTERVIEW_KEY = D_INTERVIEW.D_INTERVIEW_KEY WHERE INVESTIGATION.LAST_CHG_TIME >= :timestamp OR D_INTERVIEW.ADD_TIME >= :timestamp OR D_INTERVIEW.LAST_CHG_TIME >= :timestamp ORDER BY CASE WHEN D_INTERVIEW.ADD_TIME >= :timestamp THEN D_INTERVIEW.ADD_TIME ELSE D_INTERVIEW.LAST_CHG_TIME END ASC;'), ('F_PAGE_CASE', 'RDB', 'SELECT F_PAGE_CASE.* FROM F_PAGE_CASE JOIN INVESTIGATION ON F_PAGE_CASE.INVESTIGATION_KEY = INVESTIGATION.INVESTIGATION_KEY WHERE INVESTIGATION.LAST_CHG_TIME >= :timestamp;', 'SELECT TOP(:limit) F_PAGE_CASE.* FROM F_PAGE_CASE JOIN INVESTIGATION ON F_PAGE_CASE.INVESTIGATION_KEY = INVESTIGATION.INVESTIGATION_KEY WHERE INVESTIGATION.LAST_CHG_TIME >= :timestamp ORDER BY INVESTIGATION.LAST_CHG_TIME ASC;'), ('F_STD_PAGE_CASE', 'RDB', 'SELECT F_STD_PAGE_CASE.* FROM F_STD_PAGE_CASE JOIN INVESTIGATION ON F_STD_PAGE_CASE.INVESTIGATION_KEY = INVESTIGATION.INVESTIGATION_KEY WHERE INVESTIGATION.LAST_CHG_TIME >= :timestamp;', 'SELECT TOP(:limit) F_STD_PAGE_CASE.* FROM F_STD_PAGE_CASE JOIN INVESTIGATION ON F_STD_PAGE_CASE.INVESTIGATION_KEY = INVESTIGATION.INVESTIGATION_KEY WHERE INVESTIGATION.LAST_CHG_TIME >= :timestamp ORDER BY INVESTIGATION.LAST_CHG_TIME ASC;'), ('TREATMENT', 'RDB', 'SELECT TREATMENT.* FROM TREATMENT JOIN TREATMENT_EVENT ON TREATMENT.TREATMENT_KEY = TREATMENT_EVENT.TREATMENT_KEY JOIN INVESTIGATION ON TREATMENT_EVENT.INVESTIGATION_KEY = INVESTIGATION.INVESTIGATION_KEY WHERE INVESTIGATION.LAST_CHG_TIME >= :timestamp;', 'SELECT TOP(:limit) TREATMENT.* FROM TREATMENT JOIN TREATMENT_EVENT ON TREATMENT.TREATMENT_KEY = TREATMENT_EVENT.TREATMENT_KEY JOIN INVESTIGATION ON TREATMENT_EVENT.INVESTIGATION_KEY = INVESTIGATION.INVESTIGATION_KEY WHERE INVESTIGATION.LAST_CHG_TIME >= :timestamp ORDER BY INVESTIGATION.LAST_CHG_TIME ASC;'), ('TREATMENT_EVENT', 'RDB', 'SELECT TREATMENT_EVENT.* FROM TREATMENT_EVENT JOIN INVESTIGATION ON TREATMENT_EVENT.INVESTIGATION_KEY = INVESTIGATION.INVESTIGATION_KEY WHERE INVESTIGATION.LAST_CHG_TIME >= :timestamp;', 'SELECT TOP(:limit) TREATMENT_EVENT.* FROM TREATMENT_EVENT JOIN INVESTIGATION ON TREATMENT_EVENT.INVESTIGATION_KEY = INVESTIGATION.INVESTIGATION_KEY WHERE INVESTIGATION.LAST_CHG_TIME >= :timestamp ORDER BY INVESTIGATION.LAST_CHG_TIME ASC;'), ('D_ORGANIZATION', 'RDB', 'SELECT * FROM D_ORGANIZATION WHERE D_ORGANIZATION.ORGANIZATION_LAST_CHANGE_TIME >= :timestamp;', 'SELECT TOP(:limit) * FROM D_ORGANIZATION WHERE D_ORGANIZATION.ORGANIZATION_LAST_CHANGE_TIME >= :timestamp ORDER BY D_ORGANIZATION.ORGANIZATION_LAST_CHANGE_TIME ASC;'), ('D_PROVIDER', 'RDB', 'SELECT * FROM D_PROVIDER WHERE D_PROVIDER.PROVIDER_LAST_CHANGE_TIME >= :timestamp;', 'SELECT TOP(:limit) * FROM D_PROVIDER WHERE D_PROVIDER.PROVIDER_LAST_CHANGE_TIME >= :timestamp ORDER BY D_PROVIDER.PROVIDER_LAST_CHANGE_TIME ASC;');