feedback

flow/connectors/postgres/qvalue_convert.go

@@ -248,6 +248,8 @@ func parseUUID(value interface{}) (qvalue.QValue, error) {
 			return nil, fmt.Errorf("invalid UUID string: %w", err)
 		}
 		return qvalue.QValueUUID{Val: id}, nil
+	case [16]byte:
+		return qvalue.QValueUUID{Val: uuid.UUID(v)}, nil
 	case uuid.UUID:
 		return qvalue.QValueUUID{Val: v}, nil
 	default:
@@ -267,6 +269,12 @@ func parseUUIDArray(value interface{}) (qvalue.QValue, error) {
 			uuids = append(uuids, id)
 		}
 		return qvalue.QValueArrayUUID{Val: uuids}, nil
+	case [][16]byte:
+		uuids := make([]uuid.UUID, 0, len(v))
+		for _, v := range v {
+			uuids = append(uuids, uuid.UUID(v))
+		}
+		return qvalue.QValueArrayUUID{Val: uuids}, nil
 	case []uuid.UUID:
 		return qvalue.QValueArrayUUID{Val: v}, nil
 	default:

flow/model/qvalue/equals.go

@@ -90,6 +90,8 @@ func Equals(qv QValue, other QValue) bool {
 		return compareTimeArrays(qvValue, otherValue)
 	case QValueArrayBoolean:
 		return compareBoolArrays(q.Val, otherValue)
+	case QValueArrayUUID:
+		return compareUuidArrays(q.Val, otherValue)
 	case QValueArrayString:
 		return compareArrayString(q.Val, otherValue)
 	default:
@@ -321,6 +323,22 @@ func compareBoolArrays(value1, value2 interface{}) bool {
 	return true
 }
 
+func compareUuidArrays(value1, value2 interface{}) bool {
+	array1, ok1 := value1.([]uuid.UUID)
+	array2, ok2 := value2.([]uuid.UUID)
+
+	if !ok1 || !ok2 || len(array1) != len(array2) {
+		return false
+	}
+
+	for i := range array1 {
+		if array1[i] != array2[i] {
+			return false
+		}
+	}
+	return true
+}
+
 func compareArrayString(value1, value2 interface{}) bool {
 	array1, ok1 := value1.([]string)
 	array2, ok2 := value2.([]string)

flow/model/qvalue/kind.go

@@ -141,7 +141,7 @@ var QValueKindToClickHouseTypeMap = map[QValueKind]string{
 	QValueKindArrayTimestampTZ: "Array(DateTime64(6))",
 	QValueKindArrayJSON:        "String",
 	QValueKindArrayJSONB:       "String",
-	QValueKindArrayUUID:        "Array(String)",
+	QValueKindArrayUUID:        "Array(UUID)",
 }
 
 func getClickHouseTypeForNumericColumn(ctx context.Context, env map[string]string, column *protos.FieldDescription) (string, error) {