Specify column names on Target.

artie-labs · Jun 18, 2024 · 31cab7e · 31cab7e
1 parent 1258dbc
commit 31cab7e
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/clients/bigquery/bigquery.go b/clients/bigquery/bigquery.go
@@ -68,9 +68,10 @@ func (s *Store) Append(tableData *optimization.TableData, useTempTable bool) err
 		return fmt.Errorf("failed to append: %w", err)
 	}
 
-	query := fmt.Sprintf(`INSERT INTO %s SELECT %s FROM %s`,
+	query := fmt.Sprintf(`INSERT INTO %s (%s) SELECT %s FROM %s`,
 		tableID.FullyQualifiedName(),
 		strings.Join(sql.QuoteIdentifiers(tableData.ReadOnlyInMemoryCols().GetColumnsToUpdate(), s.Dialect()), ","),
+		strings.Join(sql.QuoteIdentifiers(tableData.ReadOnlyInMemoryCols().GetColumnsToUpdate(), s.Dialect()), ","),
 		temporaryTableID.FullyQualifiedName(),
 	)