Merge branch 'master' into refactor-storage-writer

clients/shared/default_value.go

@@ -80,8 +80,7 @@ func BackfillColumn(dwh destination.DataWarehouse, column columns.Column, tableI
 		slog.String("table", tableID.FullyQualifiedName()),
 	)
 
-	_, err = dwh.Exec(query)
-	if err != nil {
+	if _, err = dwh.Exec(query); err != nil {
 		return fmt.Errorf("failed to backfill, err: %w, query: %v", err, query)
 	}
 

lib/debezium/converters/string.go

@@ -0,0 +1,18 @@
+package converters
+
+import "github.com/artie-labs/transfer/lib/typing"
+
+type StringPassthrough struct{}
+
+func (StringPassthrough) Convert(value any) (any, error) {
+	castedValue, err := typing.AssertType[string](value)
+	if err != nil {
+		return nil, err
+	}
+
+	return castedValue, nil
+}
+
+func (StringPassthrough) ToKindDetails() typing.KindDetails {
+	return typing.String
+}

lib/debezium/converters/string_test.go

@@ -0,0 +1,21 @@
+package converters
+
+import (
+	"testing"
+
+	"github.com/stretchr/testify/assert"
+)
+
+func TestStringPassthrough_Convert(t *testing.T) {
+	{
+		// Non string
+		_, err := StringPassthrough{}.Convert(1)
+		assert.ErrorContains(t, err, "expected type string, got int")
+	}
+	{
+		// String
+		value, err := StringPassthrough{}.Convert("test")
+		assert.Nil(t, err)
+		assert.Equal(t, "test", value)
+	}
+}

lib/debezium/schema.go

@@ -82,6 +82,8 @@ func (f Field) GetScaleAndPrecision() (int32, *int32, error) {
 
 func (f Field) ToValueConverter() converters.ValueConverter {
 	switch f.DebeziumType {
+	case UUID:
+		return converters.StringPassthrough{}
 	case DateTimeWithTimezone:
 		return converters.DateTimeWithTimezone{}
 	case TimeWithTimezone:

lib/debezium/schema_test.go

@@ -271,6 +271,11 @@ func TestField_ToKindDetails(t *testing.T) {
 			},
 			expectedKindDetails: typing.Struct,
 		},
+		{
+			name:                "UUID",
+			field:               Field{DebeziumType: UUID, Type: String},
+			expectedKindDetails: typing.String,
+		},
 	}
 
 	for _, tc := range tcs {