-
Notifications
You must be signed in to change notification settings - Fork 0
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
Added One to Many Datatype Transformation for IT #90
Added One to Many Datatype Transformation for IT #90
Conversation
pawankashyapollion
commented
Jan 31, 2025
•
edited by taherkl
Loading
edited by taherkl
- Added One to Many Datatype Transformation for IT
- Fix PR review comments
|
||
private long getRowCount() { | ||
String query = String.format("SELECT COUNT(*) FROM %s", TABLE); | ||
ResultSet resultSet = cassandraResourceManager.executeStatement(query); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
executeStatement can throw exceptions as well...can add try catch on the function
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
@taherkl we should not as even in case of exception test should fail the ideal case it should not throw any exception
} | ||
} | ||
|
||
private void assertRowInCassandraDB() throws MultipleFailureException { |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Add comments to all the functions
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Address the same
@@ -25,14 +25,18 @@ | |||
import com.google.gson.JsonObject; | |||
import com.google.pubsub.v1.SubscriptionName; | |||
import com.google.pubsub.v1.TopicName; | |||
import java.io.IOException; | |||
import java.io.*; |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
import * will fail the spotless check i guess
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Handle the same
spannerResourceManager.write(m); | ||
} | ||
|
||
private void assertCustomRowsInCassandraDB() throws MultipleFailureException { |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Make sure to add comments for all the functions.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Addressed
} | ||
} | ||
|
||
private void writeBasicRowInSpanner() { |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
This file does not have comments for functions
…m#2155) * Add IT for Cassandra (#86) * Add IT for Cassandra Reverse Replication * Added IT Fixes * Added IT fixes * removed logger * removed unwanted system log * Handle Catch * Handle with safehandler * Running load test * revert unwanted commit * Added IT FIXES * Added UT and removed unwanted SOUT * Added One to Many Datatype Transformation for IT (#90) Added One to Many Datatype Transformation for IT Fix PR review comments * Handle IT for MYSQL * Added ByteBuffer TO BigInteger * Cassandra rr custom transfornation it test (#96) * PR Review Comments (#97) * Splotless fixes * Handle Retry Missing Exception Category * Rebase Issue fixes --------- Co-authored-by: pawankashyapollion <v-pawan.kumar@ollion.com>