Skip to content
Open
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
18 changes: 9 additions & 9 deletions etl/playground/znt_score_vitamined.sql
Original file line number Diff line number Diff line change
Expand Up @@ -9,15 +9,15 @@

-- MOV_EVENTS: Extracció de mov_events de datalake per carregar al p_zero datascope
with znt_colap as (
(select distinct patient_ref from datascope.znt_score)
(select distinct patient_ref from datascope.znt_scope)
)
SELECT * FROM datascope.mov_events
where patient_ref in (select patient_ref from znt_colap)
and date(start_date) > '2020-06-01'

-- CARE_LEVEL_EVENTS: Extracció de care_level_events de datalake per carregar al p_zero datascope
with znt_colap as (
(select distinct patient_ref from datascope.znt_score)
(select distinct patient_ref from datascope.znt_scope)
)
SELECT * FROM datascope.care_level_events
where patient_ref in (select patient_ref from znt_colap)
Expand All @@ -27,7 +27,7 @@ and date(start_date) > '2020-06-01'

-- EPISODE_EVENTS: extracció taula episode_events
with znt_colap as (
(select distinct patient_ref from datascope.znt_score)
(select distinct patient_ref from datascope.znt_scope)
)
SELECT * FROM datascope.episodi_events
where patient_ref in (select patient_ref from znt_colap)
Expand All @@ -37,7 +37,7 @@ and date(start_date) > '2020-06-01'
-- extracció diagnostics de datascope (mysql)

with znt_colap as (
(select distinct patient_ref from datascope.znt_score)
(select distinct patient_ref from datascope.znt_scope)
)
SELECT * FROM datascope.diag_events
where patient_ref in (select patient_ref from znt_colap)
Expand All @@ -56,11 +56,11 @@ SELECT * FROM datascope.diag_sap_dic;
-------------------------------------- BASE TABLES CREATE + INGESTIONS--------------------------------------


--- ZNT_SCORE
--- ZNT_SCOPE

DROP TABLE IF EXISTS data_scope.znt_score;
DROP TABLE IF EXISTS data_scope.znt_scope;

CREATE TABLE data_scope.znt_score (
CREATE TABLE data_scope.znt_scope (

id varchar DEFAULT NULL,
MANDT int DEFAULT NULL,
Expand All @@ -82,7 +82,7 @@ CREATE TABLE data_scope.znt_score (

);

copy data_scope.znt_score FROM '/home/admin/xavi_cabin/znt_score.csv' DELIMITER ',' CSV HEADER;
copy data_scope.znt_scope FROM '/home/admin/xavi_cabin/znt_scope.csv' DELIMITER ',' CSV HEADER;



Expand Down Expand Up @@ -387,4 +387,4 @@ FROM data_scope.diag_events
JOIN data_scope.diag_dic using(diag_ref)
where cie = 'CIE-10'
order by patient_ref,reg_date
)
)