/********************************************************************************* # Copyright 2018-08 Observational Health Data Sciences and Informatics # # # Licensed under the Apache License, Version 2.0 (the "License"); # you may not use this file except in compliance with the License. # You may obtain a copy of the License at # # http://www.apache.org/licenses/LICENSE-2.0 # # Unless required by applicable law or agreed to in writing, software # distributed under the License is distributed on an "AS IS" BASIS, # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. # See the License for the specific language governing permissions and # limitations under the License. ********************************************************************************/ /************************ ####### # # ####### ###### ##### ###### # # ##### ### # # ## ## # # # # # # # # ## ## # # # # # # # # # # # # # # # # # # # # # # # # # # # # # # # # # # # ###### # # # # # # # # ###### # # # # # # # # # # # # # # # # # # ### # # # # # # # # # # # # # # # # # # # ### # # ####### # # ####### # ##### ###### # # ## ##### ### ### pdw script to create OMOP common data model version 6.0 last revised: 27-Aug-2018 Authors: Patrick Ryan, Christian Reich, Clair Blacketer *************************/ /************************ Standardized vocabulary ************************/ --HINT DISTRIBUTE ON RANDOM IF XACT_STATE() = 1 COMMIT; CREATE TABLE concept ( concept_id INTEGER NOT NULL , concept_name VARCHAR(255) NOT NULL , domain_id VARCHAR(20) NOT NULL , vocabulary_id VARCHAR(20) NOT NULL , concept_class_id VARCHAR(20) NOT NULL , standard_concept VARCHAR(1) NULL , concept_code VARCHAR(50) NOT NULL , valid_start_date DATE NOT NULL , valid_end_date DATE NOT NULL , invalid_reason VARCHAR(1) NULL ) WITH (DISTRIBUTION = REPLICATE); --HINT DISTRIBUTE ON RANDOM IF XACT_STATE() = 1 COMMIT; CREATE TABLE vocabulary ( vocabulary_id VARCHAR(20) NOT NULL, vocabulary_name VARCHAR(255) NOT NULL, vocabulary_reference VARCHAR(255) NOT NULL, vocabulary_version VARCHAR(255) NULL, vocabulary_concept_id INTEGER NOT NULL ) WITH (DISTRIBUTION = REPLICATE); --HINT DISTRIBUTE ON RANDOM IF XACT_STATE() = 1 COMMIT; CREATE TABLE domain ( domain_id VARCHAR(20) NOT NULL, domain_name VARCHAR(255) NOT NULL, domain_concept_id INTEGER NOT NULL ) WITH (DISTRIBUTION = REPLICATE); --HINT DISTRIBUTE ON RANDOM IF XACT_STATE() = 1 COMMIT; CREATE TABLE concept_class ( concept_class_id VARCHAR(20) NOT NULL, concept_class_name VARCHAR(255) NOT NULL, concept_class_concept_id INTEGER NOT NULL ) WITH (DISTRIBUTION = REPLICATE); --HINT DISTRIBUTE ON RANDOM IF XACT_STATE() = 1 COMMIT; CREATE TABLE concept_relationship ( concept_id_1 INTEGER NOT NULL, concept_id_2 INTEGER NOT NULL, relationship_id VARCHAR(20) NOT NULL, valid_start_date DATE NOT NULL, valid_end_date DATE NOT NULL, invalid_reason VARCHAR(1) NULL ) WITH (DISTRIBUTION = REPLICATE); --HINT DISTRIBUTE ON RANDOM IF XACT_STATE() = 1 COMMIT; CREATE TABLE relationship ( relationship_id VARCHAR(20) NOT NULL, relationship_name VARCHAR(255) NOT NULL, is_hierarchical VARCHAR(1) NOT NULL, defines_ancestry VARCHAR(1) NOT NULL, reverse_relationship_id VARCHAR(20) NOT NULL, relationship_concept_id INTEGER NOT NULL ) WITH (DISTRIBUTION = REPLICATE); --HINT DISTRIBUTE ON RANDOM IF XACT_STATE() = 1 COMMIT; CREATE TABLE concept_synonym ( concept_id INTEGER NOT NULL, concept_synonym_name VARCHAR(1000) NOT NULL, language_concept_id INTEGER NOT NULL ) WITH (DISTRIBUTION = REPLICATE); --HINT DISTRIBUTE ON RANDOM IF XACT_STATE() = 1 COMMIT; CREATE TABLE concept_ancestor ( ancestor_concept_id INTEGER NOT NULL, descendant_concept_id INTEGER NOT NULL, min_levels_of_separation INTEGER NOT NULL, max_levels_of_separation INTEGER NOT NULL ) WITH (DISTRIBUTION = REPLICATE); --HINT DISTRIBUTE ON RANDOM IF XACT_STATE() = 1 COMMIT; CREATE TABLE source_to_concept_map ( source_code VARCHAR(50) NOT NULL, source_concept_id INTEGER NOT NULL, source_vocabulary_id VARCHAR(20) NOT NULL, source_code_description VARCHAR(255) NULL, target_concept_id INTEGER NOT NULL, target_vocabulary_id VARCHAR(20) NOT NULL, valid_start_date DATE NOT NULL, valid_end_date DATE NOT NULL, invalid_reason VARCHAR(1) NULL ) WITH (DISTRIBUTION = REPLICATE); --HINT DISTRIBUTE ON RANDOM IF XACT_STATE() = 1 COMMIT; CREATE TABLE drug_strength ( drug_concept_id INTEGER NOT NULL, ingredient_concept_id INTEGER NOT NULL, amount_value FLOAT NULL, amount_unit_concept_id INTEGER NULL, numerator_value FLOAT NULL, numerator_unit_concept_id INTEGER NULL, denominator_value FLOAT NULL, denominator_unit_concept_id INTEGER NULL, box_size INTEGER NULL, valid_start_date DATE NOT NULL, valid_end_date DATE NOT NULL, invalid_reason VARCHAR(1) NULL ) WITH (DISTRIBUTION = REPLICATE); /************************** Standardized meta-data ***************************/ --HINT DISTRIBUTE ON RANDOM IF XACT_STATE() = 1 COMMIT; CREATE TABLE cdm_source ( cdm_source_name VARCHAR(255) NOT NULL , cdm_source_abbreviation VARCHAR(25) NULL , cdm_holder VARCHAR(255) NULL , source_description VARCHAR(1000) NULL , source_documentation_reference VARCHAR(255) NULL , cdm_etl_reference VARCHAR(255) NULL , source_release_date DATE NULL , cdm_release_date DATE NULL , cdm_version VARCHAR(10) NULL , vocabulary_version VARCHAR(20) NULL ) WITH (DISTRIBUTION = REPLICATE); --HINT DISTRIBUTE ON RANDOM IF XACT_STATE() = 1 COMMIT; CREATE TABLE metadata ( metadata_concept_id INTEGER NOT NULL , metadata_type_concept_id INTEGER NOT NULL , name VARCHAR(250) NOT NULL , value_as_string VARCHAR(1000) NULL , value_as_concept_id INTEGER NULL , metadata_date DATE NULL , metadata_datetime DATETIME2 NULL ) WITH (DISTRIBUTION = REPLICATE); INSERT INTO metadata (metadata_concept_id, metadata_type_concept_id, name, value_as_string, value_as_concept_id, metadata_date, metadata_datetime) VALUES (0, 0, 'CDM Version', '6.0', 0, NULL, NULL) ; /************************ Standardized clinical data ************************/ --HINT DISTRIBUTE_ON_KEY(person_id) IF XACT_STATE() = 1 COMMIT; CREATE TABLE person ( person_id BIGINT NOT NULL , gender_concept_id INTEGER NOT NULL , year_of_birth INTEGER NOT NULL , month_of_birth INTEGER NULL, day_of_birth INTEGER NULL, birth_datetime DATETIME2 NULL, death_datetime DATETIME2 NULL, race_concept_id INTEGER NOT NULL, ethnicity_concept_id INTEGER NOT NULL, location_id INTEGER NULL, provider_id INTEGER NULL, care_site_id INTEGER NULL, person_source_value VARCHAR(50) NULL, gender_source_value VARCHAR(50) NULL, gender_source_concept_id INTEGER NOT NULL, race_source_value VARCHAR(50) NULL, race_source_concept_id INTEGER NOT NULL, ethnicity_source_value VARCHAR(50) NULL, ethnicity_source_concept_id INTEGER NOT NULL ) WITH (DISTRIBUTION = HASH(person_id)); --HINT DISTRIBUTE_ON_KEY(person_id) IF XACT_STATE() = 1 COMMIT; CREATE TABLE observation_period ( observation_period_id BIGINT NOT NULL , person_id BIGINT NOT NULL , observation_period_start_date DATE NOT NULL , observation_period_end_date DATE NOT NULL , period_type_concept_id INTEGER NOT NULL ) WITH (DISTRIBUTION = HASH(person_id)); --HINT DISTRIBUTE_ON_KEY(person_id) IF XACT_STATE() = 1 COMMIT; CREATE TABLE specimen ( specimen_id BIGINT NOT NULL , person_id BIGINT NOT NULL , specimen_concept_id INTEGER NOT NULL , specimen_type_concept_id INTEGER NOT NULL , specimen_date DATE NULL , specimen_datetime DATETIME2 NOT NULL , quantity FLOAT NULL , unit_concept_id INTEGER NULL , anatomic_site_concept_id INTEGER NOT NULL , disease_status_concept_id INTEGER NOT NULL , specimen_source_id VARCHAR(50) NULL , specimen_source_value VARCHAR(50) NULL , unit_source_value VARCHAR(50) NULL , anatomic_site_source_value VARCHAR(50) NULL , disease_status_source_value VARCHAR(50) NULL ) WITH (DISTRIBUTION = HASH(person_id)); --HINT DISTRIBUTE_ON_KEY(person_id) IF XACT_STATE() = 1 COMMIT; CREATE TABLE visit_occurrence ( visit_occurrence_id BIGINT NOT NULL , person_id BIGINT NOT NULL , visit_concept_id INTEGER NOT NULL , visit_start_date DATE NULL , visit_start_datetime DATETIME2 NOT NULL , visit_end_date DATE NULL , visit_end_datetime DATETIME2 NOT NULL , visit_type_concept_id INTEGER NOT NULL , provider_id INTEGER NULL, care_site_id INTEGER NULL, visit_source_value VARCHAR(50) NULL, visit_source_concept_id INTEGER NOT NULL , admitted_from_concept_id INTEGER NOT ULL , admitted_from_source_value VARCHAR(50) NULL , discharge_to_source_value VARCHAR(50) NULL , discharge_to_concept_id INTEGER NOT NULL , preceding_visit_occurrence_id INTEGER NULL ) WITH (DISTRIBUTION = HASH(person_id)); --HINT DISTRIBUTE_ON_KEY(person_id) IF XACT_STATE() = 1 COMMIT; CREATE TABLE visit_detail ( visit_detail_id BIGINT NOT NULL , person_id BIGINT NOT NULL , visit_detail_concept_id INTEGER NOT NULL , visit_detail_start_date DATE NULL , visit_detail_start_datetime DATETIME2 NOT NULL , visit_detail_end_date DATE NULL , visit_detail_end_datetime DATETIME2 NOT NULL , visit_detail_type_concept_id INTEGER NOT NULL , provider_id INTEGER NULL , care_site_id INTEGER NULL , discharge_to_concept_id INTEGER NOT NULL , admitted_from_concept_id INTEGER NOT NULL , admitted_from_source_value VARCHAR(50) NULL , visit_detail_source_value VARCHAR(50) NULL , visit_detail_source_concept_id INTEGER NOT NULL , discharge_to_source_value VARCHAR(50) NULL , preceding_visit_detail_id BIGINT NULL , visit_detail_parent_id BIGINT NULL , visit_occurrence_id BIGINT NOT NULL ) WITH (DISTRIBUTION = HASH(person_id)); --HINT DISTRIBUTE_ON_KEY(person_id) IF XACT_STATE() = 1 COMMIT; CREATE TABLE procedure_occurrence ( procedure_occurrence_id BIGINT NOT NULL , person_id BIGINT NOT NULL , procedure_concept_id INTEGER NOT NULL , procedure_date DATE NULL , procedure_datetime DATETIME2 NOT NULL , procedure_type_concept_id INTEGER NOT NULL , modifier_concept_id INTEGER NOT NULL , quantity INTEGER NULL , provider_id INTEGER NULL , visit_occurrence_id INTEGER NULL , visit_detail_id INTEGER NULL , procedure_source_value VARCHAR(50) NULL , procedure_source_concept_id INTEGER NOT NULL , modifier_source_value VARCHAR(50) NULL ) WITH (DISTRIBUTION = HASH(person_id)); --HINT DISTRIBUTE_ON_KEY(person_id) IF XACT_STATE() = 1 COMMIT; CREATE TABLE drug_exposure ( drug_exposure_id BIGINT NOT NULL , person_id BIGINT NOT NULL , drug_concept_id INTEGER NOT NULL , drug_exposure_start_date DATE NULL , drug_exposure_start_datetime DATETIME2 NOT NULL , drug_exposure_end_date DATE NULL , drug_exposure_end_datetime DATETIME2 NOT NULL , verbatim_end_date DATE NULL , drug_type_concept_id INTEGER NOT NULL , stop_reason VARCHAR(20) NULL , refills INTEGER NULL , quantity FLOAT NULL , days_supply INTEGER NULL , sig VARCHAR(1000) NULL , route_concept_id INTEGER NOT NULL , lot_number VARCHAR(50) NULL , provider_id INTEGER NULL , visit_occurrence_id INTEGER NULL , visit_detail_id INTEGER NULL , drug_source_value VARCHAR(50) NULL , drug_source_concept_id INTEGER NOT NULL , route_source_value VARCHAR(50) NULL , dose_unit_source_value VARCHAR(50) NULL ) WITH (DISTRIBUTION = HASH(person_id)); --HINT DISTRIBUTE_ON_KEY(person_id) IF XACT_STATE() = 1 COMMIT; CREATE TABLE device_exposure ( device_exposure_id BIGINT NOT NULL , person_id BIGINT NOT NULL , device_concept_id INTEGER NOT NULL , device_exposure_start_date DATE NULL , device_exposure_start_datetime DATETIME2 NOT NULL , device_exposure_end_date DATE NULL , device_exposure_end_datetime DATETIME2 NULL , device_type_concept_id INTEGER NOT NULL , unique_device_id VARCHAR(50) NULL , quantity INTEGER NULL , provider_id INTEGER NULL , visit_occurrence_id INTEGER NULL , visit_detail_id INTEGER NULL , device_source_value VARCHAR(100) NULL , device_source_concept_id INTEGER NOT NULL ) WITH (DISTRIBUTION = HASH(person_id)); --HINT DISTRIBUTE_ON_KEY(person_id) IF XACT_STATE() = 1 COMMIT; CREATE TABLE condition_occurrence ( condition_occurrence_id BIGINT NOT NULL , person_id BIGINT NOT NULL , condition_concept_id INTEGER NOT NULL , condition_start_date DATE NULL , condition_start_datetime DATETIME2 NOT NULL , condition_end_date DATE NULL , condition_end_datetime DATETIME2 NULL , condition_type_concept_id INTEGER NOT NULL , condition_status_concept_id INTEGER NOT NULL , stop_reason VARCHAR(20) NULL , provider_id INTEGER NULL , visit_occurrence_id INTEGER NULL , visit_detail_id INTEGER NULL , condition_source_value VARCHAR(50) NULL , condition_source_concept_id INTEGER NOT NULL , condition_status_source_value VARCHAR(50) NULL ) WITH (DISTRIBUTION = HASH(person_id)); --HINT DISTRIBUTE_ON_KEY(person_id) IF XACT_STATE() = 1 COMMIT; CREATE TABLE measurement ( measurement_id BIGINT NOT NULL , person_id BIGINT NOT NULL , measurement_concept_id INTEGER NOT NULL , measurement_date DATE NULL , measurement_datetime DATETIME2 NOT NULL , measurement_time VARCHAR(10) NULL, measurement_type_concept_id INTEGER NOT NULL , operator_concept_id INTEGER NULL , value_as_number FLOAT NULL , value_as_concept_id INTEGER NULL , unit_concept_id INTEGER NULL , range_low FLOAT NULL , range_high FLOAT NULL , provider_id INTEGER NULL , visit_occurrence_id INTEGER NULL , visit_detail_id INTEGER NULL , measurement_source_value VARCHAR(50) NULL , measurement_source_concept_id INTEGER NOT NULL , unit_source_value VARCHAR(50) NULL , value_source_value VARCHAR(50) NULL ) WITH (DISTRIBUTION = HASH(person_id)); --HINT DISTRIBUTE_ON_KEY(person_id) IF XACT_STATE() = 1 COMMIT; CREATE TABLE note ( note_id BIGINT NOT NULL , person_id BIGINT NOT NULL , note_event_id BIGINT NULL , note_event_field_concept_id INTEGER NOT NULL , note_date DATE NULL , note_datetime DATETIME2 NOT NULL , note_type_concept_id INTEGER NOT NULL , note_class_concept_id INTEGER NOT NULL , note_title VARCHAR(250) NULL , note_text VARCHAR(1000) NULL , encoding_concept_id INTEGER NOT NULL , language_concept_id INTEGER NOT NULL , provider_id INTEGER NULL , visit_occurrence_id INTEGER NULL , visit_detail_id INTEGER NULL , note_source_value VARCHAR(50) NULL ) WITH (DISTRIBUTION = HASH(person_id)); --HINT DISTRIBUTE ON RANDOM IF XACT_STATE() = 1 COMMIT; CREATE TABLE note_nlp ( note_nlp_id BIGINT NOT NULL , note_id BIGINT NOT NULL , section_concept_id INTEGER NOT NULL , snippet VARCHAR(250) NULL , "offset" VARCHAR(250) NULL , lexical_variant VARCHAR(250) NOT NULL , note_nlp_concept_id INTEGER NOT NULL , nlp_system VARCHAR(250) NULL , nlp_date DATE NOT NULL , nlp_datetime DATETIME2 NULL , term_exists VARCHAR(1) NULL , term_temporal VARCHAR(50) NULL , term_modifiers VARCHAR(2000) NULL , note_nlp_source_concept_id INTEGER NOT NULL ) WITH (DISTRIBUTION = REPLICATE); --HINT DISTRIBUTE_ON_KEY(person_id) IF XACT_STATE() = 1 COMMIT; CREATE TABLE observation ( observation_id BIGINT NOT NULL , person_id BIGINT NOT NULL , observation_concept_id INTEGER NOT NULL , observation_date DATE NULL , observation_datetime DATETIME2 NOT NULL , observation_type_concept_id INTEGER NOT NULL , value_as_number FLOAT NULL , value_as_string VARCHAR(60) NULL , value_as_concept_id INTEGER NULL , qualifier_concept_id INTEGER NULL , unit_concept_id INTEGER NULL , provider_id INTEGER NULL , visit_occurrence_id BIGINT NULL , visit_detail_id BIGINT NULL , observation_source_value VARCHAR(50) NULL , observation_source_concept_id INTEGER NOT NULL , unit_source_value VARCHAR(50) NULL , qualifier_source_value VARCHAR(50) NULL , observation_event_id BIGINT NULL , obs_event_field_concept_id INTEGER NOT NULL , value_as_datetime DATETIME2 NULL ) WITH (DISTRIBUTION = HASH(person_id)); --HINT DISTRIBUTE ON KEY(person_id) IF XACT_STATE() = 1 COMMIT; CREATE TABLE survey_conduct ( survey_conduct_id BIGINT NOT NULL , person_id BIGINT NOT NULL , survey_concept_id INTEGER NOT NULL , survey_start_date DATE NULL , survey_start_datetime DATETIME2 NULL , survey_end_date DATE NULL , survey_end_datetime DATETIME2 NOT NULL , provider_id BIGINT NULL , assisted_concept_id INTEGER NOT NULL , respondent_type_concept_id INTEGER NOT NULL , timing_concept_id INTEGER NOT NULL , collection_method_concept_id INTEGER NOT NULL , assisted_source_value VARCHAR(50) NULL , respondent_type_source_value VARCHAR(100) NULL , timing_source_value VARCHAR(100) NULL , collection_method_source_value VARCHAR(100) NULL , survey_source_value VARCHAR(100) NULL , survey_source_concept_id INTEGER NOT NULL , survey_source_identifier VARCHAR(100) NULL , validated_survey_concept_id INTEGER NOT NULL , validated_survey_source_value VARCHAR(100) NULL , survey_version_number VARCHAR(20) NULL , visit_occurrence_id BIGINT NULL , visit_detail_id BIGINT NULL , response_visit_occurrence_id BIGINT NULL ) WITH (DISTRIBUTION = HASH(person_id)); --HINT DISTRIBUTE ON RANDOM IF XACT_STATE() = 1 COMMIT; CREATE TABLE fact_relationship ( domain_concept_id_1 INTEGER NOT NULL , fact_id_1 BIGINT NOT NULL , domain_concept_id_2 INTEGER NOT NULL , fact_id_2 BIGINT NOT NULL , relationship_concept_id INTEGER NOT NULL ) WITH (DISTRIBUTION = REPLICATE); /************************ Standardized health system data ************************/ --HINT DISTRIBUTE ON RANDOM IF XACT_STATE() = 1 COMMIT; CREATE TABLE location ( location_id BIGINT NOT NULL , address_1 VARCHAR(50) NULL , address_2 VARCHAR(50) NULL , city VARCHAR(50) NULL , state VARCHAR(2) NULL , zip VARCHAR(9) NULL , county VARCHAR(20) NULL , country VARCHAR(100) NULL , location_source_value VARCHAR(50) NULL , latitude FLOAT NULL , longitude FLOAT NULL ) WITH (DISTRIBUTION = REPLICATE); --HINT DISTRIBUTE ON RANDOM IF XACT_STATE() = 1 COMMIT; CREATE TABLE location_history ( location_history_id BIGINT NOT NULL , location_id BIGINT NOT NULL , relationship_type_concept_id INTEGER NOT NULL , domain_id VARCHAR(50) NOT NULL , entity_id BIGINT NOT NULL , start_date DATE NOT NULL , end_date DATE NULL ) WITH (DISTRIBUTION = REPLICATE); --HINT DISTRIBUTE ON RANDOM IF XACT_STATE() = 1 COMMIT; CREATE TABLE care_site ( care_site_id BIGINT NOT NULL , care_site_name VARCHAR(255) NULL , place_of_service_concept_id INTEGER NOT NULL , location_id BIGINT NULL , care_site_source_value VARCHAR(50) NULL , place_of_service_source_value VARCHAR(50) NULL ) WITH (DISTRIBUTION = REPLICATE); --HINT DISTRIBUTE ON RANDOM IF XACT_STATE() = 1 COMMIT; CREATE TABLE provider ( provider_id BIGINT NOT NULL , provider_name VARCHAR(255) NULL , NPI VARCHAR(20) NULL , DEA VARCHAR(20) NULL , specialty_concept_id INTEGER NOT NULL , care_site_id BIGINT NULL , year_of_birth INTEGER NULL , gender_concept_id INTEGER NOT NULL , provider_source_value VARCHAR(50) NULL , specialty_source_value VARCHAR(50) NULL , specialty_source_concept_id INTEGER NOT NULL , gender_source_value VARCHAR(50) NULL , gender_source_concept_id INTEGER NOT NULL ) WITH (DISTRIBUTION = REPLICATE); /************************ Standardized health economics ************************/ --HINT DISTRIBUTE_ON_KEY(person_id) IF XACT_STATE() = 1 COMMIT; CREATE TABLE payer_plan_period ( payer_plan_period_id BIGINT NOT NULL , person_id BIGINT NOT NULL , contract_person_id BIGINT NULL , payer_plan_period_start_date DATE NOT NULL , payer_plan_period_end_date DATE NOT NULL , payer_concept_id INTEGER NOT NULL , plan_concept_id INTEGER NOT NULL , contract_concept_id INTEGER NOT NULL , sponsor_concept_id INTEGER NOT NULL , stop_reason_concept_id INTEGER NOT NULL , payer_source_value VARCHAR(50) NULL , payer_source_concept_id INTEGER NOT NULL , plan_source_value VARCHAR(50) NULL , plan_source_concept_id INTEGER NOT NULL , contract_source_value VARCHAR(50) NULL , contract_source_concept_id INTEGER NOT NULL , sponsor_source_value VARCHAR(50) NULL , sponsor_source_concept_id INTEGER NOT NULL , family_source_value VARCHAR(50) NULL , stop_reason_source_value VARCHAR(50) NULL , stop_reason_source_concept_id INTEGER NOT NULL ) WITH (DISTRIBUTION = HASH(person_id)); --HINT DISTRIBUTE ON KEY(person_id) IF XACT_STATE() = 1 COMMIT; CREATE TABLE cost ( cost_id BIGINT NOT NULL , person_id BIGINT NOT NULL, cost_event_id BIGINT NOT NULL , cost_event_field_concept_id INTEGER NOT NULL , cost_concept_id INTEGER NOT NULL , cost_type_concept_id INTEGER NOT NULL , currency_concept_id INTEGER NOT NULL , cost FLOAT NULL , incurred_date DATE NOT NULL , billed_date DATE NULL , paid_date DATE NULL , revenue_code_concept_id INTEGER NOT NULL , drg_concept_id INTEGER NOT NULL , cost_source_value VARCHAR(50) NULL , cost_source_concept_id INTEGER NOT NULL , revenue_code_source_value VARCHAR(50) NULL , drg_source_value VARCHAR(3) NULL , payer_plan_period_id BIGINT NULL ) WITH (DISTRIBUTION = HASH(person_id)); /************************ Standardized derived elements ************************/ --HINT DISTRIBUTE_ON_KEY(person_id) IF XACT_STATE() = 1 COMMIT; CREATE TABLE drug_era ( drug_era_id BIGINT NOT NULL , person_id BIGINT NOT NULL , drug_concept_id INTEGER NOT NULL , drug_era_start_datetime DATETIME2 NOT NULL , drug_era_end_datetime DATETIME2 NOT NULL , drug_exposure_count INTEGER NULL , gap_days INTEGER NULL ) WITH (DISTRIBUTION = HASH(person_id)); --HINT DISTRIBUTE_ON_KEY(person_id) IF XACT_STATE() = 1 COMMIT; CREATE TABLE dose_era ( dose_era_id BIGINT NOT NULL , person_id BIGINT NOT NULL , drug_concept_id INTEGER NOT NULL , unit_concept_id INTEGER NOT NULL , dose_value FLOAT NOT NULL , dose_era_start_datetime DATETIME2 NOT NULL , dose_era_end_datetime DATETIME2 NOT NULL ) WITH (DISTRIBUTION = HASH(person_id)); --HINT DISTRIBUTE_ON_KEY(person_id) IF XACT_STATE() = 1 COMMIT; CREATE TABLE condition_era ( condition_era_id BIGINT NOT NULL , person_id BIGINT NOT NULL , condition_concept_id INTEGER NOT NULL , condition_era_start_datetime DATETIME2 NOT NULL , condition_era_end_datetime DATETIME2 NOT NULL , condition_occurrence_count INTEGER NULL ) WITH (DISTRIBUTION = HASH(person_id));