change query to add age_binned from participant table

KPMP · Oct 29, 2024 · 822ae5e · 822ae5e
1 parent e7a1702
commit 822ae5e
Show file tree

Hide file tree

Showing 5 changed files with 36 additions and 1 deletion.
diff --git a/src/main/java/org/kpmp/participant/ParticipantClinicalDataset.java b/src/main/java/org/kpmp/participant/ParticipantClinicalDataset.java
@@ -37,6 +37,8 @@ public class ParticipantClinicalDataset implements Serializable{
     private String onRaasBlockade;
     @Column(name = "race")
     private String race;
+    @Column(name = "age_binned")
+    private String ageBinned;
 
 
     public int getParticipantClinicalId() {
@@ -142,6 +144,14 @@ public void setRace(String race){
     public String getRace() {
         return race;
     }
+
+    public String getAgeBinned() {
+        return this.ageBinned;
+    }
+
+    public void setAgeBinned(String ageBinned) {
+        this.ageBinned = ageBinned;
+    }
 
 }
 
diff --git a/src/main/java/org/kpmp/participant/ParticipantClinicalDatasetRepository.java b/src/main/java/org/kpmp/participant/ParticipantClinicalDatasetRepository.java
@@ -10,6 +10,22 @@
 public interface ParticipantClinicalDatasetRepository extends CrudRepository<ParticipantClinicalDataset, Long> {
 
 	@Cacheable("participantById")
-    @Query(value = "select * from participant_clinical where participant_id= :participantId", nativeQuery = true)
+    @Query(value = "SELECT " + 
+                "pc.participant_clinical_id, " + 
+                "pc.participant_id, " + 
+                "pc.kdigo_stage," + 
+                "pc.baseline_egfr, " + 
+                "pc.proteinuria," + 
+                "pc.a1c, " + 
+                "pc.albuminuria, " + 
+                "pc.diabetes_history," + 
+                "pc.diabetes_duration, " + 
+                "pc.hypertension_history," +
+                "pc.hypertension_duration, " +
+                "pc.on_raas_blockade," + 
+                "pc.race, " + 
+                "p.age_binned " + 
+                "from participant_clinical pc join participant p on pc.participant_id = p.participant_id where pc.participant_id = :participantId ", nativeQuery = true)
 	ParticipantClinicalDataset findByParticipantId(@Param("participantId") Integer participantId);
+
 }
diff --git a/src/main/resources/graphql/knowledge_environment.graphqls b/src/main/resources/graphql/knowledge_environment.graphqls
@@ -237,4 +237,5 @@ type ParticipantClinicalDataset {
     hypertensionDuration: String
     onRaasBlockade: String
     race: String
+    ageBinned: String
 }
diff --git a/src/test/java/org/kpmp/participant/ParticipantClinicalDatasetTest.java b/src/test/java/org/kpmp/participant/ParticipantClinicalDatasetTest.java
@@ -98,5 +98,11 @@ void testSetRace(){
         participantClinicalDataset.setRace("alien from outer space");
         assertEquals("alien from outer space", participantClinicalDataset.getRace());
     }
+
+    @Test
+    void testSetAgeBinned() {
+        participantClinicalDataset.setAgeBinned("age-age2");
+        assertEquals("age-age2", participantClinicalDataset.getAgeBinned());
+    }
 
 }
diff --git a/src/test/java/org/kpmp/participant/ParticipantServiceTest.java b/src/test/java/org/kpmp/participant/ParticipantServiceTest.java
@@ -73,6 +73,7 @@ public void testGetParticipantClincialDataset() throws Exception {
         expectedResult.setParticipantId(99);
         expectedResult.setProteinuria("proteinuria");
         expectedResult.setRace("alien from outer space");
+        expectedResult.setAgeBinned("age");
 
 
         when(participantSummaryDatasetRepository.findIdByRedcapId(newPart.getRedcapId())).thenReturn(newPart.getParticipantId());
@@ -92,6 +93,7 @@ public void testGetParticipantClincialDataset() throws Exception {
         assertEquals("Yes", result.getOnRaasBlockade());
         assertEquals("proteinuria", result.getProteinuria());
         assertEquals("alien from outer space", result.getRace());
+        assertEquals("age", result.getAgeBinned());
     }
 
 	@Test