I have problem when i try to load data to neo4j with spark

Neo4j Graph Platform Cypher
,
1

Hi,

i have a simple dataframe that i'm tying to load as nodes and relations to neo4j via spark and i doesnt work.

i used the query option to do it
my query is
"""MERGE (s:Person {s.phone: event.phone_number})
MERGE (t:Location {t.loc: event.city})
MERGE (s)-[rel:visit_type {rel.type: event.type}]->(t)
"""
i keep getting the error "please provide a valid WRITE query"
phone_number/city/type are three columns in my dataframe

can anybody help me with it?

thanks

2

I don't know if this is the cause of your error, but your syntax is not correct. Try this instead:

MERGE (s:Person {phone: event.phone_number})
MERGE (t:Location {loc: event.city})
MERGE (s)-[rel:visit_type {type: event.type}]->(t)