app/graphdb/main.py

from app import driver 
 
 
def match_person_nodes(tx, uid1: str, uid2: str): 
 tx.run("MERGE (p1:Person {uid: " + uid1 + "})") 
 tx.run("MERGE (p2:Person {uid: " + uid2 + "})") 
 tx.run( 
 "MATCH (p1:Person {uid: " 
 + uid1 
 + "}) MATCH (p2:Person {uid: " 
 + uid2 
 + "}) MERGE (p1)-[:FRIEND]-(p2)" 
 ) 
 
 
async def insert2PersonAndSetFriend(uid1: str, uid2: str): 
 with driver.session() as session: 
 session.write_transaction(match_person_nodes, uid1, uid2) 
 
 
async def deleteFriend(uid1: str, uid2: str): 
 driver.execute_query( 
 "MATCH (p1:Person {uid: " 
 + uid1 
 + "})-[r:FRIEND]-(p2:Person {uid: " 
 + uid2 
 + "}) DELETE r" 
 )