-
Notifications
You must be signed in to change notification settings - Fork 86
E2e bigquerymultitable #1277
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
base: develop
Are you sure you want to change the base?
E2e bigquerymultitable #1277
Conversation
6b14d85 to
638e149
Compare
|
Please incorporate the changes from this PR: data-integrations/database-plugins#418 |
79d82d2 to
cd2286e
Compare
.github/workflows/e2e.yml
Outdated
| @@ -1,4 +1,4 @@ | |||
| # Copyright © 2021 Cask Data, Inc. | |||
| # Copyright © 2023 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.
nit: 2021-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.
Resolved
| import java.sql.SQLException; | ||
| import java.sql.Statement; | ||
|
|
||
| import static io.cdap.plugin.bigquerymultitable.stepdesign.BQMultiTableValidation.getMysqlConnection; |
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: avoid using static imports, it makes the code unreadable.
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.
Resolved
pom.xml
Outdated
| <dependency> | ||
| <groupId>mysql</groupId> | ||
| <artifactId>mysql-connector-java</artifactId> | ||
| <version>8.0.19</version> | ||
| <scope>test</scope> | ||
| </dependency> |
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.
If the dependency is only required for e2e-tests, plz add it under e2e-tests profile.
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.
Resolved
| features = {"src/e2e-test/features"}, | ||
| glue = {"io.cdap.plugin.bigquerymultitable.stepsdesign", "io.cdap.plugin.gcs.stepsdesign", "stepsdesign", | ||
| "io.cdap.plugin.common.stepsdesign"}, | ||
| tags = {"@BQMT_SINK and not @PLUGIN-1669"}, |
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.
I am not sure if we can go ahead with the PR before PLUGIN-1669 is implemented.
Almost all the runtime scenarios require multi table plugin and will be skipped.
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.
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.
Moving this PR to draft for now, To run any of the tests which uses BQMT plugin we will have to add a feature to the scripts so we can use plugins from CDAP Hub in the test executions.
| glue = {"io.cdap.plugin.bigquerymultitable.stepsdesign", "io.cdap.plugin.gcs.stepsdesign", "stepsdesign", | ||
| "io.cdap.plugin.common.stepsdesign"}, | ||
| tags = {"@BQMT_Required"}, | ||
| //TODO: Enable test once issue is fixed https://cdap.atlassian.net/browse/PLUGIN-1134 |
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.
Can you plz help me understand how is PLUGIN-1134 related?
I cannot see any scenario involving GCSMove plugin in this PR.
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.
Resolved
| sourceTable=dummy | ||
| tableNameField=tableName | ||
| jdbcPluginName=mysql | ||
| connectionString=jdbc:mysql://10.232.0.88/cdfmysqldb |
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.
Plz do not push any Ip Addresses/hostnames in github.
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.
Deleted the IP
cd2286e to
c5e3721
Compare
src/e2e-test/java/io/cdap/plugin/bigquerymultitable/stepdesign/BQMultiTableValidation.java
Outdated
Show resolved
Hide resolved
src/e2e-test/java/io/cdap/plugin/bigquerymultitable/stepdesign/BQMultiTableValidation.java
Outdated
Show resolved
Hide resolved
src/e2e-test/java/io/cdap/plugin/bigquerymultitable/stepdesign/BigQueryMultiTable.java
Outdated
Show resolved
Hide resolved
|
|
||
| public static void createSourceDatatypesTable(String sourceTable) throws SQLException, ClassNotFoundException { | ||
| try (Connection connect = getMysqlConnection(); Statement statement = connect.createStatement()) { | ||
| String createTableQuery = "CREATE TABLE " + sourceTable + |
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.
How are we validating multiple tables when we are creating just one table here?
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.
As Big Query Multi Table Sink Plugin splits into two Tables. So we have used two existing tables tabA and tabB. Further, extracting the data from both the tables for the validation. This is the source table that is having a column table name which has two values tabA and tabB, which gets split into two table tabA and tabB by BQMT sink plugin.
c5e3721 to
e538b69
Compare
89e0b0b to
f0c2b16
Compare
f0c2b16 to
bc7b626
Compare
f9e4123 to
8b2ad66
Compare
4c9db2e to
74e2152
Compare
170af4a to
568fff4
Compare
91af24c to
ae0c3b0
Compare
d6ccc26 to
d808e6f
Compare
d808e6f to
0d56779
Compare
updated correct conn string, removed space in yml, removed verify goal in pom. changed sql connector java version to run in github actions and bqmt secret updated
54d7577 to
ae12e20
Compare
ae12e20 to
f8611c0
Compare
E2e bigquerymultitable