Fix/primary key only table #194
Closed
Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
Fix
fixes #142
Types of changes
Description
The Pull request fixes the connector issue, which doesn't support primary key-only tables.
In Cassandra, if there is any table with only primary key columns,
Ex,
then the connector throws an error because of an error in the SQL select statement formation.
Considerations
There is confusion on the issue (#142) about what to push into the data topic when it's only a primary key table, and how to differentiate between a delete query and primary key-only table inserts.
To differentiate between the above-mentioned scenarios, we decided to send all the columns' data into the value field (including primary key columns) for insert and update for a primary key-only table.
The delete query data for all types of tables, including primary key-only tables, will have the value as
nullfor AVRO and{}for JSON, as before.What's added/changed
Checklist: