json parse

airbytehq · Feb 23, 2022 · 11a6725 · 11a6725
1 parent c68fc92
commit 11a6725
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...ift/src/main/java/io/airbyte/integrations/destination/redshift/RedshiftSqlOperations.java b/...ift/src/main/java/io/airbyte/integrations/destination/redshift/RedshiftSqlOperations.java
@@ -52,7 +52,7 @@ public void insertRecordsInternal(final JdbcDatabase database,
         JavaBaseConstants.COLUMN_NAME_AB_ID,
         JavaBaseConstants.COLUMN_NAME_DATA,
         JavaBaseConstants.COLUMN_NAME_EMITTED_AT);
-    final String recordQueryComponent = "(?, ?, ?),\n";
+    final String recordQueryComponent = "(?, JSON_PARSE(?), ?),\n";
     SqlOperationsUtils.insertRawRecordsInSingleQuery(insertQueryComponent, recordQueryComponent, database, records);
   }