lint

Author: Amogh-Bharadwaj

flow/connectors/postgres/normalize_stmt_generator.go

@@ -178,10 +178,10 @@ func (n *normalizeStmtGenerator) generateMergeStatement(
 		// Include them in the record as jsonb, then unwrap in the USING SELECT.
 		switch column.Type {
 		case "json":
-			recordDefs = append(recordDefs, fmt.Sprintf("%s jsonb", quotedCol))
+			recordDefs = append(recordDefs, quotedCol+" jsonb")
 			selectExprs = append(selectExprs, fmt.Sprintf("(%s #>> '{}')::json AS %s", quotedCol, quotedCol))
 		case "jsonb":
-			recordDefs = append(recordDefs, fmt.Sprintf("%s jsonb", quotedCol))
+			recordDefs = append(recordDefs, quotedCol+" jsonb")
 			selectExprs = append(selectExprs, fmt.Sprintf("(%s #>> '{}')::jsonb AS %s", quotedCol, quotedCol))
 		default:
 			recordDefs = append(recordDefs, fmt.Sprintf("%s %s", quotedCol, pgType))