Rules are what used to avoid creating redundant nodes . E.g. Encounter has object field called subject , since every object makes a node in the graph
So a node called Subject will be created without the Rules . But we specified rename subject with patient since we know that this object
refers to a patient object so instead of Subject , Patient node will be created or merged with existing Node.
rules := map[string]map[string]interface{}{
"Encounter": {
"subject": "patient",
"serviceProvider": "organization",
},
"Patient": {
"generalPractitioner": "practitioner",
},
}Sample Usages
func main() {
data := []byte(`
{
"id": "49c2df26-6fb9-43fb-82a2-3bd413a95934",
"meta": {
"profile": [
"http://standardhealthrecord.org/fhir/StructureDefinition/shr-demographics-PersonOfRecord"
]
},
"identifier": [
{
"type": {
"coding": [
{
"system": "http://hl7.org/fhir/identifier-type",
"code": "SB"
}
]
},
"system": "http://hl7.org/fhir/sid/us-ssn",
"value": "999608294"
}
],
"name": [
{
"use": "official",
"family": "Abernathy691",
"given": [
"Carlotta591"
]
}
],
"telecom": [
{
"system": "phone",
"value": "1-892-670-6907 x741",
"use": "home"
}
],
"gender": "female",
"birthDate": "2004-09-12",
"address": [
{
"line": [
"775 Jerde Pike"
],
"city": "Sunderland",
"state": "MA",
"postalCode": "01375",
"country": "US"
}
],
"maritalStatus": {
"coding": [
{
"system": "http://hl7.org/fhir/v3/MaritalStatus",
"code": "S"
}
],
"text": "Never Married"
},
"multipleBirthBoolean": false,
"communication": [
{
"language": {
"coding": [
{
"system": "http://hl7.org/fhir/ValueSet/languages",
"code": "en-US",
"display": "English (United States)"
}
]
}
}
],
"generalPractitioner": [
{
"reference": "urn:uuid:1a3711a3-1d38-4aeb-b25f-705ea922b1c2"
}
],
"resourceType": "Patient"
}
`)
/*var graphs []Graph
master := createMasterNode(&unmarshal)
graphs = append(graphs, master)*/
rules := map[string]map[string]interface{}{
"Patient": {
"generalPractitioner": "practitioner",
},
}
var unmarshal map[string]interface{}
err := json.Unmarshal(data, &unmarshal)
if err != nil {
panic(err)
}
resource := unmarshal["resourceType"].(string)
jsonInfo := models.JSONInfo{
DecodedJSON: unmarshal,
Rules: getRules(resource, rules),
Master: strings.ToLower(resource),
ID: unmarshal["id"].(string),
}
j := J.Jypher{}
graph := j.GetJypher(&jsonInfo)
data, _ = json.MarshalIndent(graph, " ", " ")
fmt.Println(string(data))
cypher := j.BuildCypher()
fmt.Println(cypher)
}
func getRules(resource string, rules map[string]map[string]interface{}) map[string]interface{} {
if rule, ok := rules[resource]; ok {
return rule
} else {
panic(fmt.Sprintf("Rules provided but rules for [%s] not found, check the rules dictionary", resource))
}
return nil
}Decoded Graph model out of the JSON
{
"address0":{
"nodes":{
"lebel":"address0",
"properties":[
{
"city":"Sunderland"
},
{
"state":"MA"
},
{
"postalCode":"01375"
},
{
"country":"US"
}
]
},
"edges":{
"source":"patient",
"target":"address0"
}
},
"coding0":{
"nodes":{
"lebel":"coding0",
"properties":[
{
"system":"http://hl7.org/fhir/identifier-type"
},
{
"code":"SB"
}
]
},
"edges":{
"source":"type",
"target":"coding0"
}
},
"coding1":{
"nodes":{
"lebel":"coding1",
"properties":[
{
"system":"http://hl7.org/fhir/v3/MaritalStatus"
},
{
"code":"S"
}
]
},
"edges":{
"source":"maritalStatus",
"target":"coding1"
}
},
"coding4":{
"nodes":{
"lebel":"coding4",
"properties":[
{
"system":"http://hl7.org/fhir/ValueSet/languages"
},
{
"code":"en-US"
},
{
"display":"English (United States)"
}
]
},
"edges":{
"source":"language",
"target":"coding4"
}
},
"communication4":{
"nodes":{
"lebel":"communication4"
},
"edges":{
"source":"patient",
"target":"communication4"
}
},
"identifier0":{
"nodes":{
"lebel":"identifier0",
"properties":[
{
"system":"http://hl7.org/fhir/sid/us-ssn"
},
{
"value":"999608294"
}
]
},
"edges":{
"source":"patient",
"target":"identifier0"
}
},
"language":{
"nodes":{
"lebel":"language"
},
"edges":{
"source":"communication4",
"target":"language"
}
},
"maritalStatus":{
"nodes":{
"lebel":"maritalStatus",
"properties":[
{
"text":"Never Married"
}
]
},
"edges":{
"source":"patient",
"target":"maritalStatus"
}
},
"meta":{
"nodes":{
"lebel":"meta"
},
"edges":{
"source":"patient",
"target":"meta"
}
},
"name1":{
"nodes":{
"lebel":"name1",
"properties":[
{
"use":"official"
},
{
"family":"Abernathy691"
}
]
},
"edges":{
"source":"patient",
"target":"name1"
}
},
"patient":{
"nodes":{
"id":"49c2df26-6fb9-43fb-82a2-3bd413a95934",
"lebel":"patient",
"properties":[
{
"resourceType":"Patient"
},
{
"id":"49c2df26-6fb9-43fb-82a2-3bd413a95934"
},
{
"gender":"female"
},
{
"birthDate":"2004-09-12"
}
]
},
"edges":{
"source":"patient",
"target":"patient"
}
},
"practitioner3":{
"nodes":{
"id":"urn:uuid:1a3711a3-1d38-4aeb-b25f-705ea922b1c2",
"lebel":"practitioner3",
"properties":[
{
"reference":"urn:uuid:1a3711a3-1d38-4aeb-b25f-705ea922b1c2"
}
]
},
"edges":{
"source":"patient",
"target":"practitioner3"
}
},
"telecom2":{
"nodes":{
"lebel":"telecom2",
"properties":[
{
"value":"1-892-670-6907 x741"
},
{
"use":"home"
},
{
"system":"phone"
}
]
},
"edges":{
"source":"patient",
"target":"telecom2"
}
},
"type":{
"nodes":{
"lebel":"type"
},
"edges":{
"source":"identifier0",
"target":"type"
}
}
}Generated CYPHER QUERY
MERGE (patient:Patient {id:'49c2df26-6fb9-43fb-82a2-3bd413a95934'}) ON CREATE SET patient.resourceType = 'Patient', patient.id = '49c2df26-6fb9-43fb-82a2-3bd413a95934', patient.gender = 'female', patient.birthDate = '2004-09-12'
CREATE (identifier0:Identifier) SET identifier0.system = 'http://hl7.org/fhir/sid/us-ssn', identifier0.value = '999608294', identifier0._id = '49c2df26-6fb9-43fb-82a2-3bd413a95934'
MERGE (patient)-[:PATIENT_IDENTIFIER]->(identifier0)
CREATE (type:Type) SET type._id = '49c2df26-6fb9-43fb-82a2-3bd413a95934'
MERGE (identifier0)-[:IDENTIFIER0_TYPE]->(type)
CREATE (coding0:Coding) SET coding0.system = 'http://hl7.org/fhir/identifier-type', coding0.code = 'SB', coding0._id = '49c2df26-6fb9-43fb-82a2-3bd413a95934'
MERGE (type)-[:TYPE_CODING]->(coding0)
CREATE (name1:Name) SET name1.use = 'official', name1.family = 'Abernathy691', name1._id = '49c2df26-6fb9-43fb-82a2-3bd413a95934'
MERGE (patient)-[:PATIENT_NAME]->(name1)
CREATE (telecom2:Telecom) SET telecom2.value = '1-892-670-6907 x741', telecom2.use = 'home', telecom2.system = 'phone', telecom2._id = '49c2df26-6fb9-43fb-82a2-3bd413a95934'
MERGE (patient)-[:PATIENT_TELECOM]->(telecom2)
MERGE (practitioner3:Practitioner {id:'urn:uuid:1a3711a3-1d38-4aeb-b25f-705ea922b1c2'}) ON CREATE SET practitioner3.reference = 'urn:uuid:1a3711a3-1d38-4aeb-b25f-705ea922b1c2'
MERGE (patient)-[:PATIENT_PRACTITIONER]->(practitioner3)
CREATE (communication4:Communication) SET communication4._id = '49c2df26-6fb9-43fb-82a2-3bd413a95934'
MERGE (patient)-[:PATIENT_COMMUNICATION]->(communication4)
CREATE (language:Language) SET language._id = '49c2df26-6fb9-43fb-82a2-3bd413a95934'
MERGE (communication4)-[:COMMUNICATION4_LANGUAGE]->(language)
CREATE (coding4:Coding) SET coding4.system = 'http://hl7.org/fhir/ValueSet/languages', coding4.code = 'en-US', coding4.display = 'English (United States)', coding4._id = '49c2df26-6fb9-43fb-82a2-3bd413a95934'
MERGE (language)-[:LANGUAGE_CODING]->(coding4)
CREATE (meta:Meta) SET meta._id = '49c2df26-6fb9-43fb-82a2-3bd413a95934'
MERGE (patient)-[:PATIENT_META]->(meta) CREATE (address0:Address) SET address0.city = 'Sunderland', address0.state = 'MA', address0.postalCode = '01375', address0.country = 'US', address0._id = '49c2df26-6fb9-43fb-82a2-3bd413a95934'
MERGE (patient)-[:PATIENT_ADDRESS]->(address0)
CREATE (maritalStatus:MaritalStatus) SET maritalStatus.text = 'Never Married', maritalStatus._id = '49c2df26-6fb9-43fb-82a2-3bd413a95934'
MERGE (patient)-[:PATIENT_MARITALSTATUS]->(maritalStatus) CREATE (coding1:Coding) SET coding1.system = 'http://hl7.org/fhir/v3/MaritalStatus', coding1.code = 'S', coding1._id = '49c2df26-6fb9-43fb-82a2-3bd413a95934'
MERGE (maritalStatus)-[:MARITALSTATUS_CODING]->(coding1)
Sample Output Graph
- Create separate Node with Array of String
- Serialization of Query Generation for better Execution of Cypher
- Remove id field from properties of master node
- multiple identifier in a array list with same type of field name , right now it skips and takes only one