-
Notifications
You must be signed in to change notification settings - Fork 34
cloudSql-mySql e2e #408
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
cloudSql-mySql e2e #408
Conversation
411a5c0 to
6905e24
Compare
3f7326e to
38c502d
Compare
88a567e to
ee2d76d
Compare
| } | ||
| } | ||
|
|
||
|
|
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.
Nit: Remove extra empty line
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.
Removed extra line.
| package io.cdap.plugin.cloudmysql.stepsdesign; | ||
|
|
||
|
|
||
|
|
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.
Nit: Remove extra empty line
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.
Removed.
| @@ -0,0 +1,21 @@ | |||
| /* | |||
| * Copyright © 2022 Cask Data, Inc. | |||
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.
fix year
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.
Changed it to '2023'
|
|
||
|
|
||
|
|
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.
Nit: Remove extra empty lines (keep only 1)
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.
Removed extra line.
| ## License for the specific language governing permissions and limitations under | ||
| # the License.. | ||
|
|
||
| @CloudMySql |
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.
Should this also be a required test (@CloudMySql_Required) similar to the one for sink (cloudsql-mysql-plugin/src/e2e-test/features/sink/CloudMySqlDesignTime.feature)?
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.
The Required tag has been included for every feature of the source and sink. Added the @CloudMySql_Required tag to this feature.
| ResultSet rs = statement.executeQuery(countQuery)) { | ||
| int num = 0; | ||
| while (rs.next()) { | ||
| num = (rs.getInt(1)); |
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.
| num = (rs.getInt(1)); | |
| num = rs.getInt(1); |
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.
Done.
|
|
||
| public static void createTargetDatatypesTable(String targetTable) throws SQLException, ClassNotFoundException { | ||
| try (Connection connect = getCloudSqlConnection(); Statement statement = connect.createStatement()) { | ||
| String datatypesColumns = PluginPropertyUtils.pluginProp("datatypesColumns"); |
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.
Use constant
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.
Replaced with constants.
| public static List<Object> bigQueryRows = new ArrayList<>(); | ||
| public static Gson gson = new Gson(); | ||
|
|
||
| public static void main(String[] args) throws SQLException, ClassNotFoundException { |
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.
Remove the main method
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.
Removed the main function.
|
|
||
| boolean recordsMatched = BQValidation.validateDBAndBQRecordValues( | ||
| PluginPropertyUtils.pluginProp("sourceTable"), | ||
| PluginPropertyUtils.pluginProp("bqTargetTable")); |
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.
use constants
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.
Done.
|
Please check and fix build failures |
7fcaead to
6be3897
Compare
|
Let's ensure e2e build passes before merging |
6ab4ca0 to
9e0903d
Compare
9e0903d to
14ffab5
Compare
14ffab5 to
9b8c049
Compare
cloudsql-mysql e2e