-
Notifications
You must be signed in to change notification settings - Fork 85
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
E2e bigquerymultitable #1277
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