neo4j-streams icon indicating copy to clipboard operation
neo4j-streams copied to clipboard

Implement writeTransaction function

Open viveksaran71 opened this issue 3 years ago • 0 comments

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!

viveksaran71 avatar Jan 26 '22 15:01 viveksaran71