append union statement for crrt

Author: aegis301

mimic-iv/concepts/organfailure/kdigo_stages.sql

@@ -3,35 +3,35 @@
 -- Baseline creatinine is defined as the lowest creatinine in the past 7 days.
 
 -- get creatinine stages
-with cr_stg AS
+WITH cr_stg AS
 (
   SELECT
     cr.stay_id
     , cr.charttime
     , cr.creat_low_past_7day 
     , cr.creat_low_past_48hr
     , cr.creat
-    , case
+    , CASE
         -- 3x baseline
-        when cr.creat >= (cr.creat_low_past_7day*3.0) then 3
+        WHEN cr.creat >= (cr.creat_low_past_7day*3.0) THEN 3
         -- *OR* cr >= 4.0 with associated increase
-        when cr.creat >= 4
+        WHEN cr.creat >= 4
         -- For patients reaching Stage 3 by SCr >4.0 mg/dl
         -- require that the patient first achieve ... acute increase >= 0.3 within 48 hr
         -- *or* an increase of >= 1.5 times baseline
-        and (cr.creat_low_past_48hr <= 3.7 OR cr.creat >= (1.5*cr.creat_low_past_7day))
-            then 3 
+        AND (cr.creat_low_past_48hr <= 3.7 OR cr.creat >= (1.5*cr.creat_low_past_7day))
+            THEN 3 
         -- TODO: initiation of RRT
-        when cr.creat >= (cr.creat_low_past_7day*2.0) then 2
-        when cr.creat >= (cr.creat_low_past_48hr+0.3) then 1
-        when cr.creat >= (cr.creat_low_past_7day*1.5) then 1
-    else 0 end as aki_stage_creat
+        WHEN cr.creat >= (cr.creat_low_past_7day*2.0) THEN 2
+        WHEN cr.creat >= (cr.creat_low_past_48hr+0.3) THEN 1
+        WHEN cr.creat >= (cr.creat_low_past_7day*1.5) THEN 1
+    ELSE 0 END AS aki_stage_creat
   FROM `physionet-data.mimiciv_derived.kdigo_creatinine`
 )
 -- stages for UO / creat
-, uo_stg as
+, uo_stg AS
 (
-  select
+  SELECT
       uo.stay_id
     , uo.charttime
     , uo.weight
@@ -53,6 +53,16 @@ with cr_stg AS
   FROM `physionet-data.mimiciv_derived.kdigo_uo` uo
   INNER JOIN `physionet-data.mimiciv_icu.icustays` ie
     ON uo.stay_id = ie.stay_id
+),
+-- get CRRT data
+crrt_stg AS (
+  SELECT 
+	stay_id, 
+	charttime, 
+	CASE
+    	WHEN charttime IS NOT NULL THEN 3
+        ELSE NULL END AS aki_stage_crrt
+FROM `physionet-data.mimic_derived.crrt`
 )
 -- get all charttimes documented
 , tm_stg AS
@@ -64,18 +74,13 @@ with cr_stg AS
     SELECT
       stay_id, charttime
     FROM uo_stg
-),
--- get CRRT data
-crrt_stg AS (
-  SELECT 
-	stay_id, 
-	charttime, 
-	CASE
-    	WHEN charttime IS NOT NULL THEN 3
-        ELSE NULL END AS aki_stage_crrt
-FROM `physionet-data.mimic_derived.crrt`
+    UNION DISTINCT
+    SELECT
+      stay_id, charttime
+    FROM crrt_stg
+
 )
-select
+SELECT
     ie.subject_id
   , ie.hadm_id
   , ie.stay_id