postgres updates to latest cdk

airbytehq · Feb 13, 2024 · 4c6f0f6 · 4c6f0f6
1 parent c15b812
commit 4c6f0f6
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 13 deletions.
diff --git a/airbyte-integrations/connectors/destination-postgres-strict-encrypt/build.gradle b/airbyte-integrations/connectors/destination-postgres-strict-encrypt/build.gradle
@@ -5,7 +5,7 @@ plugins {
 airbyteJavaConnector {
     cdkVersionRequired = '0.20.4'
     features = ['db-destinations', 'typing-deduping', 'datastore-postgres']
-    useLocalCdk = false
+    useLocalCdk = true
 }
 
 application {

diff --git a/airbyte-integrations/connectors/destination-postgres/build.gradle b/airbyte-integrations/connectors/destination-postgres/build.gradle
@@ -5,7 +5,7 @@ plugins {
 airbyteJavaConnector {
     cdkVersionRequired = '0.20.4'
     features = ['db-destinations', 'datastore-postgres', 'typing-deduping']
-    useLocalCdk = false
+    useLocalCdk = true
 }
 
 application {

diff --git a/...va/io/airbyte/integrations/destination/postgres/typing_deduping/PostgresSqlGenerator.java b/...va/io/airbyte/integrations/destination/postgres/typing_deduping/PostgresSqlGenerator.java
@@ -173,20 +173,12 @@ protected List<Field<?>> extractRawDataFields(final LinkedHashMap<ColumnId, Airb
         .map(column -> castedField(
             extractColumnAsJson(column.getKey()),
             column.getValue(),
-            column.getKey().name(),
-            useExpensiveSaferCasting))
-        .collect(Collectors.toList());
+            useExpensiveSaferCasting
+            ).as(quotedName(column.getKey().name()))
+        ).collect(Collectors.toList());
   }
 
   @Override
-  protected Field<?> castedField(
-                                 final Field<?> field,
-                                 final AirbyteType type,
-                                 final String alias,
-                                 final boolean useExpensiveSaferCasting) {
-    return castedField(field, type, useExpensiveSaferCasting).as(quotedName(alias));
-  }
-
   protected Field<?> castedField(
                                  final Field<?> field,
                                  final AirbyteType type,