33import pandas as pd
44from datetime import datetime
55from enum import IntEnum
6- from utils .data_validation import DataValidation
76
87
98class SqlQueryValues (IntEnum ):
@@ -52,7 +51,7 @@ def get_kit_id_from_db(
5251 "subjects_to_retrieve" : no_of_kits_to_retrieve ,
5352 }
5453
55- kit_id_df = DataValidation ().check_for_duplicate_records (query , params )
54+ kit_id_df = OracleDB ().execute_query (query , params )
5655
5756 return kit_id_df
5857
@@ -115,7 +114,7 @@ def get_kit_id_logged_from_db(smokescreen_properties: dict) -> pd.DataFrame:
115114 "subjects_to_retrieve" : smokescreen_properties ["c3_total_fit_kits_to_retrieve" ],
116115 }
117116
118- kit_id_df = DataValidation ().check_for_duplicate_records (query , params )
117+ kit_id_df = OracleDB ().execute_query (query , params )
119118
120119 return kit_id_df
121120
@@ -303,7 +302,7 @@ def get_subjects_for_appointments(subjects_to_retrieve: int) -> pd.DataFrame:
303302 "subjects_to_retrieve" : subjects_to_retrieve ,
304303 }
305304
306- subjects_df = DataValidation ().check_for_duplicate_records (query , params )
305+ subjects_df = OracleDB ().execute_query (query , params )
307306
308307 return subjects_df
309308
@@ -321,7 +320,7 @@ def get_subjects_with_booked_appointments(subjects_to_retrieve: int) -> pd.DataF
321320 subjects_df (pd.DataFrame): A pandas DataFrame containing the result of the query
322321 """
323322
324- query = """select a.appointment_date, s.subject_nhs_number , c.person_family_name, c.person_given_name
323+ query = """select distinct(s.subject_nhs_number), a.appointment_date , c.person_family_name, c.person_given_name
325324 from
326325 (select count(*), ds.screening_subject_id
327326 from
@@ -362,6 +361,6 @@ def get_subjects_with_booked_appointments(subjects_to_retrieve: int) -> pd.DataF
362361 "subjects_to_retrieve" : subjects_to_retrieve ,
363362 }
364363
365- subjects_df = DataValidation ().check_for_duplicate_records (query , params )
364+ subjects_df = OracleDB ().execute_query (query , params )
366365
367366 return subjects_df
0 commit comments