neo4j-streams
neo4j-streams copied to clipboard
Implement writeTransaction function
Please add a feature which will replace the usage of the readTransaction function (into the Neo4jSourceService.kt class) with a writeTransaction so that users can provide a cypher query with also write operations and not only read operations.
For example,
We could set neo4j.source.query so we have a .sentToKafka property to indicate which node information was already sent.
So using our movies example if we want to send information about people:
MATCH (n:Movie) WHERE (n.sentToKafka is null or n.sentToKafka = 'N') SET n.sentToKafka = 'Y' return n
Thank you for your help!