diff --git a/dataloader/load_data_expanded_access.cypher b/dataloader/load_data_expanded_access.cypher index e0b7070..17c72fa 100644 --- a/dataloader/load_data_expanded_access.cypher +++ b/dataloader/load_data_expanded_access.cypher @@ -1,9 +1,9 @@ -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+NOT+AREA%5BStudyType%5DInterventional+AND+NOT+AREA%5BStudyType%5DObservational&fields=NCTId&fmt=json&max_rnk=1000') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=NOT+AREA%5BStudyType%5DInterventional+AND+NOT+AREA%5BStudyType%5DObservational&fields=NCTId&fmt=json&max_rnk=1000') yield value with value.StudyFieldsResponse.NStudiesFound as NStudies, RANGE(0,(value.StudyFieldsResponse.NStudiesFound/1000)) as nloop UNWIND nloop as i with range(1+1000*i,1000+1000*i,999) as RANGES with RANGES, RANGES[1] as urange, RANGES[0] as lrange -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+NOT+AREA%5BStudyType%5DInterventional+AND+NOT+AREA%5BStudyType%5DObservational&fields=NCTId,OrgStudyId,BriefTitle,Acronym,OfficialTitle,StudyType&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=NOT+AREA%5BStudyType%5DInterventional+AND+NOT+AREA%5BStudyType%5DObservational&fields=NCTId,OrgStudyId,BriefTitle,Acronym,OfficialTitle,StudyType&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value with value.StudyFieldsResponse.StudyFields as coll unwind coll as study_metadata UNWIND study_metadata.NCTId as Id UNWIND study_metadata.StudyType as StudyType @@ -23,12 +23,12 @@ with si, study_metadata UNWIND study_metadata.Acronym as Acronym set si.acronym=Acronym ; -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+NOT+AREA%5BStudyType%5DInterventional+AND+NOT+AREA%5BStudyType%5DObservational&fields=NCTId&fmt=json&max_rnk=1000') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=NOT+AREA%5BStudyType%5DInterventional+AND+NOT+AREA%5BStudyType%5DObservational&fields=NCTId&fmt=json&max_rnk=1000') yield value with value.StudyFieldsResponse.NStudiesFound as NStudies, RANGE(0,(value.StudyFieldsResponse.NStudiesFound/1000)) as nloop UNWIND nloop as i with range(1+1000*i,1000+1000*i,999) as RANGES with RANGES, RANGES[1] as urange, RANGES[0] as lrange -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+NOT+AREA%5BStudyType%5DInterventional+AND+NOT+AREA%5BStudyType%5DObservational&fields=NCTId,OverallStatus,WhyStopped,StartDate,PrimaryCompletionDate,CompletionDate&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=NOT+AREA%5BStudyType%5DInterventional+AND+NOT+AREA%5BStudyType%5DObservational&fields=NCTId,OverallStatus,WhyStopped,StartDate,PrimaryCompletionDate,CompletionDate&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value with value.StudyFieldsResponse.StudyFields as coll unwind coll as study_metadata UNWIND study_metadata.NCTId as Id match(ct:ClinicalTrial{NCTId:Id}) @@ -48,12 +48,12 @@ UNWIND study_metadata.WhyStopped as WhyStopped MERGE(ct)-[:WAS_STOPPED]->(r:StopReason{reason:WhyStopped}) MERGE(s)-[:HAS_REASON]->(r) ; -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+NOT+AREA%5BStudyType%5DInterventional+AND+NOT+AREA%5BStudyType%5DObservational&fields=NCTId&fmt=json&max_rnk=1000') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=NOT+AREA%5BStudyType%5DInterventional+AND+NOT+AREA%5BStudyType%5DObservational&fields=NCTId&fmt=json&max_rnk=1000') yield value with value.StudyFieldsResponse.NStudiesFound as NStudies, RANGE(0,(value.StudyFieldsResponse.NStudiesFound/1000)) as nloop UNWIND nloop as i with range(1+1000*i,1000+1000*i,999) as RANGES with RANGES, RANGES[1] as urange, RANGES[0] as lrange -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+NOT+AREA%5BStudyType%5DInterventional+AND+NOT+AREA%5BStudyType%5DObservational&fields=NCTId,ResponsiblePartyType,ResponsiblePartyInvestigatorFullName,ResponsiblePartyInvestigatorAffiliation,LeadSponsorName,CollaboratorName&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=NOT+AREA%5BStudyType%5DInterventional+AND+NOT+AREA%5BStudyType%5DObservational&fields=NCTId,ResponsiblePartyType,ResponsiblePartyInvestigatorFullName,ResponsiblePartyInvestigatorAffiliation,LeadSponsorName,CollaboratorName&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value with value.StudyFieldsResponse.StudyFields as coll unwind coll as study_metadata UNWIND study_metadata.ResponsiblePartyType as ResponsiblePartyType MERGE(r:Responsible{type:ResponsiblePartyType}) @@ -77,12 +77,12 @@ FOREACH(ignoreMe IN CASE WHEN r.type='Sponsor-Investigator' THEN [1] ELSE [] END MERGE(r)-[:IS_RESPONSIBLE]->(k) MERGE(r)-[:IS_RESPONSIBLE]->(i)) ; -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+NOT+AREA%5BStudyType%5DInterventional+AND+NOT+AREA%5BStudyType%5DObservational&fields=NCTId&fmt=json&max_rnk=1000') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=NOT+AREA%5BStudyType%5DInterventional+AND+NOT+AREA%5BStudyType%5DObservational&fields=NCTId&fmt=json&max_rnk=1000') yield value with value.StudyFieldsResponse.NStudiesFound as NStudies, RANGE(0,(value.StudyFieldsResponse.NStudiesFound/1000)) as nloop UNWIND nloop as i with range(1+1000*i,1000+1000*i,999) as RANGES with RANGES, RANGES[1] as urange, RANGES[0] as lrange -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+NOT+AREA%5BStudyType%5DInterventional+AND+NOT+AREA%5BStudyType%5DObservational&fields=NCTId,ResponsiblePartyType,ResponsiblePartyInvestigatorFullName,ResponsiblePartyInvestigatorAffiliation,LeadSponsorName,CollaboratorName&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=NOT+AREA%5BStudyType%5DInterventional+AND+NOT+AREA%5BStudyType%5DObservational&fields=NCTId,ResponsiblePartyType,ResponsiblePartyInvestigatorFullName,ResponsiblePartyInvestigatorAffiliation,LeadSponsorName,CollaboratorName&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value with value.StudyFieldsResponse.StudyFields as coll unwind coll as study_metadata UNWIND study_metadata.NCTId as Id match(ct:ClinicalTrial{NCTId:Id}) @@ -94,12 +94,12 @@ MERGE(r:Response{YN:'Yes'}) ; MERGE(k:Response{YN:'No'}) ; -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+NOT+AREA%5BStudyType%5DInterventional+AND+NOT+AREA%5BStudyType%5DObservational&fields=NCTId&fmt=json&max_rnk=1000') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=NOT+AREA%5BStudyType%5DInterventional+AND+NOT+AREA%5BStudyType%5DObservational&fields=NCTId&fmt=json&max_rnk=1000') yield value with value.StudyFieldsResponse.NStudiesFound as NStudies, RANGE(0,(value.StudyFieldsResponse.NStudiesFound/1000)) as nloop UNWIND nloop as i with range(1+1000*i,1000+1000*i,999) as RANGES with RANGES, RANGES[1] as urange, RANGES[0] as lrange -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+NOT+AREA%5BStudyType%5DInterventional+AND+NOT+AREA%5BStudyType%5DObservational&fields=NCTId,IsFDARegulatedDrug,IsFDARegulatedDevice,IsUnapprovedDevice,HasExpandedAccess&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=NOT+AREA%5BStudyType%5DInterventional+AND+NOT+AREA%5BStudyType%5DObservational&fields=NCTId,IsFDARegulatedDrug,IsFDARegulatedDevice,IsUnapprovedDevice,HasExpandedAccess&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value with value.StudyFieldsResponse.StudyFields as coll unwind coll as study_metadata UNWIND study_metadata.NCTId as Id match(ct:ClinicalTrial{NCTId:Id}), (r:Response{YN:'Yes'}) @@ -113,12 +113,12 @@ UNWIND study_metadata.IsUnapprovedDevice as IsUnapprovedDevice FOREACH(ignoreMe IN CASE WHEN IsUnapprovedDevice='No' THEN [1] ELSE [] END | MERGE(ct)-[:IS_FDA_UNAPPROVED_DEVICE]->(r)) ; -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+NOT+AREA%5BStudyType%5DInterventional+AND+NOT+AREA%5BStudyType%5DObservational&fields=NCTId&fmt=json&max_rnk=1000') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=NOT+AREA%5BStudyType%5DInterventional+AND+NOT+AREA%5BStudyType%5DObservational&fields=NCTId&fmt=json&max_rnk=1000') yield value with value.StudyFieldsResponse.NStudiesFound as NStudies, RANGE(0,(value.StudyFieldsResponse.NStudiesFound/1000)) as nloop UNWIND nloop as i with range(1+1000*i,1000+1000*i,999) as RANGES with RANGES, RANGES[1] as urange, RANGES[0] as lrange -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+NOT+AREA%5BStudyType%5DInterventional+AND+NOT+AREA%5BStudyType%5DObservational&fields=NCTId,IsFDARegulatedDrug,IsFDARegulatedDevice,IsUnapprovedDevice,HasExpandedAccess&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=NOT+AREA%5BStudyType%5DInterventional+AND+NOT+AREA%5BStudyType%5DObservational&fields=NCTId,IsFDARegulatedDrug,IsFDARegulatedDevice,IsUnapprovedDevice,HasExpandedAccess&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value with value.StudyFieldsResponse.StudyFields as coll unwind coll as study_metadata UNWIND study_metadata.NCTId as Id UNWIND study_metadata.IsFDARegulatedDrug as IsFDARegulatedDrug @@ -132,12 +132,12 @@ match(ct:ClinicalTrial{NCTId:Id}),(r:Response{YN:'No'}) FOREACH(ignoreMe IN CASE WHEN IsFDARegulatedDrug='No' THEN [1] ELSE [] END | MERGE(ct)-[:IS_FDA_REGULATED_DRUG]->(r)) ; -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+NOT+AREA%5BStudyType%5DInterventional+AND+NOT+AREA%5BStudyType%5DObservational&fields=NCTId&fmt=json&max_rnk=1000') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=NOT+AREA%5BStudyType%5DInterventional+AND+NOT+AREA%5BStudyType%5DObservational&fields=NCTId&fmt=json&max_rnk=1000') yield value with value.StudyFieldsResponse.NStudiesFound as NStudies, RANGE(0,(value.StudyFieldsResponse.NStudiesFound/1000)) as nloop UNWIND nloop as i with range(1+1000*i,1000+1000*i,999) as RANGES with RANGES, RANGES[1] as urange, RANGES[0] as lrange -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+NOT+AREA%5BStudyType%5DInterventional+AND+NOT+AREA%5BStudyType%5DObservational&fields=NCTId,IsFDARegulatedDrug,IsFDARegulatedDevice,IsUnapprovedDevice,HasExpandedAccess&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=NOT+AREA%5BStudyType%5DInterventional+AND+NOT+AREA%5BStudyType%5DObservational&fields=NCTId,IsFDARegulatedDrug,IsFDARegulatedDevice,IsUnapprovedDevice,HasExpandedAccess&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value with value.StudyFieldsResponse.StudyFields as coll unwind coll as study_metadata UNWIND study_metadata.NCTId as Id match(ct:ClinicalTrial{NCTId:Id}),(r:Response{YN:'Yes'}) @@ -151,12 +151,12 @@ UNWIND study_metadata.IsFDARegulatedDevice as IsFDARegulatedDevice FOREACH(ignoreMe IN CASE WHEN IsFDARegulatedDevice='No' THEN [1] ELSE [] END | MERGE(ct)-[:IS_FDA_REGULATED_DEVICE]->(r)) ; -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+NOT+AREA%5BStudyType%5DInterventional+AND+NOT+AREA%5BStudyType%5DObservational&fields=NCTId&fmt=json&max_rnk=1000') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=NOT+AREA%5BStudyType%5DInterventional+AND+NOT+AREA%5BStudyType%5DObservational&fields=NCTId&fmt=json&max_rnk=1000') yield value with value.StudyFieldsResponse.NStudiesFound as NStudies, RANGE(0,(value.StudyFieldsResponse.NStudiesFound/1000)) as nloop UNWIND nloop as i with range(1+1000*i,1000+1000*i,999) as RANGES with RANGES, RANGES[1] as urange, RANGES[0] as lrange -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+NOT+AREA%5BStudyType%5DInterventional+AND+NOT+AREA%5BStudyType%5DObservational&fields=NCTId,IsFDARegulatedDrug,IsFDARegulatedDevice,IsUnapprovedDevice,HasExpandedAccess&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=NOT+AREA%5BStudyType%5DInterventional+AND+NOT+AREA%5BStudyType%5DObservational&fields=NCTId,IsFDARegulatedDrug,IsFDARegulatedDevice,IsUnapprovedDevice,HasExpandedAccess&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value with value.StudyFieldsResponse.StudyFields as coll unwind coll as study_metadata UNWIND study_metadata.NCTId as Id match(ct:ClinicalTrial{NCTId:Id}),(r:Response{YN:'Yes'}) @@ -170,12 +170,12 @@ UNWIND study_metadata.HasExpandedAccess as HasExpandedAccess FOREACH(ignoreMe IN CASE WHEN HasExpandedAccess='No' THEN [1] ELSE [] END | MERGE(ct)-[:HAS_EXPANDED_ACCESS]->(r)) ; -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+NOT+AREA%5BStudyType%5DInterventional+AND+NOT+AREA%5BStudyType%5DObservational&fields=NCTId&fmt=json&max_rnk=1000') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=NOT+AREA%5BStudyType%5DInterventional+AND+NOT+AREA%5BStudyType%5DObservational&fields=NCTId&fmt=json&max_rnk=1000') yield value with value.StudyFieldsResponse.NStudiesFound as NStudies, RANGE(0,(value.StudyFieldsResponse.NStudiesFound/1000)) as nloop UNWIND nloop as i with range(1+1000*i,1000+1000*i,999) as RANGES with RANGES, RANGES[1] as urange, RANGES[0] as lrange -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+NOT+AREA%5BStudyType%5DInterventional+AND+NOT+AREA%5BStudyType%5DObservational&fields=NCTId,BriefSummary,DetailedDescription,Condition,Keyword&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=NOT+AREA%5BStudyType%5DInterventional+AND+NOT+AREA%5BStudyType%5DObservational&fields=NCTId,BriefSummary,DetailedDescription,Condition,Keyword&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value with value.StudyFieldsResponse.StudyFields as coll unwind coll as study_metadata UNWIND study_metadata.NCTId as Id match(ct:ClinicalTrial{NCTId:Id}) @@ -193,12 +193,12 @@ with ct, t, study_metadata UNWIND study_metadata.DetailedDescription as DetailedDescription set t.description=DetailedDescription ; -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+NOT+AREA%5BStudyType%5DInterventional+AND+NOT+AREA%5BStudyType%5DObservational&fields=NCTId&fmt=json&max_rnk=1000') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=NOT+AREA%5BStudyType%5DInterventional+AND+NOT+AREA%5BStudyType%5DObservational&fields=NCTId&fmt=json&max_rnk=1000') yield value with value.StudyFieldsResponse.NStudiesFound as NStudies, RANGE(0,(value.StudyFieldsResponse.NStudiesFound/1000)) as nloop UNWIND nloop as i with range(1+1000*i,1000+1000*i,999) as RANGES with RANGES, RANGES[1] as urange, RANGES[0] as lrange -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+NOT+AREA%5BStudyType%5DInterventional+AND+NOT+AREA%5BStudyType%5DObservational&fields=NCTId,DesignObservationalModel,DesignTimePerspective,BioSpecRetention,BioSpecDescription&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=NOT+AREA%5BStudyType%5DInterventional+AND+NOT+AREA%5BStudyType%5DObservational&fields=NCTId,DesignObservationalModel,DesignTimePerspective,BioSpecRetention,BioSpecDescription&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value with value.StudyFieldsResponse.StudyFields as coll unwind coll as study_metadata UNWIND study_metadata.NCTId as Id UNWIND study_metadata.DesignObservationalModel as Model @@ -206,12 +206,12 @@ match(ct:ClinicalTrial{NCTId:Id}) MERGE(m:Design{model:Model}) MERGE (ct)-[:HAS_STUDY_DESIGN]->(m) ; -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+NOT+AREA%5BStudyType%5DInterventional+AND+NOT+AREA%5BStudyType%5DObservational&fields=NCTId&fmt=json&max_rnk=1000') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=NOT+AREA%5BStudyType%5DInterventional+AND+NOT+AREA%5BStudyType%5DObservational&fields=NCTId&fmt=json&max_rnk=1000') yield value with value.StudyFieldsResponse.NStudiesFound as NStudies, RANGE(0,(value.StudyFieldsResponse.NStudiesFound/1000)) as nloop UNWIND nloop as i with range(1+1000*i,1000+1000*i,999) as RANGES with RANGES, RANGES[1] as urange, RANGES[0] as lrange -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+NOT+AREA%5BStudyType%5DInterventional+AND+NOT+AREA%5BStudyType%5DObservational&fields=NCTId,DesignObservationalModel,DesignTimePerspective,BioSpecRetention,BioSpecDescription&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=NOT+AREA%5BStudyType%5DInterventional+AND+NOT+AREA%5BStudyType%5DObservational&fields=NCTId,DesignObservationalModel,DesignTimePerspective,BioSpecRetention,BioSpecDescription&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value with value.StudyFieldsResponse.StudyFields as coll unwind coll as study_metadata UNWIND study_metadata.NCTId as Id UNWIND study_metadata.DesignTimePerspective as DesignTimePerspective @@ -219,12 +219,12 @@ match(ct:ClinicalTrial{NCTId:Id}) MERGE(t:ObservationPeriod{time:DesignTimePerspective}) MERGE (ct)-[:HAS_OBSERVATION_PERIOD]->(t) ; -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+NOT+AREA%5BStudyType%5DInterventional+AND+NOT+AREA%5BStudyType%5DObservational&fields=NCTId&fmt=json&max_rnk=1000') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=NOT+AREA%5BStudyType%5DInterventional+AND+NOT+AREA%5BStudyType%5DObservational&fields=NCTId&fmt=json&max_rnk=1000') yield value with value.StudyFieldsResponse.NStudiesFound as NStudies, RANGE(0,(value.StudyFieldsResponse.NStudiesFound/1000)) as nloop UNWIND nloop as i with range(1+1000*i,1000+1000*i,999) as RANGES with RANGES, RANGES[1] as urange, RANGES[0] as lrange -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+NOT+AREA%5BStudyType%5DInterventional+AND+NOT+AREA%5BStudyType%5DObservational&fields=NCTId,DesignObservationalModel,DesignTimePerspective,BioSpecRetention,BioSpecDescription&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=NOT+AREA%5BStudyType%5DInterventional+AND+NOT+AREA%5BStudyType%5DObservational&fields=NCTId,DesignObservationalModel,DesignTimePerspective,BioSpecRetention,BioSpecDescription&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value with value.StudyFieldsResponse.StudyFields as coll unwind coll as study_metadata UNWIND study_metadata.NCTId as Id UNWIND study_metadata.BioSpecRetention as BioSpecRetention @@ -235,12 +235,12 @@ with b, study_metadata UNWIND study_metadata.BioSpecDescription as BioSpecDescription SET b.description=BioSpecDescription ; -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+NOT+AREA%5BStudyType%5DInterventional+AND+NOT+AREA%5BStudyType%5DObservational&fields=NCTId&fmt=json&max_rnk=1000') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=NOT+AREA%5BStudyType%5DInterventional+AND+NOT+AREA%5BStudyType%5DObservational&fields=NCTId&fmt=json&max_rnk=1000') yield value with value.StudyFieldsResponse.NStudiesFound as NStudies, RANGE(0,(value.StudyFieldsResponse.NStudiesFound/1000)) as nloop UNWIND nloop as i with range(1+1000*i,1000+1000*i,999) as RANGES with RANGES, RANGES[1] as urange, RANGES[0] as lrange -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+NOT+AREA%5BStudyType%5DInterventional+AND+NOT+AREA%5BStudyType%5DObservational&fields=NCTId,DesignObservationalModel,ArmGroupLabel,ArmGroupType,ArmGroupDescription,InterventionType,InterventionName,InterventionOtherName,InterventionDescription&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=NOT+AREA%5BStudyType%5DInterventional+AND+NOT+AREA%5BStudyType%5DObservational&fields=NCTId,DesignObservationalModel,ArmGroupLabel,ArmGroupType,ArmGroupDescription,InterventionType,InterventionName,InterventionOtherName,InterventionDescription&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value with value.StudyFieldsResponse.StudyFields as coll unwind coll as study_metadata UNWIND study_metadata.NCTId as Id UNWIND study_metadata.DesignObservationalModel as Model @@ -253,12 +253,12 @@ MERGE(a:Arm{name:study_metadata.ArmGroupLabel[i]}) MERGE(ct)-[:HAS_STUDY_ARMS]->(a)-[:BELONGS_TO_MODEL]->(m) ) ; -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+NOT+AREA%5BStudyType%5DInterventional+AND+NOT+AREA%5BStudyType%5DObservational&fields=NCTId&fmt=json&max_rnk=1000') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=NOT+AREA%5BStudyType%5DInterventional+AND+NOT+AREA%5BStudyType%5DObservational&fields=NCTId&fmt=json&max_rnk=1000') yield value with value.StudyFieldsResponse.NStudiesFound as NStudies, RANGE(0,(value.StudyFieldsResponse.NStudiesFound/1000)) as nloop UNWIND nloop as i with range(1+1000*i,1000+1000*i,999) as RANGES with RANGES, RANGES[1] as urange, RANGES[0] as lrange -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+NOT+AREA%5BStudyType%5DInterventional+AND+NOT+AREA%5BStudyType%5DObservational&fields=NCTId,DesignObservationalModel,ArmGroupLabel,ArmGroupType,ArmGroupDescription,InterventionType,InterventionName,InterventionOtherName,InterventionDescription&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=NOT+AREA%5BStudyType%5DInterventional+AND+NOT+AREA%5BStudyType%5DObservational&fields=NCTId,DesignObservationalModel,ArmGroupLabel,ArmGroupType,ArmGroupDescription,InterventionType,InterventionName,InterventionOtherName,InterventionDescription&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value with value.StudyFieldsResponse.StudyFields as coll unwind coll as study_metadata UNWIND study_metadata.NCTId as Id match(ct:ClinicalTrial{NCTId:Id}) @@ -269,12 +269,12 @@ MERGE(ct)-[:INVESTIGATES_INTERVENTION]->(e:Intervention{name:study_metadata.Inte ON CREATE SET e.type=study_metadata.InterventionType[i] ) ; -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+NOT+AREA%5BStudyType%5DInterventional+AND+NOT+AREA%5BStudyType%5DObservational&fields=NCTId&fmt=json&max_rnk=1000') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=NOT+AREA%5BStudyType%5DInterventional+AND+NOT+AREA%5BStudyType%5DObservational&fields=NCTId&fmt=json&max_rnk=1000') yield value with value.StudyFieldsResponse.NStudiesFound as NStudies, RANGE(0,(value.StudyFieldsResponse.NStudiesFound/1000)) as nloop UNWIND nloop as i with range(1+1000*i,1000+1000*i,999) as RANGES with RANGES, RANGES[1] as urange, RANGES[0] as lrange -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+NOT+AREA%5BStudyType%5DInterventional+AND+NOT+AREA%5BStudyType%5DObservational&fields=NCTId,PrimaryOutcomeMeasure,PrimaryOutcomeDescription,PrimaryOutcomeTimeFrame,SecondaryOutcomeMeasure,SecondaryOutcomeDescription,SecondaryOutcomeTimeFrame,OtherOutcomeMeasure,OtherOutcomeDescription,OtherOutcomeTimeFrame&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=NOT+AREA%5BStudyType%5DInterventional+AND+NOT+AREA%5BStudyType%5DObservational&fields=NCTId,PrimaryOutcomeMeasure,PrimaryOutcomeDescription,PrimaryOutcomeTimeFrame,SecondaryOutcomeMeasure,SecondaryOutcomeDescription,SecondaryOutcomeTimeFrame,OtherOutcomeMeasure,OtherOutcomeDescription,OtherOutcomeTimeFrame&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value with value.StudyFieldsResponse.StudyFields as coll unwind coll as study_metadata UNWIND study_metadata.NCTId as Id match(ct:ClinicalTrial{NCTId:Id}) @@ -285,12 +285,12 @@ MERGE(ct)-[:HAS_PRIMARY_OUTCOME]->(a:Outcome{name:study_metadata.PrimaryOutcomeM ON CREATE SET a.time=study_metadata.PrimaryOutcomeTimeFrame[i] ) ; -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+NOT+AREA%5BStudyType%5DInterventional+AND+NOT+AREA%5BStudyType%5DObservational&fields=NCTId&fmt=json&max_rnk=1000') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=NOT+AREA%5BStudyType%5DInterventional+AND+NOT+AREA%5BStudyType%5DObservational&fields=NCTId&fmt=json&max_rnk=1000') yield value with value.StudyFieldsResponse.NStudiesFound as NStudies, RANGE(0,(value.StudyFieldsResponse.NStudiesFound/1000)) as nloop UNWIND nloop as i with range(1+1000*i,1000+1000*i,999) as RANGES with RANGES, RANGES[1] as urange, RANGES[0] as lrange -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+NOT+AREA%5BStudyType%5DInterventional+AND+NOT+AREA%5BStudyType%5DObservational&fields=NCTId,PrimaryOutcomeMeasure,PrimaryOutcomeDescription,PrimaryOutcomeTimeFrame,SecondaryOutcomeMeasure,SecondaryOutcomeDescription,SecondaryOutcomeTimeFrame,OtherOutcomeMeasure,OtherOutcomeDescription,OtherOutcomeTimeFrame&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=NOT+AREA%5BStudyType%5DInterventional+AND+NOT+AREA%5BStudyType%5DObservational&fields=NCTId,PrimaryOutcomeMeasure,PrimaryOutcomeDescription,PrimaryOutcomeTimeFrame,SecondaryOutcomeMeasure,SecondaryOutcomeDescription,SecondaryOutcomeTimeFrame,OtherOutcomeMeasure,OtherOutcomeDescription,OtherOutcomeTimeFrame&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value with value.StudyFieldsResponse.StudyFields as coll unwind coll as study_metadata UNWIND study_metadata.NCTId as Id match(ct:ClinicalTrial{NCTId:Id}) @@ -301,12 +301,12 @@ MERGE(ct)-[:HAS_SECONDARY_OUTCOME]->(a:Outcome{name:study_metadata.SecondaryOutc ON CREATE SET a.time=study_metadata.SecondaryOutcomeTimeFrame[i] ) ; -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+NOT+AREA%5BStudyType%5DInterventional+AND+NOT+AREA%5BStudyType%5DObservational&fields=NCTId&fmt=json&max_rnk=1000') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=NOT+AREA%5BStudyType%5DInterventional+AND+NOT+AREA%5BStudyType%5DObservational&fields=NCTId&fmt=json&max_rnk=1000') yield value with value.StudyFieldsResponse.NStudiesFound as NStudies, RANGE(0,(value.StudyFieldsResponse.NStudiesFound/1000)) as nloop UNWIND nloop as i with range(1+1000*i,1000+1000*i,999) as RANGES with RANGES, RANGES[1] as urange, RANGES[0] as lrange -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+NOT+AREA%5BStudyType%5DInterventional+AND+NOT+AREA%5BStudyType%5DObservational&fields=NCTId,PrimaryOutcomeMeasure,PrimaryOutcomeDescription,PrimaryOutcomeTimeFrame,SecondaryOutcomeMeasure,SecondaryOutcomeDescription,SecondaryOutcomeTimeFrame,OtherOutcomeMeasure,OtherOutcomeDescription,OtherOutcomeTimeFrame&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=NOT+AREA%5BStudyType%5DInterventional+AND+NOT+AREA%5BStudyType%5DObservational&fields=NCTId,PrimaryOutcomeMeasure,PrimaryOutcomeDescription,PrimaryOutcomeTimeFrame,SecondaryOutcomeMeasure,SecondaryOutcomeDescription,SecondaryOutcomeTimeFrame,OtherOutcomeMeasure,OtherOutcomeDescription,OtherOutcomeTimeFrame&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value with value.StudyFieldsResponse.StudyFields as coll unwind coll as study_metadata UNWIND study_metadata.NCTId as Id match(ct:ClinicalTrial{NCTId:Id}) @@ -317,12 +317,12 @@ MERGE(ct)-[:HAS_OTHER_OUTCOME]->(a:Outcome{name:study_metadata.OtherOutcomeMeasu ON CREATE SET a.time=study_metadata.OtherOutcomeTimeFrame[i] ) ; -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+NOT+AREA%5BStudyType%5DInterventional+AND+NOT+AREA%5BStudyType%5DObservational&fields=NCTId&fmt=json&max_rnk=1000') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=NOT+AREA%5BStudyType%5DInterventional+AND+NOT+AREA%5BStudyType%5DObservational&fields=NCTId&fmt=json&max_rnk=1000') yield value with value.StudyFieldsResponse.NStudiesFound as NStudies, RANGE(0,(value.StudyFieldsResponse.NStudiesFound/1000)) as nloop UNWIND nloop as i with range(1+1000*i,1000+1000*i,999) as RANGES with RANGES, RANGES[1] as urange, RANGES[0] as lrange -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+NOT+AREA%5BStudyType%5DInterventional+AND+NOT+AREA%5BStudyType%5DObservational&fields=NCTId,Gender,GenderBased,GenderDescription,MinimumAge,MaximumAge,HealthyVolunteers,StudyPopulation,SamplingMethod,EligibilityCriteria&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=NOT+AREA%5BStudyType%5DInterventional+AND+NOT+AREA%5BStudyType%5DObservational&fields=NCTId,Gender,GenderBased,GenderDescription,MinimumAge,MaximumAge,HealthyVolunteers,StudyPopulation,SamplingMethod,EligibilityCriteria&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value with value.StudyFieldsResponse.StudyFields as coll unwind coll as study_metadata UNWIND study_metadata.NCTId as Id match(ct:ClinicalTrial{NCTId:Id}) @@ -333,12 +333,12 @@ with study_metadata, ct, p UNWIND study_metadata.SamplingMethod as SamplingMethod SET p.sampling=SamplingMethod ; -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+NOT+AREA%5BStudyType%5DInterventional+AND+NOT+AREA%5BStudyType%5DObservational&fields=NCTId&fmt=json&max_rnk=1000') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=NOT+AREA%5BStudyType%5DInterventional+AND+NOT+AREA%5BStudyType%5DObservational&fields=NCTId&fmt=json&max_rnk=1000') yield value with value.StudyFieldsResponse.NStudiesFound as NStudies, RANGE(0,(value.StudyFieldsResponse.NStudiesFound/1000)) as nloop UNWIND nloop as i with range(1+1000*i,1000+1000*i,999) as RANGES with RANGES, RANGES[1] as urange, RANGES[0] as lrange -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+NOT+AREA%5BStudyType%5DInterventional+AND+NOT+AREA%5BStudyType%5DObservational&fields=NCTId,Gender,GenderBased,GenderDescription,MinimumAge,MaximumAge,HealthyVolunteers,StudyPopulation,SamplingMethod,EligibilityCriteria&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=NOT+AREA%5BStudyType%5DInterventional+AND+NOT+AREA%5BStudyType%5DObservational&fields=NCTId,Gender,GenderBased,GenderDescription,MinimumAge,MaximumAge,HealthyVolunteers,StudyPopulation,SamplingMethod,EligibilityCriteria&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value with value.StudyFieldsResponse.StudyFields as coll unwind coll as study_metadata UNWIND study_metadata.NCTId as Id match(ct:ClinicalTrial{NCTId:Id}) @@ -349,12 +349,12 @@ with ct, g, study_metadata UNWIND study_metadata.GenderDescription as GenderDescription set g.description=GenderDescription ; -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+NOT+AREA%5BStudyType%5DInterventional+AND+NOT+AREA%5BStudyType%5DObservational&fields=NCTId&fmt=json&max_rnk=1000') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=NOT+AREA%5BStudyType%5DInterventional+AND+NOT+AREA%5BStudyType%5DObservational&fields=NCTId&fmt=json&max_rnk=1000') yield value with value.StudyFieldsResponse.NStudiesFound as NStudies, RANGE(0,(value.StudyFieldsResponse.NStudiesFound/1000)) as nloop UNWIND nloop as i with range(1+1000*i,1000+1000*i,999) as RANGES with RANGES, RANGES[1] as urange, RANGES[0] as lrange -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+NOT+AREA%5BStudyType%5DInterventional+AND+NOT+AREA%5BStudyType%5DObservational&fields=NCTId,Gender,GenderBased,GenderDescription,MinimumAge,MaximumAge,HealthyVolunteers,StudyPopulation,SamplingMethod,EligibilityCriteria&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=NOT+AREA%5BStudyType%5DInterventional+AND+NOT+AREA%5BStudyType%5DObservational&fields=NCTId,Gender,GenderBased,GenderDescription,MinimumAge,MaximumAge,HealthyVolunteers,StudyPopulation,SamplingMethod,EligibilityCriteria&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value with value.StudyFieldsResponse.StudyFields as coll unwind coll as study_metadata UNWIND study_metadata.NCTId as Id match(ct:ClinicalTrial{NCTId:Id}) @@ -363,12 +363,12 @@ UNWIND study_metadata.MinimumAge as MinAge UNWIND study_metadata.MaximumAge as MaxAge MERGE (ct)-[:INCLUDES_AGE_RANGE]->(a:AgeRange{minAge:MinAge,maxAge:MaxAge}) ; -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+NOT+AREA%5BStudyType%5DInterventional+AND+NOT+AREA%5BStudyType%5DObservational&fields=NCTId&fmt=json&max_rnk=1000') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=NOT+AREA%5BStudyType%5DInterventional+AND+NOT+AREA%5BStudyType%5DObservational&fields=NCTId&fmt=json&max_rnk=1000') yield value with value.StudyFieldsResponse.NStudiesFound as NStudies, RANGE(0,(value.StudyFieldsResponse.NStudiesFound/1000)) as nloop UNWIND nloop as i with range(1+1000*i,1000+1000*i,999) as RANGES with RANGES, RANGES[1] as urange, RANGES[0] as lrange -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+NOT+AREA%5BStudyType%5DInterventional+AND+NOT+AREA%5BStudyType%5DObservational&fields=NCTId,Gender,GenderBased,GenderDescription,MinimumAge,MaximumAge,HealthyVolunteers,StudyPopulation,SamplingMethod,EligibilityCriteria&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=NOT+AREA%5BStudyType%5DInterventional+AND+NOT+AREA%5BStudyType%5DObservational&fields=NCTId,Gender,GenderBased,GenderDescription,MinimumAge,MaximumAge,HealthyVolunteers,StudyPopulation,SamplingMethod,EligibilityCriteria&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value with value.StudyFieldsResponse.StudyFields as coll unwind coll as study_metadata UNWIND study_metadata.NCTId as Id match(ct:ClinicalTrial{NCTId:Id}) @@ -389,12 +389,12 @@ with ct, Inclusion, Exclusion MERGE(incl:InclusionCriteria{criteria:Inclusion}) MERGE(ct)-[:HAS_INCLUSION_CRITERIA]->(incl) MERGE(excl:ExclusionCriteria{criteria:Exclusion}) MERGE(ct)-[:HAS_EXCLUSION_CRITERIA]->(excl) ; -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+NOT+AREA%5BStudyType%5DInterventional+AND+NOT+AREA%5BStudyType%5DObservational&fields=NCTId&fmt=json&max_rnk=1000') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=NOT+AREA%5BStudyType%5DInterventional+AND+NOT+AREA%5BStudyType%5DObservational&fields=NCTId&fmt=json&max_rnk=1000') yield value with value.StudyFieldsResponse.NStudiesFound as NStudies, RANGE(0,(value.StudyFieldsResponse.NStudiesFound/1000)) as nloop UNWIND nloop as i with range(1+1000*i,1000+1000*i,999) as RANGES with RANGES, RANGES[1] as urange, RANGES[0] as lrange -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+NOT+AREA%5BStudyType%5DInterventional+AND+NOT+AREA%5BStudyType%5DObservational&fields=NCTId,CentralContactName,CentralContactEmail,OverallOfficialName,OverallOfficialAffiliation,OverallOfficialRole&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=NOT+AREA%5BStudyType%5DInterventional+AND+NOT+AREA%5BStudyType%5DObservational&fields=NCTId,CentralContactName,CentralContactEmail,OverallOfficialName,OverallOfficialAffiliation,OverallOfficialRole&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value with value.StudyFieldsResponse.StudyFields as coll unwind coll as study_metadata UNWIND study_metadata.NCTId as Id match(ct:ClinicalTrial{NCTId:Id}) @@ -402,12 +402,12 @@ UNWIND study_metadata.CentralContactName as Name UNWIND study_metadata.CentralContactEMail as Email MERGE (ct)-[:HAS_CONTACT_PERSON]->(c:Contact{name:Name,email:Email}) ; -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+NOT+AREA%5BStudyType%5DInterventional+AND+NOT+AREA%5BStudyType%5DObservational&fields=NCTId&fmt=json&max_rnk=1000') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=NOT+AREA%5BStudyType%5DInterventional+AND+NOT+AREA%5BStudyType%5DObservational&fields=NCTId&fmt=json&max_rnk=1000') yield value with value.StudyFieldsResponse.NStudiesFound as NStudies, RANGE(0,(value.StudyFieldsResponse.NStudiesFound/1000)) as nloop UNWIND nloop as i with range(1+1000*i,1000+1000*i,999) as RANGES with RANGES, RANGES[1] as urange, RANGES[0] as lrange -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+NOT+AREA%5BStudyType%5DInterventional+AND+NOT+AREA%5BStudyType%5DObservational&fields=NCTId,LocationFacility,LocationCity,LocationState,LocationCountry&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=NOT+AREA%5BStudyType%5DInterventional+AND+NOT+AREA%5BStudyType%5DObservational&fields=NCTId,LocationFacility,LocationCity,LocationState,LocationCountry&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value with value.StudyFieldsResponse.StudyFields as coll unwind coll as study_metadata UNWIND study_metadata.NCTId as Id match(ct:ClinicalTrial{NCTId:Id}) @@ -426,12 +426,12 @@ FOREACH(i in ncity | MERGE(ci)-[:LOCATED_IN]->(c) ) ; -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+NOT+AREA%5BStudyType%5DInterventional+AND+NOT+AREA%5BStudyType%5DObservational&fields=NCTId&fmt=json&max_rnk=1000') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=NOT+AREA%5BStudyType%5DInterventional+AND+NOT+AREA%5BStudyType%5DObservational&fields=NCTId&fmt=json&max_rnk=1000') yield value with value.StudyFieldsResponse.NStudiesFound as NStudies, RANGE(0,(value.StudyFieldsResponse.NStudiesFound/1000)) as nloop UNWIND nloop as i with range(1+1000*i,1000+1000*i,999) as RANGES with RANGES, RANGES[1] as urange, RANGES[0] as lrange -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+NOT+AREA%5BStudyType%5DInterventional+AND+NOT+AREA%5BStudyType%5DObservational&fields=NCTId,ReferencePMID,ReferenceCitation,ReferenceType,SeeAlsoLinkURL&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=NOT+AREA%5BStudyType%5DInterventional+AND+NOT+AREA%5BStudyType%5DObservational&fields=NCTId,ReferencePMID,ReferenceCitation,ReferenceType,SeeAlsoLinkURL&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value with value.StudyFieldsResponse.StudyFields as coll unwind coll as study_metadata UNWIND study_metadata.NCTId as Id match(ct:ClinicalTrial{NCTId:Id}) @@ -453,4 +453,4 @@ MERGE(ct)-[:REFERS_TO_URL]->(l) match(i:InclusionCriteria) where i.criteria in ['-', 'none'] DETACH DELETE i ; match(e:ExclusionCriteria) where e.criteria in ['-', 'none'] DETACH DELETE e -; +; \ No newline at end of file diff --git a/dataloader/load_data_interventional.cypher b/dataloader/load_data_interventional.cypher index a2c51c2..b5e0e69 100644 --- a/dataloader/load_data_interventional.cypher +++ b/dataloader/load_data_interventional.cypher @@ -1,9 +1,9 @@ -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+AREA%5BStudyType%5DInterventional&fields=NCTId&fmt=json&max_rnk=1000') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=AREA%5BStudyType%5DInterventional&fields=NCTId&fmt=json&max_rnk=1000') yield value with value.StudyFieldsResponse.NStudiesFound as NStudies, RANGE(0,(value.StudyFieldsResponse.NStudiesFound/1000)) as nloop UNWIND nloop as i with range(1+1000*i,1000+1000*i,999) as RANGES with RANGES, RANGES[1] as urange, RANGES[0] as lrange -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+AREA%5BStudyType%5DInterventional&fields=NCTId,OrgStudyId,BriefTitle,Acronym,OfficialTitle,StudyType&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=AREA%5BStudyType%5DInterventional&fields=NCTId,OrgStudyId,BriefTitle,Acronym,OfficialTitle,StudyType&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value with value.StudyFieldsResponse.StudyFields as coll unwind coll as study_metadata UNWIND study_metadata.NCTId as Id UNWIND study_metadata.StudyType as StudyType @@ -23,12 +23,12 @@ with si, study_metadata UNWIND study_metadata.Acronym as Acronym set si.acronym=Acronym ; -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+AREA%5BStudyType%5DInterventional&fields=NCTId&fmt=json&max_rnk=1000') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=AREA%5BStudyType%5DInterventional&fields=NCTId&fmt=json&max_rnk=1000') yield value with value.StudyFieldsResponse.NStudiesFound as NStudies, RANGE(0,(value.StudyFieldsResponse.NStudiesFound/1000)) as nloop UNWIND nloop as i with range(1+1000*i,1000+1000*i,999) as RANGES with RANGES, RANGES[1] as urange, RANGES[0] as lrange -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+AREA%5BStudyType%5DInterventional&fields=NCTId,OverallStatus,WhyStopped,StartDate,PrimaryCompletionDate,CompletionDate&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=AREA%5BStudyType%5DInterventional&fields=NCTId,OverallStatus,WhyStopped,StartDate,PrimaryCompletionDate,CompletionDate&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value with value.StudyFieldsResponse.StudyFields as coll unwind coll as study_metadata UNWIND study_metadata.NCTId as Id match(ct:ClinicalTrial{NCTId:Id}) @@ -48,12 +48,12 @@ UNWIND study_metadata.WhyStopped as WhyStopped MERGE(ct)-[:WAS_STOPPED]->(r:StopReason{reason:WhyStopped}) MERGE(s)-[:HAS_REASON]->(r) ; -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+AREA%5BStudyType%5DInterventional&fields=NCTId&fmt=json&max_rnk=1000') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=AREA%5BStudyType%5DInterventional&fields=NCTId&fmt=json&max_rnk=1000') yield value with value.StudyFieldsResponse.NStudiesFound as NStudies, RANGE(0,(value.StudyFieldsResponse.NStudiesFound/1000)) as nloop UNWIND nloop as i with range(1+1000*i,1000+1000*i,999) as RANGES with RANGES, RANGES[1] as urange, RANGES[0] as lrange -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+AREA%5BStudyType%5DInterventional&fields=NCTId,ResponsiblePartyType,ResponsiblePartyInvestigatorFullName,ResponsiblePartyInvestigatorAffiliation,LeadSponsorName,CollaboratorName&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=AREA%5BStudyType%5DInterventional&fields=NCTId,ResponsiblePartyType,ResponsiblePartyInvestigatorFullName,ResponsiblePartyInvestigatorAffiliation,LeadSponsorName,CollaboratorName&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value with value.StudyFieldsResponse.StudyFields as coll unwind coll as study_metadata UNWIND study_metadata.ResponsiblePartyType as ResponsiblePartyType MERGE(r:Responsible{type:ResponsiblePartyType}) @@ -77,12 +77,12 @@ FOREACH(ignoreMe IN CASE WHEN r.type='Sponsor-Investigator' THEN [1] ELSE [] END MERGE(r)-[:IS_RESPONSIBLE]->(k) MERGE(r)-[:IS_RESPONSIBLE]->(i)) ; -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+AREA%5BStudyType%5DInterventional&fields=NCTId&fmt=json&max_rnk=1000') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=AREA%5BStudyType%5DInterventional&fields=NCTId&fmt=json&max_rnk=1000') yield value with value.StudyFieldsResponse.NStudiesFound as NStudies, RANGE(0,(value.StudyFieldsResponse.NStudiesFound/1000)) as nloop UNWIND nloop as i with range(1+1000*i,1000+1000*i,999) as RANGES with RANGES, RANGES[1] as urange, RANGES[0] as lrange -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+AREA%5BStudyType%5DInterventional&fields=NCTId,ResponsiblePartyType,ResponsiblePartyInvestigatorFullName,ResponsiblePartyInvestigatorAffiliation,LeadSponsorName,CollaboratorName&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=AREA%5BStudyType%5DInterventional&fields=NCTId,ResponsiblePartyType,ResponsiblePartyInvestigatorFullName,ResponsiblePartyInvestigatorAffiliation,LeadSponsorName,CollaboratorName&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value with value.StudyFieldsResponse.StudyFields as coll unwind coll as study_metadata UNWIND study_metadata.NCTId as Id match(ct:ClinicalTrial{NCTId:Id}) @@ -94,12 +94,12 @@ MERGE(r:Response{YN:'Yes'}) ; MERGE(k:Response{YN:'No'}) ; -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+AREA%5BStudyType%5DInterventional&fields=NCTId&fmt=json&max_rnk=1000') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=AREA%5BStudyType%5DInterventional&fields=NCTId&fmt=json&max_rnk=1000') yield value with value.StudyFieldsResponse.NStudiesFound as NStudies, RANGE(0,(value.StudyFieldsResponse.NStudiesFound/1000)) as nloop UNWIND nloop as i with range(1+1000*i,1000+1000*i,999) as RANGES with RANGES, RANGES[1] as urange, RANGES[0] as lrange -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+AREA%5BStudyType%5DInterventional&fields=NCTId,IsFDARegulatedDrug,IsFDARegulatedDevice,IsUnapprovedDevice,HasExpandedAccess&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=AREA%5BStudyType%5DInterventional&fields=NCTId,IsFDARegulatedDrug,IsFDARegulatedDevice,IsUnapprovedDevice,HasExpandedAccess&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value with value.StudyFieldsResponse.StudyFields as coll unwind coll as study_metadata UNWIND study_metadata.NCTId as Id match(ct:ClinicalTrial{NCTId:Id}), (r:Response{YN:'Yes'}) @@ -113,12 +113,12 @@ UNWIND study_metadata.IsUnapprovedDevice as IsUnapprovedDevice FOREACH(ignoreMe IN CASE WHEN IsUnapprovedDevice='No' THEN [1] ELSE [] END | MERGE(ct)-[:IS_FDA_UNAPPROVED_DEVICE]->(r)) ; -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+AREA%5BStudyType%5DInterventional&fields=NCTId&fmt=json&max_rnk=1000') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=AREA%5BStudyType%5DInterventional&fields=NCTId&fmt=json&max_rnk=1000') yield value with value.StudyFieldsResponse.NStudiesFound as NStudies, RANGE(0,(value.StudyFieldsResponse.NStudiesFound/1000)) as nloop UNWIND nloop as i with range(1+1000*i,1000+1000*i,999) as RANGES with RANGES, RANGES[1] as urange, RANGES[0] as lrange -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+AREA%5BStudyType%5DInterventional&fields=NCTId,IsFDARegulatedDrug,IsFDARegulatedDevice,IsUnapprovedDevice,HasExpandedAccess&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=AREA%5BStudyType%5DInterventional&fields=NCTId,IsFDARegulatedDrug,IsFDARegulatedDevice,IsUnapprovedDevice,HasExpandedAccess&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value with value.StudyFieldsResponse.StudyFields as coll unwind coll as study_metadata UNWIND study_metadata.NCTId as Id UNWIND study_metadata.IsFDARegulatedDrug as IsFDARegulatedDrug @@ -132,12 +132,12 @@ match(ct:ClinicalTrial{NCTId:Id}),(r:Response{YN:'No'}) FOREACH(ignoreMe IN CASE WHEN IsFDARegulatedDrug='No' THEN [1] ELSE [] END | MERGE(ct)-[:IS_FDA_REGULATED_DRUG]->(r)) ; -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+AREA%5BStudyType%5DInterventional&fields=NCTId&fmt=json&max_rnk=1000') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=AREA%5BStudyType%5DInterventional&fields=NCTId&fmt=json&max_rnk=1000') yield value with value.StudyFieldsResponse.NStudiesFound as NStudies, RANGE(0,(value.StudyFieldsResponse.NStudiesFound/1000)) as nloop UNWIND nloop as i with range(1+1000*i,1000+1000*i,999) as RANGES with RANGES, RANGES[1] as urange, RANGES[0] as lrange -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+AREA%5BStudyType%5DInterventional&fields=NCTId,IsFDARegulatedDrug,IsFDARegulatedDevice,IsUnapprovedDevice,HasExpandedAccess&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=AREA%5BStudyType%5DInterventional&fields=NCTId,IsFDARegulatedDrug,IsFDARegulatedDevice,IsUnapprovedDevice,HasExpandedAccess&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value with value.StudyFieldsResponse.StudyFields as coll unwind coll as study_metadata UNWIND study_metadata.NCTId as Id match(ct:ClinicalTrial{NCTId:Id}),(r:Response{YN:'Yes'}) @@ -151,12 +151,12 @@ UNWIND study_metadata.IsFDARegulatedDevice as IsFDARegulatedDevice FOREACH(ignoreMe IN CASE WHEN IsFDARegulatedDevice='No' THEN [1] ELSE [] END | MERGE(ct)-[:IS_FDA_REGULATED_DEVICE]->(r)) ; -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+AREA%5BStudyType%5DInterventional&fields=NCTId&fmt=json&max_rnk=1000') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=AREA%5BStudyType%5DInterventional&fields=NCTId&fmt=json&max_rnk=1000') yield value with value.StudyFieldsResponse.NStudiesFound as NStudies, RANGE(0,(value.StudyFieldsResponse.NStudiesFound/1000)) as nloop UNWIND nloop as i with range(1+1000*i,1000+1000*i,999) as RANGES with RANGES, RANGES[1] as urange, RANGES[0] as lrange -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+AREA%5BStudyType%5DInterventional&fields=NCTId,IsFDARegulatedDrug,IsFDARegulatedDevice,IsUnapprovedDevice,HasExpandedAccess&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=AREA%5BStudyType%5DInterventional&fields=NCTId,IsFDARegulatedDrug,IsFDARegulatedDevice,IsUnapprovedDevice,HasExpandedAccess&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value with value.StudyFieldsResponse.StudyFields as coll unwind coll as study_metadata UNWIND study_metadata.NCTId as Id match(ct:ClinicalTrial{NCTId:Id}),(r:Response{YN:'Yes'}) @@ -170,12 +170,12 @@ UNWIND study_metadata.HasExpandedAccess as HasExpandedAccess FOREACH(ignoreMe IN CASE WHEN HasExpandedAccess='No' THEN [1] ELSE [] END | MERGE(ct)-[:HAS_EXPANDED_ACCESS]->(r)) ; -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+AREA%5BStudyType%5DInterventional&fields=NCTId&fmt=json&max_rnk=1000') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=AREA%5BStudyType%5DInterventional&fields=NCTId&fmt=json&max_rnk=1000') yield value with value.StudyFieldsResponse.NStudiesFound as NStudies, RANGE(0,(value.StudyFieldsResponse.NStudiesFound/1000)) as nloop UNWIND nloop as i with range(1+1000*i,1000+1000*i,999) as RANGES with RANGES, RANGES[1] as urange, RANGES[0] as lrange -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+AREA%5BStudyType%5DInterventional&fields=NCTId,BriefSummary,DetailedDescription,Condition,Keyword&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=AREA%5BStudyType%5DInterventional&fields=NCTId,BriefSummary,DetailedDescription,Condition,Keyword&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value with value.StudyFieldsResponse.StudyFields as coll unwind coll as study_metadata UNWIND study_metadata.NCTId as Id match(ct:ClinicalTrial{NCTId:Id}) @@ -193,12 +193,12 @@ with ct, t, study_metadata UNWIND study_metadata.DetailedDescription as DetailedDescription set t.description=DetailedDescription ; -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+AREA%5BStudyType%5DInterventional&fields=NCTId&fmt=json&max_rnk=1000') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=AREA%5BStudyType%5DInterventional&fields=NCTId&fmt=json&max_rnk=1000') yield value with value.StudyFieldsResponse.NStudiesFound as NStudies, RANGE(0,(value.StudyFieldsResponse.NStudiesFound/1000)) as nloop UNWIND nloop as i with range(1+1000*i,1000+1000*i,999) as RANGES with RANGES, RANGES[1] as urange, RANGES[0] as lrange -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+AREA%5BStudyType%5DInterventional&fields=NCTId,DesignPrimaryPurpose,Phase,DesignInterventionModel,DesignInterventionModelDescription&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=AREA%5BStudyType%5DInterventional&fields=NCTId,DesignPrimaryPurpose,Phase,DesignInterventionModel,DesignInterventionModelDescription&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value with value.StudyFieldsResponse.StudyFields as coll unwind coll as study_metadata UNWIND study_metadata.NCTId as Id UNWIND study_metadata.Phase as Phase @@ -218,12 +218,12 @@ UNWIND study_metadata.DesignInterventionModelDescription as ModelDescription match(ct)-[:HAS_STUDY_DESIGN]->(m:Design) set m.description=ModelDescription ; -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+AREA%5BStudyType%5DInterventional&fields=NCTId&fmt=json&max_rnk=1000') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=AREA%5BStudyType%5DInterventional&fields=NCTId&fmt=json&max_rnk=1000') yield value with value.StudyFieldsResponse.NStudiesFound as NStudies, RANGE(0,(value.StudyFieldsResponse.NStudiesFound/1000)) as nloop UNWIND nloop as i with range(1+1000*i,1000+1000*i,999) as RANGES with RANGES, RANGES[1] as urange, RANGES[0] as lrange -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+AREA%5BStudyType%5DInterventional&fields=NCTId,DesignObservationalModel,ArmGroupLabel,ArmGroupType,ArmGroupDescription,InterventionType,InterventionName,InterventionOtherName,InterventionDescription&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=AREA%5BStudyType%5DInterventional&fields=NCTId,DesignObservationalModel,ArmGroupLabel,ArmGroupType,ArmGroupDescription,InterventionType,InterventionName,InterventionOtherName,InterventionDescription&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value with value.StudyFieldsResponse.StudyFields as coll unwind coll as study_metadata UNWIND study_metadata.NCTId as Id UNWIND study_metadata.DesignObservationalModel as Model @@ -236,12 +236,12 @@ ON CREATE SET a.type=study_metadata.ArmGroupType[i] MERGE(ct)-[:HAS_STUDY_ARMS]->(a)-[:BELONGS_TO_MODEL]->(m) ) ; -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+AREA%5BStudyType%5DInterventional&fields=NCTId&fmt=json&max_rnk=1000') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=AREA%5BStudyType%5DInterventional&fields=NCTId&fmt=json&max_rnk=1000') yield value with value.StudyFieldsResponse.NStudiesFound as NStudies, RANGE(0,(value.StudyFieldsResponse.NStudiesFound/1000)) as nloop UNWIND nloop as i with range(1+1000*i,1000+1000*i,999) as RANGES with RANGES, RANGES[1] as urange, RANGES[0] as lrange -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+AREA%5BStudyType%5DInterventional&fields=NCTId,DesignObservationalModel,ArmGroupLabel,ArmGroupType,ArmGroupDescription,InterventionType,InterventionName,InterventionOtherName,InterventionDescription&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=AREA%5BStudyType%5DInterventional&fields=NCTId,DesignObservationalModel,ArmGroupLabel,ArmGroupType,ArmGroupDescription,InterventionType,InterventionName,InterventionOtherName,InterventionDescription&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value with value.StudyFieldsResponse.StudyFields as coll unwind coll as study_metadata UNWIND study_metadata.NCTId as Id match(ct:ClinicalTrial{NCTId:Id}) @@ -252,12 +252,12 @@ ON CREATE SET e.description=study_metadata.InterventionDescription[i] ON CREATE SET e.type=study_metadata.InterventionType[i] ) ; -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+AREA%5BStudyType%5DInterventional&fields=NCTId&fmt=json&max_rnk=1000') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=AREA%5BStudyType%5DInterventional&fields=NCTId&fmt=json&max_rnk=1000') yield value with value.StudyFieldsResponse.NStudiesFound as NStudies, RANGE(0,(value.StudyFieldsResponse.NStudiesFound/1000)) as nloop UNWIND nloop as i with range(1+1000*i,1000+1000*i,999) as RANGES with RANGES, RANGES[1] as urange, RANGES[0] as lrange -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+AREA%5BStudyType%5DInterventional&fields=NCTId,PrimaryOutcomeMeasure,PrimaryOutcomeDescription,PrimaryOutcomeTimeFrame,SecondaryOutcomeMeasure,SecondaryOutcomeDescription,SecondaryOutcomeTimeFrame,OtherOutcomeMeasure,OtherOutcomeDescription,OtherOutcomeTimeFrame&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=AREA%5BStudyType%5DInterventional&fields=NCTId,PrimaryOutcomeMeasure,PrimaryOutcomeDescription,PrimaryOutcomeTimeFrame,SecondaryOutcomeMeasure,SecondaryOutcomeDescription,SecondaryOutcomeTimeFrame,OtherOutcomeMeasure,OtherOutcomeDescription,OtherOutcomeTimeFrame&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value with value.StudyFieldsResponse.StudyFields as coll unwind coll as study_metadata UNWIND study_metadata.NCTId as Id match(ct:ClinicalTrial{NCTId:Id}) @@ -268,12 +268,12 @@ ON CREATE SET a.description=study_metadata.PrimaryOutcomeDescription[i] ON CREATE SET a.time=study_metadata.PrimaryOutcomeTimeFrame[i] ) ; -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+AREA%5BStudyType%5DInterventional&fields=NCTId&fmt=json&max_rnk=1000') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=AREA%5BStudyType%5DInterventional&fields=NCTId&fmt=json&max_rnk=1000') yield value with value.StudyFieldsResponse.NStudiesFound as NStudies, RANGE(0,(value.StudyFieldsResponse.NStudiesFound/1000)) as nloop UNWIND nloop as i with range(1+1000*i,1000+1000*i,999) as RANGES with RANGES, RANGES[1] as urange, RANGES[0] as lrange -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+AREA%5BStudyType%5DInterventional&fields=NCTId,PrimaryOutcomeMeasure,PrimaryOutcomeDescription,PrimaryOutcomeTimeFrame,SecondaryOutcomeMeasure,SecondaryOutcomeDescription,SecondaryOutcomeTimeFrame,OtherOutcomeMeasure,OtherOutcomeDescription,OtherOutcomeTimeFrame&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=AREA%5BStudyType%5DInterventional&fields=NCTId,PrimaryOutcomeMeasure,PrimaryOutcomeDescription,PrimaryOutcomeTimeFrame,SecondaryOutcomeMeasure,SecondaryOutcomeDescription,SecondaryOutcomeTimeFrame,OtherOutcomeMeasure,OtherOutcomeDescription,OtherOutcomeTimeFrame&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value with value.StudyFieldsResponse.StudyFields as coll unwind coll as study_metadata UNWIND study_metadata.NCTId as Id match(ct:ClinicalTrial{NCTId:Id}) @@ -284,12 +284,12 @@ ON CREATE SET a.description=study_metadata.SecondaryOutcomeDescription[i] ON CREATE SET a.time=study_metadata.SecondaryOutcomeTimeFrame[i] ) ; -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+AREA%5BStudyType%5DInterventional&fields=NCTId&fmt=json&max_rnk=1000') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=AREA%5BStudyType%5DInterventional&fields=NCTId&fmt=json&max_rnk=1000') yield value with value.StudyFieldsResponse.NStudiesFound as NStudies, RANGE(0,(value.StudyFieldsResponse.NStudiesFound/1000)) as nloop UNWIND nloop as i with range(1+1000*i,1000+1000*i,999) as RANGES with RANGES, RANGES[1] as urange, RANGES[0] as lrange -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+AREA%5BStudyType%5DInterventional&fields=NCTId,PrimaryOutcomeMeasure,PrimaryOutcomeDescription,PrimaryOutcomeTimeFrame,SecondaryOutcomeMeasure,SecondaryOutcomeDescription,SecondaryOutcomeTimeFrame,OtherOutcomeMeasure,OtherOutcomeDescription,OtherOutcomeTimeFrame&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=AREA%5BStudyType%5DInterventional&fields=NCTId,PrimaryOutcomeMeasure,PrimaryOutcomeDescription,PrimaryOutcomeTimeFrame,SecondaryOutcomeMeasure,SecondaryOutcomeDescription,SecondaryOutcomeTimeFrame,OtherOutcomeMeasure,OtherOutcomeDescription,OtherOutcomeTimeFrame&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value with value.StudyFieldsResponse.StudyFields as coll unwind coll as study_metadata UNWIND study_metadata.NCTId as Id match(ct:ClinicalTrial{NCTId:Id}) @@ -300,12 +300,12 @@ ON CREATE SET a.description=study_metadata.OtherOutcomeDescription[i] ON CREATE SET a.time=study_metadata.OtherOutcomeTimeFrame[i] ) ; -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+AREA%5BStudyType%5DInterventional&fields=NCTId&fmt=json&max_rnk=1000') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=AREA%5BStudyType%5DInterventional&fields=NCTId&fmt=json&max_rnk=1000') yield value with value.StudyFieldsResponse.NStudiesFound as NStudies, RANGE(0,(value.StudyFieldsResponse.NStudiesFound/1000)) as nloop UNWIND nloop as i with range(1+1000*i,1000+1000*i,999) as RANGES with RANGES, RANGES[1] as urange, RANGES[0] as lrange -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+AREA%5BStudyType%5DInterventional&fields=NCTId,Gender,GenderBased,GenderDescription,MinimumAge,MaximumAge,HealthyVolunteers,StudyPopulation,SamplingMethod,EligibilityCriteria&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=AREA%5BStudyType%5DInterventional&fields=NCTId,Gender,GenderBased,GenderDescription,MinimumAge,MaximumAge,HealthyVolunteers,StudyPopulation,SamplingMethod,EligibilityCriteria&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value with value.StudyFieldsResponse.StudyFields as coll unwind coll as study_metadata UNWIND study_metadata.NCTId as Id match(ct:ClinicalTrial{NCTId:Id}) @@ -316,12 +316,12 @@ with study_metadata, ct, p UNWIND study_metadata.SamplingMethod as SamplingMethod SET p.sampling=SamplingMethod ; -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+AREA%5BStudyType%5DInterventional&fields=NCTId&fmt=json&max_rnk=1000') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=AREA%5BStudyType%5DInterventional&fields=NCTId&fmt=json&max_rnk=1000') yield value with value.StudyFieldsResponse.NStudiesFound as NStudies, RANGE(0,(value.StudyFieldsResponse.NStudiesFound/1000)) as nloop UNWIND nloop as i with range(1+1000*i,1000+1000*i,999) as RANGES with RANGES, RANGES[1] as urange, RANGES[0] as lrange -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+AREA%5BStudyType%5DInterventional&fields=NCTId,Gender,GenderBased,GenderDescription,MinimumAge,MaximumAge,HealthyVolunteers,StudyPopulation,SamplingMethod,EligibilityCriteria&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=AREA%5BStudyType%5DInterventional&fields=NCTId,Gender,GenderBased,GenderDescription,MinimumAge,MaximumAge,HealthyVolunteers,StudyPopulation,SamplingMethod,EligibilityCriteria&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value with value.StudyFieldsResponse.StudyFields as coll unwind coll as study_metadata UNWIND study_metadata.NCTId as Id match(ct:ClinicalTrial{NCTId:Id}) @@ -332,12 +332,12 @@ with ct, g, study_metadata UNWIND study_metadata.GenderDescription as GenderDescription set g.description=GenderDescription ; -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+AREA%5BStudyType%5DInterventional&fields=NCTId&fmt=json&max_rnk=1000') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=AREA%5BStudyType%5DInterventional&fields=NCTId&fmt=json&max_rnk=1000') yield value with value.StudyFieldsResponse.NStudiesFound as NStudies, RANGE(0,(value.StudyFieldsResponse.NStudiesFound/1000)) as nloop UNWIND nloop as i with range(1+1000*i,1000+1000*i,999) as RANGES with RANGES, RANGES[1] as urange, RANGES[0] as lrange -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+AREA%5BStudyType%5DInterventional&fields=NCTId,Gender,GenderBased,GenderDescription,MinimumAge,MaximumAge,HealthyVolunteers,StudyPopulation,SamplingMethod,EligibilityCriteria&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=AREA%5BStudyType%5DInterventional&fields=NCTId,Gender,GenderBased,GenderDescription,MinimumAge,MaximumAge,HealthyVolunteers,StudyPopulation,SamplingMethod,EligibilityCriteria&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value with value.StudyFieldsResponse.StudyFields as coll unwind coll as study_metadata UNWIND study_metadata.NCTId as Id match(ct:ClinicalTrial{NCTId:Id}) @@ -346,12 +346,12 @@ UNWIND study_metadata.MinimumAge as MinAge UNWIND study_metadata.MaximumAge as MaxAge MERGE(ct)-[:INCLUDES_AGE_RANGE]->(a:AgeRange{minAge:MinAge,maxAge:MaxAge}) ; -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+AREA%5BStudyType%5DInterventional&fields=NCTId&fmt=json&max_rnk=1000') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=AREA%5BStudyType%5DInterventional&fields=NCTId&fmt=json&max_rnk=1000') yield value with value.StudyFieldsResponse.NStudiesFound as NStudies, RANGE(0,(value.StudyFieldsResponse.NStudiesFound/1000)) as nloop UNWIND nloop as i with range(1+1000*i,1000+1000*i,999) as RANGES with RANGES, RANGES[1] as urange, RANGES[0] as lrange -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+AREA%5BStudyType%5DInterventional&fields=NCTId,Gender,GenderBased,GenderDescription,MinimumAge,MaximumAge,HealthyVolunteers,StudyPopulation,SamplingMethod,EligibilityCriteria&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=AREA%5BStudyType%5DInterventional&fields=NCTId,Gender,GenderBased,GenderDescription,MinimumAge,MaximumAge,HealthyVolunteers,StudyPopulation,SamplingMethod,EligibilityCriteria&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value with value.StudyFieldsResponse.StudyFields as coll unwind coll as study_metadata UNWIND study_metadata.NCTId as Id match(ct:ClinicalTrial{NCTId:Id}) @@ -372,12 +372,12 @@ with ct, Inclusion, Exclusion MERGE(incl:InclusionCriteria{criteria:Inclusion}) MERGE(ct)-[:HAS_INCLUSION_CRITERIA]->(incl) MERGE(excl:ExclusionCriteria{criteria:Exclusion}) MERGE(ct)-[:HAS_EXCLUSION_CRITERIA]->(excl) ; -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+AREA%5BStudyType%5DInterventional&fields=NCTId&fmt=json&max_rnk=1000') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=AREA%5BStudyType%5DInterventional&fields=NCTId&fmt=json&max_rnk=1000') yield value with value.StudyFieldsResponse.NStudiesFound as NStudies, RANGE(0,(value.StudyFieldsResponse.NStudiesFound/1000)) as nloop UNWIND nloop as i with range(1+1000*i,1000+1000*i,999) as RANGES with RANGES, RANGES[1] as urange, RANGES[0] as lrange -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+AREA%5BStudyType%5DInterventional&fields=NCTId,CentralContactName,CentralContactEmail,OverallOfficialName,OverallOfficialAffiliation,OverallOfficialRole&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=AREA%5BStudyType%5DInterventional&fields=NCTId,CentralContactName,CentralContactEmail,OverallOfficialName,OverallOfficialAffiliation,OverallOfficialRole&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value with value.StudyFieldsResponse.StudyFields as coll unwind coll as study_metadata UNWIND study_metadata.NCTId as Id match(ct:ClinicalTrial{NCTId:Id}) @@ -388,12 +388,12 @@ with study_metadata,c UNWIND study_metadata.CentralContactEmail as Email SET c.email=Email ; -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+AREA%5BStudyType%5DInterventional&fields=NCTId&fmt=json&max_rnk=1000') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=AREA%5BStudyType%5DInterventional&fields=NCTId&fmt=json&max_rnk=1000') yield value with value.StudyFieldsResponse.NStudiesFound as NStudies, RANGE(0,(value.StudyFieldsResponse.NStudiesFound/1000)) as nloop UNWIND nloop as i with range(1+1000*i,1000+1000*i,999) as RANGES with RANGES, RANGES[1] as urange, RANGES[0] as lrange -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+AREA%5BStudyType%5DInterventional&fields=NCTId,LocationFacility,LocationCity,LocationState,LocationCountry&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=AREA%5BStudyType%5DInterventional&fields=NCTId,LocationFacility,LocationCity,LocationState,LocationCountry&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value with value.StudyFieldsResponse.StudyFields as coll unwind coll as study_metadata UNWIND study_metadata.NCTId as Id match(ct:ClinicalTrial{NCTId:Id}) @@ -412,12 +412,12 @@ FOREACH(i in ncity | MERGE(ci)-[:LOCATED_IN]->(c) ) ; -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+AREA%5BStudyType%5DInterventional&fields=NCTId&fmt=json&max_rnk=1000') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=AREA%5BStudyType%5DInterventional&fields=NCTId&fmt=json&max_rnk=1000') yield value with value.StudyFieldsResponse.NStudiesFound as NStudies, RANGE(0,(value.StudyFieldsResponse.NStudiesFound/1000)) as nloop UNWIND nloop as i with range(1+1000*i,1000+1000*i,999) as RANGES with RANGES, RANGES[1] as urange, RANGES[0] as lrange -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+AREA%5BStudyType%5DInterventional&fields=NCTId,ReferencePMID,ReferenceCitation,ReferenceType,SeeAlsoLinkURL&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=AREA%5BStudyType%5DInterventional&fields=NCTId,ReferencePMID,ReferenceCitation,ReferenceType,SeeAlsoLinkURL&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value with value.StudyFieldsResponse.StudyFields as coll unwind coll as study_metadata UNWIND study_metadata.NCTId as Id match(ct:ClinicalTrial{NCTId:Id}) @@ -439,4 +439,4 @@ MERGE(ct)-[:REFERS_TO_URL]->(l) match(i:InclusionCriteria) where i.criteria in ['-', 'none'] DETACH DELETE i ; match(e:ExclusionCriteria) where e.criteria in ['-', 'none'] DETACH DELETE e -; +; \ No newline at end of file diff --git a/dataloader/load_data_observational.cypher b/dataloader/load_data_observational.cypher index 65eefee..d33c228 100644 --- a/dataloader/load_data_observational.cypher +++ b/dataloader/load_data_observational.cypher @@ -1,9 +1,9 @@ -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+AREA%5BStudyType%5DObservational&fields=NCTId&fmt=json&max_rnk=1000') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=AREA%5BStudyType%5DObservational&fields=NCTId&fmt=json&max_rnk=1000') yield value with value.StudyFieldsResponse.NStudiesFound as NStudies, RANGE(0,(value.StudyFieldsResponse.NStudiesFound/1000)) as nloop UNWIND nloop as i with range(1+1000*i,1000+1000*i,999) as RANGES with RANGES, RANGES[1] as urange, RANGES[0] as lrange -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+AREA%5BStudyType%5DObservational&fields=NCTId,OrgStudyId,BriefTitle,Acronym,OfficialTitle,StudyType&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=AREA%5BStudyType%5DObservational&fields=NCTId,OrgStudyId,BriefTitle,Acronym,OfficialTitle,StudyType&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value with value.StudyFieldsResponse.StudyFields as coll unwind coll as study_metadata UNWIND study_metadata.NCTId as Id UNWIND study_metadata.StudyType as StudyType @@ -23,12 +23,12 @@ with si, study_metadata UNWIND study_metadata.Acronym as Acronym set si.acronym=Acronym ; -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+AREA%5BStudyType%5DObservational&fields=NCTId&fmt=json&max_rnk=1000') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=AREA%5BStudyType%5DObservational&fields=NCTId&fmt=json&max_rnk=1000') yield value with value.StudyFieldsResponse.NStudiesFound as NStudies, RANGE(0,(value.StudyFieldsResponse.NStudiesFound/1000)) as nloop UNWIND nloop as i with range(1+1000*i,1000+1000*i,999) as RANGES with RANGES, RANGES[1] as urange, RANGES[0] as lrange -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+AREA%5BStudyType%5DObservational&fields=NCTId,OverallStatus,WhyStopped,StartDate,PrimaryCompletionDate,CompletionDate&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=AREA%5BStudyType%5DObservational&fields=NCTId,OverallStatus,WhyStopped,StartDate,PrimaryCompletionDate,CompletionDate&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value with value.StudyFieldsResponse.StudyFields as coll unwind coll as study_metadata UNWIND study_metadata.NCTId as Id match(ct:ClinicalTrial{NCTId:Id}) @@ -48,12 +48,12 @@ UNWIND study_metadata.WhyStopped as WhyStopped MERGE(ct)-[:WAS_STOPPED]->(r:StopReason{reason:WhyStopped}) MERGE(s)-[:HAS_REASON]->(r) ; -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+AREA%5BStudyType%5DObservational&fields=NCTId&fmt=json&max_rnk=1000') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=AREA%5BStudyType%5DObservational&fields=NCTId&fmt=json&max_rnk=1000') yield value with value.StudyFieldsResponse.NStudiesFound as NStudies, RANGE(0,(value.StudyFieldsResponse.NStudiesFound/1000)) as nloop UNWIND nloop as i with range(1+1000*i,1000+1000*i,999) as RANGES with RANGES, RANGES[1] as urange, RANGES[0] as lrange -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+AREA%5BStudyType%5DObservational&fields=NCTId,ResponsiblePartyType,ResponsiblePartyInvestigatorFullName,ResponsiblePartyInvestigatorAffiliation,LeadSponsorName,CollaboratorName&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=AREA%5BStudyType%5DObservational&fields=NCTId,ResponsiblePartyType,ResponsiblePartyInvestigatorFullName,ResponsiblePartyInvestigatorAffiliation,LeadSponsorName,CollaboratorName&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value with value.StudyFieldsResponse.StudyFields as coll unwind coll as study_metadata UNWIND study_metadata.ResponsiblePartyType as ResponsiblePartyType MERGE(r:Responsible{type:ResponsiblePartyType}) @@ -77,12 +77,12 @@ FOREACH(ignoreMe IN CASE WHEN r.type='Sponsor-Investigator' THEN [1] ELSE [] END MERGE(r)-[:IS_RESPONSIBLE]->(k) MERGE(r)-[:IS_RESPONSIBLE]->(i)) ; -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+AREA%5BStudyType%5DObservational&fields=NCTId&fmt=json&max_rnk=1000') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=AREA%5BStudyType%5DObservational&fields=NCTId&fmt=json&max_rnk=1000') yield value with value.StudyFieldsResponse.NStudiesFound as NStudies, RANGE(0,(value.StudyFieldsResponse.NStudiesFound/1000)) as nloop UNWIND nloop as i with range(1+1000*i,1000+1000*i,999) as RANGES with RANGES, RANGES[1] as urange, RANGES[0] as lrange -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+AREA%5BStudyType%5DObservational&fields=NCTId,ResponsiblePartyType,ResponsiblePartyInvestigatorFullName,ResponsiblePartyInvestigatorAffiliation,LeadSponsorName,CollaboratorName&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=AREA%5BStudyType%5DObservational&fields=NCTId,ResponsiblePartyType,ResponsiblePartyInvestigatorFullName,ResponsiblePartyInvestigatorAffiliation,LeadSponsorName,CollaboratorName&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value with value.StudyFieldsResponse.StudyFields as coll unwind coll as study_metadata UNWIND study_metadata.NCTId as Id match(ct:ClinicalTrial{NCTId:Id}) @@ -94,12 +94,12 @@ MERGE(r:Response{YN:'Yes'}) ; MERGE(k:Response{YN:'No'}) ; -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+AREA%5BStudyType%5DObservational&fields=NCTId&fmt=json&max_rnk=1000') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=AREA%5BStudyType%5DObservational&fields=NCTId&fmt=json&max_rnk=1000') yield value with value.StudyFieldsResponse.NStudiesFound as NStudies, RANGE(0,(value.StudyFieldsResponse.NStudiesFound/1000)) as nloop UNWIND nloop as i with range(1+1000*i,1000+1000*i,999) as RANGES with RANGES, RANGES[1] as urange, RANGES[0] as lrange -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+AREA%5BStudyType%5DObservational&fields=NCTId,IsFDARegulatedDrug,IsFDARegulatedDevice,IsUnapprovedDevice,HasExpandedAccess&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=AREA%5BStudyType%5DObservational&fields=NCTId,IsFDARegulatedDrug,IsFDARegulatedDevice,IsUnapprovedDevice,HasExpandedAccess&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value with value.StudyFieldsResponse.StudyFields as coll unwind coll as study_metadata UNWIND study_metadata.NCTId as Id match(ct:ClinicalTrial{NCTId:Id}), (r:Response{YN:'Yes'}) @@ -113,12 +113,12 @@ UNWIND study_metadata.IsUnapprovedDevice as IsUnapprovedDevice FOREACH(ignoreMe IN CASE WHEN IsUnapprovedDevice='No' THEN [1] ELSE [] END | MERGE(ct)-[:IS_FDA_UNAPPROVED_DEVICE]->(r)) ; -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+AREA%5BStudyType%5DObservational&fields=NCTId&fmt=json&max_rnk=1000') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=AREA%5BStudyType%5DObservational&fields=NCTId&fmt=json&max_rnk=1000') yield value with value.StudyFieldsResponse.NStudiesFound as NStudies, RANGE(0,(value.StudyFieldsResponse.NStudiesFound/1000)) as nloop UNWIND nloop as i with range(1+1000*i,1000+1000*i,999) as RANGES with RANGES, RANGES[1] as urange, RANGES[0] as lrange -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+AREA%5BStudyType%5DObservational&fields=NCTId,IsFDARegulatedDrug,IsFDARegulatedDevice,IsUnapprovedDevice,HasExpandedAccess&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=AREA%5BStudyType%5DObservational&fields=NCTId,IsFDARegulatedDrug,IsFDARegulatedDevice,IsUnapprovedDevice,HasExpandedAccess&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value with value.StudyFieldsResponse.StudyFields as coll unwind coll as study_metadata UNWIND study_metadata.NCTId as Id UNWIND study_metadata.IsFDARegulatedDrug as IsFDARegulatedDrug @@ -132,12 +132,12 @@ match(ct:ClinicalTrial{NCTId:Id}),(r:Response{YN:'No'}) FOREACH(ignoreMe IN CASE WHEN IsFDARegulatedDrug='No' THEN [1] ELSE [] END | MERGE(ct)-[:IS_FDA_REGULATED_DRUG]->(r)) ; -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+AREA%5BStudyType%5DObservational&fields=NCTId&fmt=json&max_rnk=1000') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=AREA%5BStudyType%5DObservational&fields=NCTId&fmt=json&max_rnk=1000') yield value with value.StudyFieldsResponse.NStudiesFound as NStudies, RANGE(0,(value.StudyFieldsResponse.NStudiesFound/1000)) as nloop UNWIND nloop as i with range(1+1000*i,1000+1000*i,999) as RANGES with RANGES, RANGES[1] as urange, RANGES[0] as lrange -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+AREA%5BStudyType%5DObservational&fields=NCTId,IsFDARegulatedDrug,IsFDARegulatedDevice,IsUnapprovedDevice,HasExpandedAccess&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=AREA%5BStudyType%5DObservational&fields=NCTId,IsFDARegulatedDrug,IsFDARegulatedDevice,IsUnapprovedDevice,HasExpandedAccess&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value with value.StudyFieldsResponse.StudyFields as coll unwind coll as study_metadata UNWIND study_metadata.NCTId as Id match(ct:ClinicalTrial{NCTId:Id}),(r:Response{YN:'Yes'}) @@ -151,12 +151,12 @@ UNWIND study_metadata.IsFDARegulatedDevice as IsFDARegulatedDevice FOREACH(ignoreMe IN CASE WHEN IsFDARegulatedDevice='No' THEN [1] ELSE [] END | MERGE(ct)-[:IS_FDA_REGULATED_DEVICE]->(r)) ; -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+AREA%5BStudyType%5DObservational&fields=NCTId&fmt=json&max_rnk=1000') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=AREA%5BStudyType%5DObservational&fields=NCTId&fmt=json&max_rnk=1000') yield value with value.StudyFieldsResponse.NStudiesFound as NStudies, RANGE(0,(value.StudyFieldsResponse.NStudiesFound/1000)) as nloop UNWIND nloop as i with range(1+1000*i,1000+1000*i,999) as RANGES with RANGES, RANGES[1] as urange, RANGES[0] as lrange -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+AREA%5BStudyType%5DObservational&fields=NCTId,IsFDARegulatedDrug,IsFDARegulatedDevice,IsUnapprovedDevice,HasExpandedAccess&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=AREA%5BStudyType%5DObservational&fields=NCTId,IsFDARegulatedDrug,IsFDARegulatedDevice,IsUnapprovedDevice,HasExpandedAccess&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value with value.StudyFieldsResponse.StudyFields as coll unwind coll as study_metadata UNWIND study_metadata.NCTId as Id match(ct:ClinicalTrial{NCTId:Id}),(r:Response{YN:'Yes'}) @@ -170,12 +170,12 @@ UNWIND study_metadata.HasExpandedAccess as HasExpandedAccess FOREACH(ignoreMe IN CASE WHEN HasExpandedAccess='No' THEN [1] ELSE [] END | MERGE(ct)-[:HAS_EXPANDED_ACCESS]->(r)) ; -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+AREA%5BStudyType%5DObservational&fields=NCTId&fmt=json&max_rnk=1000') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=AREA%5BStudyType%5DObservational&fields=NCTId&fmt=json&max_rnk=1000') yield value with value.StudyFieldsResponse.NStudiesFound as NStudies, RANGE(0,(value.StudyFieldsResponse.NStudiesFound/1000)) as nloop UNWIND nloop as i with range(1+1000*i,1000+1000*i,999) as RANGES with RANGES, RANGES[1] as urange, RANGES[0] as lrange -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+AREA%5BStudyType%5DObservational&fields=NCTId,BriefSummary,DetailedDescription,Condition,Keyword&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=AREA%5BStudyType%5DObservational&fields=NCTId,BriefSummary,DetailedDescription,Condition,Keyword&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value with value.StudyFieldsResponse.StudyFields as coll unwind coll as study_metadata UNWIND study_metadata.NCTId as Id match(ct:ClinicalTrial{NCTId:Id}) @@ -193,12 +193,12 @@ with ct, t, study_metadata UNWIND study_metadata.DetailedDescription as DetailedDescription set t.description=DetailedDescription ; -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+AREA%5BStudyType%5DObservational&fields=NCTId&fmt=json&max_rnk=1000') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=AREA%5BStudyType%5DObservational&fields=NCTId&fmt=json&max_rnk=1000') yield value with value.StudyFieldsResponse.NStudiesFound as NStudies, RANGE(0,(value.StudyFieldsResponse.NStudiesFound/1000)) as nloop UNWIND nloop as i with range(1+1000*i,1000+1000*i,999) as RANGES with RANGES, RANGES[1] as urange, RANGES[0] as lrange -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+AREA%5BStudyType%5DObservational&fields=NCTId,DesignObservationalModel,DesignTimePerspective,BioSpecRetention,BioSpecDescription&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=AREA%5BStudyType%5DObservational&fields=NCTId,DesignObservationalModel,DesignTimePerspective,BioSpecRetention,BioSpecDescription&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value with value.StudyFieldsResponse.StudyFields as coll unwind coll as study_metadata UNWIND study_metadata.NCTId as Id UNWIND study_metadata.DesignObservationalModel as Model @@ -206,12 +206,12 @@ match(ct:ClinicalTrial{NCTId:Id}) MERGE(m:Design{model:Model}) MERGE (ct)-[:HAS_STUDY_DESIGN]->(m) ; -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+AREA%5BStudyType%5DObservational&fields=NCTId&fmt=json&max_rnk=1000') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=AREA%5BStudyType%5DObservational&fields=NCTId&fmt=json&max_rnk=1000') yield value with value.StudyFieldsResponse.NStudiesFound as NStudies, RANGE(0,(value.StudyFieldsResponse.NStudiesFound/1000)) as nloop UNWIND nloop as i with range(1+1000*i,1000+1000*i,999) as RANGES with RANGES, RANGES[1] as urange, RANGES[0] as lrange -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+AREA%5BStudyType%5DObservational&fields=NCTId,DesignObservationalModel,DesignTimePerspective,BioSpecRetention,BioSpecDescription&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=AREA%5BStudyType%5DObservational&fields=NCTId,DesignObservationalModel,DesignTimePerspective,BioSpecRetention,BioSpecDescription&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value with value.StudyFieldsResponse.StudyFields as coll unwind coll as study_metadata UNWIND study_metadata.NCTId as Id UNWIND study_metadata.DesignTimePerspective as DesignTimePerspective @@ -219,12 +219,12 @@ match(ct:ClinicalTrial{NCTId:Id}) MERGE(t:ObservationPeriod{time:DesignTimePerspective}) MERGE (ct)-[:HAS_OBSERVATION_PERIOD]->(t) ; -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+AREA%5BStudyType%5DObservational&fields=NCTId&fmt=json&max_rnk=1000') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=AREA%5BStudyType%5DObservational&fields=NCTId&fmt=json&max_rnk=1000') yield value with value.StudyFieldsResponse.NStudiesFound as NStudies, RANGE(0,(value.StudyFieldsResponse.NStudiesFound/1000)) as nloop UNWIND nloop as i with range(1+1000*i,1000+1000*i,999) as RANGES with RANGES, RANGES[1] as urange, RANGES[0] as lrange -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+AREA%5BStudyType%5DObservational&fields=NCTId,DesignObservationalModel,DesignTimePerspective,BioSpecRetention,BioSpecDescription&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=AREA%5BStudyType%5DObservational&fields=NCTId,DesignObservationalModel,DesignTimePerspective,BioSpecRetention,BioSpecDescription&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value with value.StudyFieldsResponse.StudyFields as coll unwind coll as study_metadata UNWIND study_metadata.NCTId as Id UNWIND study_metadata.BioSpecRetention as BioSpecRetention @@ -235,12 +235,12 @@ with b, study_metadata UNWIND study_metadata.BioSpecDescription as BioSpecDescription SET b.description=BioSpecDescription ; -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+AREA%5BStudyType%5DObservational&fields=NCTId&fmt=json&max_rnk=1000') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=AREA%5BStudyType%5DObservational&fields=NCTId&fmt=json&max_rnk=1000') yield value with value.StudyFieldsResponse.NStudiesFound as NStudies, RANGE(0,(value.StudyFieldsResponse.NStudiesFound/1000)) as nloop UNWIND nloop as i with range(1+1000*i,1000+1000*i,999) as RANGES with RANGES, RANGES[1] as urange, RANGES[0] as lrange -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+AREA%5BStudyType%5DObservational&fields=NCTId,DesignObservationalModel,ArmGroupLabel,ArmGroupType,ArmGroupDescription,InterventionType,InterventionName,InterventionOtherName,InterventionDescription&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=AREA%5BStudyType%5DObservational&fields=NCTId,DesignObservationalModel,ArmGroupLabel,ArmGroupType,ArmGroupDescription,InterventionType,InterventionName,InterventionOtherName,InterventionDescription&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value with value.StudyFieldsResponse.StudyFields as coll unwind coll as study_metadata UNWIND study_metadata.NCTId as Id UNWIND study_metadata.DesignObservationalModel as Model @@ -253,12 +253,12 @@ ON CREATE SET a.type=study_metadata.ArmGroupType[i] MERGE(a)-[:BELONGS_TO_MODEL]->(m) ) ; -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+AREA%5BStudyType%5DObservational&fields=NCTId&fmt=json&max_rnk=1000') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=AREA%5BStudyType%5DObservational&fields=NCTId&fmt=json&max_rnk=1000') yield value with value.StudyFieldsResponse.NStudiesFound as NStudies, RANGE(0,(value.StudyFieldsResponse.NStudiesFound/1000)) as nloop UNWIND nloop as i with range(1+1000*i,1000+1000*i,999) as RANGES with RANGES, RANGES[1] as urange, RANGES[0] as lrange -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+AREA%5BStudyType%5DObservational&fields=NCTId,DesignObservationalModel,ArmGroupLabel,ArmGroupType,ArmGroupDescription,InterventionType,InterventionName,InterventionOtherName,InterventionDescription&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=AREA%5BStudyType%5DObservational&fields=NCTId,DesignObservationalModel,ArmGroupLabel,ArmGroupType,ArmGroupDescription,InterventionType,InterventionName,InterventionOtherName,InterventionDescription&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value with value.StudyFieldsResponse.StudyFields as coll unwind coll as study_metadata UNWIND study_metadata.NCTId as Id UNWIND study_metadata.DesignObservationalModel as Model @@ -270,12 +270,12 @@ ON CREATE SET e.description=study_metadata.InterventionDescription[i] ON CREATE SET e.type=study_metadata.InterventionType[i] ) ; -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+AREA%5BStudyType%5DObservational&fields=NCTId&fmt=json&max_rnk=1000') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=AREA%5BStudyType%5DObservational&fields=NCTId&fmt=json&max_rnk=1000') yield value with value.StudyFieldsResponse.NStudiesFound as NStudies, RANGE(0,(value.StudyFieldsResponse.NStudiesFound/1000)) as nloop UNWIND nloop as i with range(1+1000*i,1000+1000*i,999) as RANGES with RANGES, RANGES[1] as urange, RANGES[0] as lrange -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+AREA%5BStudyType%5DObservational&fields=NCTId,PrimaryOutcomeMeasure,PrimaryOutcomeDescription,PrimaryOutcomeTimeFrame,SecondaryOutcomeMeasure,SecondaryOutcomeDescription,SecondaryOutcomeTimeFrame,OtherOutcomeMeasure,OtherOutcomeDescription,OtherOutcomeTimeFrame&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=AREA%5BStudyType%5DObservational&fields=NCTId,PrimaryOutcomeMeasure,PrimaryOutcomeDescription,PrimaryOutcomeTimeFrame,SecondaryOutcomeMeasure,SecondaryOutcomeDescription,SecondaryOutcomeTimeFrame,OtherOutcomeMeasure,OtherOutcomeDescription,OtherOutcomeTimeFrame&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value with value.StudyFieldsResponse.StudyFields as coll unwind coll as study_metadata UNWIND study_metadata.NCTId as Id match(ct:ClinicalTrial{NCTId:Id}) @@ -286,12 +286,12 @@ ON CREATE SET a.description=study_metadata.PrimaryOutcomeDescription[i] ON CREATE SET a.time=study_metadata.PrimaryOutcomeTimeFrame[i] ) ; -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+AREA%5BStudyType%5DObservational&fields=NCTId&fmt=json&max_rnk=1000') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=AREA%5BStudyType%5DObservational&fields=NCTId&fmt=json&max_rnk=1000') yield value with value.StudyFieldsResponse.NStudiesFound as NStudies, RANGE(0,(value.StudyFieldsResponse.NStudiesFound/1000)) as nloop UNWIND nloop as i with range(1+1000*i,1000+1000*i,999) as RANGES with RANGES, RANGES[1] as urange, RANGES[0] as lrange -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+AREA%5BStudyType%5DObservational&fields=NCTId,PrimaryOutcomeMeasure,PrimaryOutcomeDescription,PrimaryOutcomeTimeFrame,SecondaryOutcomeMeasure,SecondaryOutcomeDescription,SecondaryOutcomeTimeFrame,OtherOutcomeMeasure,OtherOutcomeDescription,OtherOutcomeTimeFrame&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=AREA%5BStudyType%5DObservational&fields=NCTId,PrimaryOutcomeMeasure,PrimaryOutcomeDescription,PrimaryOutcomeTimeFrame,SecondaryOutcomeMeasure,SecondaryOutcomeDescription,SecondaryOutcomeTimeFrame,OtherOutcomeMeasure,OtherOutcomeDescription,OtherOutcomeTimeFrame&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value with value.StudyFieldsResponse.StudyFields as coll unwind coll as study_metadata UNWIND study_metadata.NCTId as Id match(ct:ClinicalTrial{NCTId:Id}) @@ -302,12 +302,12 @@ ON CREATE SET a.description=study_metadata.SecondaryOutcomeDescription[i] ON CREATE SET a.time=study_metadata.SecondaryOutcomeTimeFrame[i] ) ; -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+AREA%5BStudyType%5DObservational&fields=NCTId&fmt=json&max_rnk=1000') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=AREA%5BStudyType%5DObservational&fields=NCTId&fmt=json&max_rnk=1000') yield value with value.StudyFieldsResponse.NStudiesFound as NStudies, RANGE(0,(value.StudyFieldsResponse.NStudiesFound/1000)) as nloop UNWIND nloop as i with range(1+1000*i,1000+1000*i,999) as RANGES with RANGES, RANGES[1] as urange, RANGES[0] as lrange -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+AREA%5BStudyType%5DObservational&fields=NCTId,PrimaryOutcomeMeasure,PrimaryOutcomeDescription,PrimaryOutcomeTimeFrame,SecondaryOutcomeMeasure,SecondaryOutcomeDescription,SecondaryOutcomeTimeFrame,OtherOutcomeMeasure,OtherOutcomeDescription,OtherOutcomeTimeFrame&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=AREA%5BStudyType%5DObservational&fields=NCTId,PrimaryOutcomeMeasure,PrimaryOutcomeDescription,PrimaryOutcomeTimeFrame,SecondaryOutcomeMeasure,SecondaryOutcomeDescription,SecondaryOutcomeTimeFrame,OtherOutcomeMeasure,OtherOutcomeDescription,OtherOutcomeTimeFrame&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value with value.StudyFieldsResponse.StudyFields as coll unwind coll as study_metadata UNWIND study_metadata.NCTId as Id match(ct:ClinicalTrial{NCTId:Id}) @@ -318,12 +318,12 @@ ON CREATE SET a.description=study_metadata.OtherOutcomeDescription[i] ON CREATE SET a.time=study_metadata.OtherOutcomeTimeFrame[i] ) ; -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+AREA%5BStudyType%5DObservational&fields=NCTId&fmt=json&max_rnk=1000') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=AREA%5BStudyType%5DObservational&fields=NCTId&fmt=json&max_rnk=1000') yield value with value.StudyFieldsResponse.NStudiesFound as NStudies, RANGE(0,(value.StudyFieldsResponse.NStudiesFound/1000)) as nloop UNWIND nloop as i with range(1+1000*i,1000+1000*i,999) as RANGES with RANGES, RANGES[1] as urange, RANGES[0] as lrange -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+AREA%5BStudyType%5DObservational&fields=NCTId,Gender,GenderBased,GenderDescription,MinimumAge,MaximumAge,HealthyVolunteers,StudyPopulation,SamplingMethod,EligibilityCriteria&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=AREA%5BStudyType%5DObservational&fields=NCTId,Gender,GenderBased,GenderDescription,MinimumAge,MaximumAge,HealthyVolunteers,StudyPopulation,SamplingMethod,EligibilityCriteria&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value with value.StudyFieldsResponse.StudyFields as coll unwind coll as study_metadata UNWIND study_metadata.NCTId as Id match(ct:ClinicalTrial{NCTId:Id}) @@ -332,12 +332,12 @@ UNWIND study_metadata.SamplingMethod as SamplingMethod MERGE (ct)-[:HAS_STUDY_POPULATION]->(p:StudyPopulation{name:StudyPopulation}) ON CREATE SET p.sampling=SamplingMethod ; -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+AREA%5BStudyType%5DObservational&fields=NCTId&fmt=json&max_rnk=1000') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=AREA%5BStudyType%5DObservational&fields=NCTId&fmt=json&max_rnk=1000') yield value with value.StudyFieldsResponse.NStudiesFound as NStudies, RANGE(0,(value.StudyFieldsResponse.NStudiesFound/1000)) as nloop UNWIND nloop as i with range(1+1000*i,1000+1000*i,999) as RANGES with RANGES, RANGES[1] as urange, RANGES[0] as lrange -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+AREA%5BStudyType%5DObservational&fields=NCTId,Gender,GenderBased,GenderDescription,MinimumAge,MaximumAge,HealthyVolunteers,StudyPopulation,SamplingMethod,EligibilityCriteria&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=AREA%5BStudyType%5DObservational&fields=NCTId,Gender,GenderBased,GenderDescription,MinimumAge,MaximumAge,HealthyVolunteers,StudyPopulation,SamplingMethod,EligibilityCriteria&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value with value.StudyFieldsResponse.StudyFields as coll unwind coll as study_metadata UNWIND study_metadata.NCTId as Id match(ct:ClinicalTrial{NCTId:Id}) @@ -348,12 +348,12 @@ with ct, g, study_metadata UNWIND study_metadata.GenderDescription as GenderDescription set g.description=GenderDescription ; -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+AREA%5BStudyType%5DObservational&fields=NCTId&fmt=json&max_rnk=1000') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=AREA%5BStudyType%5DObservational&fields=NCTId&fmt=json&max_rnk=1000') yield value with value.StudyFieldsResponse.NStudiesFound as NStudies, RANGE(0,(value.StudyFieldsResponse.NStudiesFound/1000)) as nloop UNWIND nloop as i with range(1+1000*i,1000+1000*i,999) as RANGES with RANGES, RANGES[1] as urange, RANGES[0] as lrange -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+AREA%5BStudyType%5DObservational&fields=NCTId,Gender,GenderBased,GenderDescription,MinimumAge,MaximumAge,HealthyVolunteers,StudyPopulation,SamplingMethod,EligibilityCriteria&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=AREA%5BStudyType%5DObservational&fields=NCTId,Gender,GenderBased,GenderDescription,MinimumAge,MaximumAge,HealthyVolunteers,StudyPopulation,SamplingMethod,EligibilityCriteria&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value with value.StudyFieldsResponse.StudyFields as coll unwind coll as study_metadata UNWIND study_metadata.NCTId as Id match(ct:ClinicalTrial{NCTId:Id}) @@ -361,12 +361,12 @@ UNWIND study_metadata.MinimumAge as MinAge UNWIND study_metadata.MaximumAge as MaxAge MERGE (ct)-[:INCLUDES_AGE_RANGE]->(a:AgeRange{minAge:MinAge,maxAge:MaxAge}) ; -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+AREA%5BStudyType%5DObservational&fields=NCTId&fmt=json&max_rnk=1000') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=AREA%5BStudyType%5DObservational&fields=NCTId&fmt=json&max_rnk=1000') yield value with value.StudyFieldsResponse.NStudiesFound as NStudies, RANGE(0,(value.StudyFieldsResponse.NStudiesFound/1000)) as nloop UNWIND nloop as i with range(1+1000*i,1000+1000*i,999) as RANGES with RANGES, RANGES[1] as urange, RANGES[0] as lrange -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+AREA%5BStudyType%5DObservational&fields=NCTId,Gender,GenderBased,GenderDescription,MinimumAge,MaximumAge,HealthyVolunteers,StudyPopulation,SamplingMethod,EligibilityCriteria&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=AREA%5BStudyType%5DObservational&fields=NCTId,Gender,GenderBased,GenderDescription,MinimumAge,MaximumAge,HealthyVolunteers,StudyPopulation,SamplingMethod,EligibilityCriteria&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value with value.StudyFieldsResponse.StudyFields as coll unwind coll as study_metadata UNWIND study_metadata.NCTId as Id match(ct:ClinicalTrial{NCTId:Id}) @@ -387,12 +387,12 @@ with ct, Inclusion, Exclusion MERGE(incl:InclusionCriteria{criteria:Inclusion}) MERGE(ct)-[:HAS_INCLUSION_CRITERIA]->(incl) MERGE(excl:ExclusionCriteria{criteria:Exclusion}) MERGE(ct)-[:HAS_EXCLUSION_CRITERIA]->(excl) ; -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+AREA%5BStudyType%5DObservational&fields=NCTId&fmt=json&max_rnk=1000') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=AREA%5BStudyType%5DObservational&fields=NCTId&fmt=json&max_rnk=1000') yield value with value.StudyFieldsResponse.NStudiesFound as NStudies, RANGE(0,(value.StudyFieldsResponse.NStudiesFound/1000)) as nloop UNWIND nloop as i with range(1+1000*i,1000+1000*i,999) as RANGES with RANGES, RANGES[1] as urange, RANGES[0] as lrange -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+AREA%5BStudyType%5DObservational&fields=NCTId,CentralContactName,CentralContactEmail,OverallOfficialName,OverallOfficialAffiliation,OverallOfficialRole&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=AREA%5BStudyType%5DObservational&fields=NCTId,CentralContactName,CentralContactEmail,OverallOfficialName,OverallOfficialAffiliation,OverallOfficialRole&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value with value.StudyFieldsResponse.StudyFields as coll unwind coll as study_metadata UNWIND study_metadata.NCTId as Id match(ct:ClinicalTrial{NCTId:Id}) @@ -403,12 +403,12 @@ with study_metadata,c UNWIND study_metadata.CentralContactEmail as Email SET c.email=Email ; -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+AREA%5BStudyType%5DObservational&fields=NCTId&fmt=json&max_rnk=1000') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=AREA%5BStudyType%5DObservational&fields=NCTId&fmt=json&max_rnk=1000') yield value with value.StudyFieldsResponse.NStudiesFound as NStudies, RANGE(0,(value.StudyFieldsResponse.NStudiesFound/1000)) as nloop UNWIND nloop as i with range(1+1000*i,1000+1000*i,999) as RANGES with RANGES, RANGES[1] as urange, RANGES[0] as lrange -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+AREA%5BStudyType%5DObservational&fields=NCTId,LocationFacility,LocationCity,LocationState,LocationCountry&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=AREA%5BStudyType%5DObservational&fields=NCTId,LocationFacility,LocationCity,LocationState,LocationCountry&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value with value.StudyFieldsResponse.StudyFields as coll unwind coll as study_metadata UNWIND study_metadata.NCTId as Id match(ct:ClinicalTrial{NCTId:Id}) @@ -427,12 +427,12 @@ FOREACH(i in ncity | MERGE(ci)-[:LOCATED_IN]->(c) ) ; -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+AREA%5BStudyType%5DObservational&fields=NCTId&fmt=json&max_rnk=1000') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=AREA%5BStudyType%5DObservational&fields=NCTId&fmt=json&max_rnk=1000') yield value with value.StudyFieldsResponse.NStudiesFound as NStudies, RANGE(0,(value.StudyFieldsResponse.NStudiesFound/1000)) as nloop UNWIND nloop as i with range(1+1000*i,1000+1000*i,999) as RANGES with RANGES, RANGES[1] as urange, RANGES[0] as lrange -call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=COVID+AND+AREA%5BStudyType%5DObservational&fields=NCTId,ReferencePMID,ReferenceCitation,ReferenceType,SeeAlsoLinkURL&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value +call apoc.load.json('https://clinicaltrials.gov/api/query/study_fields?expr=AREA%5BStudyType%5DObservational&fields=NCTId,ReferencePMID,ReferenceCitation,ReferenceType,SeeAlsoLinkURL&min_rnk='+lrange+'&max_rnk='+urange+'&fmt=json') yield value with value.StudyFieldsResponse.StudyFields as coll unwind coll as study_metadata UNWIND study_metadata.NCTId as Id match(ct:ClinicalTrial{NCTId:Id}) @@ -454,4 +454,4 @@ MERGE(ct)-[:REFERS_TO_URL]->(l) match(i:InclusionCriteria) where i.criteria in ['-', 'none'] DETACH DELETE i ; match(e:ExclusionCriteria) where e.criteria in ['-', 'none'] DETACH DELETE e -; +; \ No newline at end of file