airbytehq
diff --git a/‎airbyte-integrations/connectors/destination-redshift/src/main/java/io/airbyte/integrations/destination/redshift/RedshiftSqlOperations.java‎
Lines changed: 1 addition & 1 deletion b/‎airbyte-integrations/connectors/destination-redshift/src/main/java/io/airbyte/integrations/destination/redshift/RedshiftSqlOperations.java‎
Lines changed: 1 addition & 1 deletion
@@ -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);
  }
Original file line number	Diff line number	Diff line change
`@@ -52,7 +52,7 @@ public void insertRecordsInternal(final JdbcDatabase database,`
`52`	`52`	`JavaBaseConstants.COLUMN_NAME_AB_ID,`
`53`	`53`	`JavaBaseConstants.COLUMN_NAME_DATA,`
`54`	`54`	`JavaBaseConstants.COLUMN_NAME_EMITTED_AT);`
`55`		`- final String recordQueryComponent = "(?, ?, ?),\n";`
	`55`	`+ final String recordQueryComponent = "(?, JSON_PARSE(?), ?),\n";`
`56`	`56`	`SqlOperationsUtils.insertRawRecordsInSingleQuery(insertQueryComponent, recordQueryComponent, database, records);`
`57`	`57`	`}`
`58`	`58`