postgres updates to latest cdk

airbytehq · Feb 1, 2024 · 62d1d26 · 62d1d26
1 parent 38b5a37
commit 62d1d26
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
@@ -9,7 +9,7 @@ airbyteJavaConnector {
             'db-sources', // required for tests
             'db-destinations'
     ]
-    useLocalCdk = false
+    useLocalCdk = true
 }
 
 //remove once upgrading the CDK version to 0.4.x or later

diff --git a/airbyte-integrations/connectors/destination-postgres/build.gradle b/airbyte-integrations/connectors/destination-postgres/build.gradle
@@ -9,7 +9,7 @@ airbyteJavaConnector {
             'db-sources', // required for tests
             'db-destinations',
     ]
-    useLocalCdk = false
+    useLocalCdk = true
 }
 
 //remove once upgrading the CDK version to 0.4.x or later

diff --git a/...va/io/airbyte/integrations/destination/postgres/typing_deduping/PostgresSqlGenerator.java b/...va/io/airbyte/integrations/destination/postgres/typing_deduping/PostgresSqlGenerator.java
@@ -160,20 +160,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,