From 063085b14cc132bd6a576c208800edfb8b0fb243 Mon Sep 17 00:00:00 2001 From: Edward Gao Date: Wed, 31 Jan 2024 14:27:12 -0800 Subject: [PATCH] fixes --- .../redshift/typing_deduping/RedshiftDestinationHandler.java | 3 ++- .../typing_deduping/RedshiftSqlGeneratorIntegrationTest.java | 5 +++++ 2 files changed, 7 insertions(+), 1 deletion(-) diff --git a/airbyte-integrations/connectors/destination-redshift/src/main/java/io/airbyte/integrations/destination/redshift/typing_deduping/RedshiftDestinationHandler.java b/airbyte-integrations/connectors/destination-redshift/src/main/java/io/airbyte/integrations/destination/redshift/typing_deduping/RedshiftDestinationHandler.java index a9b0ec0330e0..f697b9525ebc 100644 --- a/airbyte-integrations/connectors/destination-redshift/src/main/java/io/airbyte/integrations/destination/redshift/typing_deduping/RedshiftDestinationHandler.java +++ b/airbyte-integrations/connectors/destination-redshift/src/main/java/io/airbyte/integrations/destination/redshift/typing_deduping/RedshiftDestinationHandler.java @@ -14,12 +14,13 @@ import java.util.List; import java.util.UUID; import lombok.extern.slf4j.Slf4j; +import org.jooq.SQLDialect; @Slf4j public class RedshiftDestinationHandler extends JdbcDestinationHandler { public RedshiftDestinationHandler(final String databaseName, final JdbcDatabase jdbcDatabase) { - super(databaseName, jdbcDatabase); + super(databaseName, jdbcDatabase, SQLDialect.POSTGRES); } @Override diff --git a/airbyte-integrations/connectors/destination-redshift/src/test-integration/java/io/airbyte/integrations/destination/redshift/typing_deduping/RedshiftSqlGeneratorIntegrationTest.java b/airbyte-integrations/connectors/destination-redshift/src/test-integration/java/io/airbyte/integrations/destination/redshift/typing_deduping/RedshiftSqlGeneratorIntegrationTest.java index 0467db068485..6a54fa5e4c85 100644 --- a/airbyte-integrations/connectors/destination-redshift/src/test-integration/java/io/airbyte/integrations/destination/redshift/typing_deduping/RedshiftSqlGeneratorIntegrationTest.java +++ b/airbyte-integrations/connectors/destination-redshift/src/test-integration/java/io/airbyte/integrations/destination/redshift/typing_deduping/RedshiftSqlGeneratorIntegrationTest.java @@ -159,6 +159,11 @@ protected DestinationHandler getDestinationHandler() { return new RedshiftDestinationHandler(databaseName, database); } + @Override + protected boolean supportsSafeCast() { + return true; + } + @Override protected JdbcDatabase getDatabase() { return database;