diff --git a/backend/memgraph/create_relationship.go b/backend/memgraph/create_relationship.go index b55cda6..34b1d20 100644 --- a/backend/memgraph/create_relationship.go +++ b/backend/memgraph/create_relationship.go @@ -26,7 +26,8 @@ func (r *Relationship) CreateRelationship(driver neo4j.DriverWithContext) (*neo4 } else if r.Direction == "<-" { query = fmt.Sprintf(`%s CREATE (a)<-[r:%s {verified: false}]-(b) RETURN r;`, query, r.Relationship) } else { - query = fmt.Sprintf(`%s CREATE (a)-[r:%s {verified: false}]-(b) RETURN r;`, query, r.Relationship) + query = fmt.Sprintf(`%s CREATE (a)<-[r1:%s {verified: True}]-(b) CREATE (a)-[r2:%s {verified: True}]->(b) RETURN r1, r2;`, + query, r.Relationship, r.Relationship) } result, err := session.Run(ctx, query, nil) diff --git a/backend/memgraph/create_relationship_and_person.go b/backend/memgraph/create_relationship_and_person.go index d1649f1..ae3828f 100644 --- a/backend/memgraph/create_relationship_and_person.go +++ b/backend/memgraph/create_relationship_and_person.go @@ -23,7 +23,7 @@ func (rp *RelationshipAndPerson) CreateRelationshipAndPerson(driver neo4j.Driver rp.Person.ID = strings.ReplaceAll(uuid.New().String(), "-", "") - query := fmt.Sprintf(`MATCH (a:Person) WHERE a.ID = %s`, rp.Relationship.FirstPersonID) + query := fmt.Sprintf(`MATCH (a:Person) WHERE a.ID = '%s'`, rp.Relationship.FirstPersonID) query = fmt.Sprintf("%s CREATE (b:Person {%s})", query, rp.Person.ToString()) @@ -32,7 +32,8 @@ func (rp *RelationshipAndPerson) CreateRelationshipAndPerson(driver neo4j.Driver } else if rp.Relationship.Direction == "<-" { query = fmt.Sprintf(`%s CREATE (a)<-[r:%s {verified: True}]-(b) RETURN r;`, query, rp.Relationship.Relationship) } else { - query = fmt.Sprintf(`%s CREATE (a)-[r:%s {verified: True}]-(b) RETURN r;`, query, rp.Relationship.Relationship) + query = fmt.Sprintf(`%s CREATE (a)<-[r1:%s {verified: True}]-(b) CREATE (a)-[r2:%s {verified: True}]->(b) RETURN r1, r2, b;`, + query, rp.Relationship.Relationship, rp.Relationship.Relationship) } result, err := session.Run(ctx, query, nil)