-
Notifications
You must be signed in to change notification settings - Fork 4.4k
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
Destination mysql: Switch to dv2 raw tables #37322
Conversation
The latest updates on your projects. Learn more about Vercel for Git ↗︎ 1 Ignored Deployment
|
This stack of pull requests is managed by Graphite. Learn more about stacking. |
@@ -132,23 +136,22 @@ protected List<JsonNode> retrieveRecords(final TestDestinationEnv testEnv, | |||
} | |||
|
|||
private List<JsonNode> retrieveRecordsFromTable(final String tableName, final String schemaName) throws SQLException { | |||
try (final DSLContext dslContext = DSLContextFactory.create( | |||
final DSLContext dslContext = DSLContextFactory.create( |
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 think jooq removed the autocloseable interface from DslContext?
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.
yeah had the same experience in Oracle
94a3dc0
to
dd57516
Compare
7a3147d
to
b15916f
Compare
dd57516
to
97d1fa3
Compare
a8dc68e
to
0a27153
Compare
97d1fa3
to
4e09b56
Compare
0a27153
to
81b0ca0
Compare
bd83d63
to
f6e353f
Compare
@@ -43,6 +43,7 @@ | |||
import org.junit.jupiter.api.Timeout; | |||
import org.testcontainers.containers.MySQLContainer; | |||
|
|||
@Disabled |
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.
everything starts failing because we're writing to a different raw table. Disable the legacy DAT suite.
... https://github.com/airbytehq/airbyte/issues/29818 continues to exist
4255c6e
to
f3ee677
Compare
41a159a
to
ecffdd8
Compare
807fef1
to
19bb0fc
Compare
/* | ||
* We want to generate a query like: | ||
* | ||
* LOAD DATA LOCAL INFILE '/a/b/c' INTO TABLE foo.bar FIELDS TERMINATED BY ',' ENCLOSED BY |
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.
.... thanks, autoformat
ecffdd8
to
307c476
Compare
19bb0fc
to
60079a8
Compare
307c476
to
6f1f8b4
Compare
60079a8
to
4f77fe7
Compare
6f1f8b4
to
4be8c70
Compare
4f77fe7
to
b7f83d8
Compare
4be8c70
to
8e32610
Compare
bafc309
to
38c8d07
Compare
8e32610
to
1004c52
Compare
3b4f4fc
to
33935e7
Compare
1004c52
to
7ae481a
Compare
33935e7
to
cf60f60
Compare
7ae481a
to
2067931
Compare
cf60f60
to
2870be2
Compare
2067931
to
be524ad
Compare
2870be2
to
f4cc766
Compare
closing this PR in favor of #36936 |
Switch the raw tables to DV2 format. See #36936 for implementing T+D. This PR sets a few "disable T+D" booleans for the sake of being able to run tests; that PR unsets them.
I'll merge #36936 into this branch and release them as a single major version bump - not planning to publish a version of destination-mysql with just dv2 raw tables.
There's some weird stuff going on in MysqlNameTransformer, which I didn't try to solve here. I mostly just don't understand what all the methods are supposed to do (e.g. how does getIdentifier relate to convertStreamName?). MysqlNameTransformer behaves differently from PostgresNameTransformer, and I elected to work around that inconsistency. IMO we should probably revamp that class to be less opinionated about what tables we create.