Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Implement writeTransaction function #521

Closed
viveksaran71 opened this issue Jan 26, 2022 · 1 comment
Closed

Implement writeTransaction function #521

viveksaran71 opened this issue Jan 26, 2022 · 1 comment
Labels
wontfix This will not be worked on

Comments

@viveksaran71
Copy link

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!

@ali-ince ali-ince added the wontfix This will not be worked on label Jan 16, 2025
@ali-ince
Copy link
Contributor

With the introduction of CDC based source connector, this should no longer be needed. But if the user still wants to track what changes have been sent over, it should still be done through timestamp properties.

@ali-ince ali-ince closed this as not planned Won't fix, can't repro, duplicate, stale Jan 16, 2025
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
wontfix This will not be worked on
Projects
None yet
Development

No branches or pull requests

2 participants