-
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
🎉Source-redshift: added an optional field for schema\s selection #9721
🎉Source-redshift: added an optional field for schema\s selection #9721
Conversation
/test connector=connectors/source-redshift
|
...rs/source-redshift/src/main/java/io/airbyte/integrations/source/redshift/RedshiftSource.java
Outdated
Show resolved
Hide resolved
...rs/source-redshift/src/main/java/io/airbyte/integrations/source/redshift/RedshiftSource.java
Show resolved
Hide resolved
...rs/source-redshift/src/main/java/io/airbyte/integrations/source/redshift/RedshiftSource.java
Outdated
Show resolved
Hide resolved
...rs/source-redshift/src/main/java/io/airbyte/integrations/source/redshift/RedshiftSource.java
Show resolved
Hide resolved
...rs/source-redshift/src/main/java/io/airbyte/integrations/source/redshift/RedshiftSource.java
Show resolved
Hide resolved
airbyte-integrations/connectors/source-redshift/src/main/resources/spec.json
Outdated
Show resolved
Hide resolved
.../airbyte/integrations/io/airbyte/integration_tests/sources/RedshiftSourceAcceptanceTest.java
Outdated
Show resolved
Hide resolved
…election # Conflicts: # airbyte-integrations/connectors/source-redshift/src/main/resources/spec.json
...rs/source-redshift/src/main/java/io/airbyte/integrations/source/redshift/RedshiftSource.java
Show resolved
Hide resolved
...rs/source-redshift/src/main/java/io/airbyte/integrations/source/redshift/RedshiftSource.java
Show resolved
Hide resolved
airbyte-integrations/connectors/source-redshift/src/main/resources/spec.json
Outdated
Show resolved
Hide resolved
airbyte-integrations/connectors/source-redshift/src/main/resources/spec.json
Outdated
Show resolved
Hide resolved
@@ -52,6 +53,9 @@ protected void setupEnvironment(final TestDestinationEnv environment) throws Exc | |||
RedshiftSource.DRIVER_CLASS); | |||
|
|||
schemaName = Strings.addRandomSuffix("integration_test", "_", 5).toLowerCase(); | |||
|
|||
config = config.set("schemas", Jsons.jsonNode(List.of(schemaName))); | |||
|
|||
final String createSchemaQuery = String.format("CREATE SCHEMA %s", schemaName); |
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 also create a second schema (like unselected_schema
) with some tables, and verify in the acceptance test that the catalog will not include anything in the second schema?
Otherwise, I think the schema selection is not tested any where currently.
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.
Moved data creation to a separate method and added one more schema creation to have some noise. Thanks
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 just realized that the SourceAcceptanceTest
does not actually verify the catalog. I created an issue to track it:
#9818
/test connector=connectors/source-redshift
|
/publish connector=connectors/source-redshift
|
What
Currently we are not able to select a particular schema for selection. That causes a mess and inconvenience if you have multiple schemas but want to migrate only some of them.
How
Added a new optional field on UI for schema selection similarly to Postgres and Oracle source connectors.
!!!!!!!TODO ONCE PR APPROVED: !!!!!!!!!!
Tested locally:


All schemas are shown If no schemas selected explicitly
Tested with particular schema selection




Recommended reading order
🚨 User Impact 🚨
The newly added field is an optional one. So breaks in backward compatibility are expected.
Pre-merge Checklist
Expand the relevant checklist and delete the others.
New Connector
Community member or Airbyter
airbyte_secret
./gradlew :airbyte-integrations:connectors:<name>:integrationTest
.README.md
bootstrap.md
. See description and examplesdocs/SUMMARY.md
docs/integrations/<source or destination>/<name>.md
including changelog. See changelog exampledocs/integrations/README.md
airbyte-integrations/builds.md
Airbyter
If this is a community PR, the Airbyte engineer reviewing this PR is responsible for the below items.
/test connector=connectors/<name>
command is passing./publish
command described hereUpdating a connector
Community member or Airbyter
airbyte_secret
./gradlew :airbyte-integrations:connectors:<name>:integrationTest
.README.md
bootstrap.md
. See description and examplesdocs/integrations/<source or destination>/<name>.md
including changelog. See changelog exampleAirbyter
If this is a community PR, the Airbyte engineer reviewing this PR is responsible for the below items.
/test connector=connectors/<name>
command is passing./publish
command described here