From 4ab48053d1d14e46a04b104a6c01da082dbfa0c9 Mon Sep 17 00:00:00 2001 From: Robin Tang Date: Thu, 12 Dec 2024 12:22:41 -0800 Subject: [PATCH] Clean up. --- clients/bigquery/dialect/dialect.go | 1 - clients/bigquery/storagewrite.go | 5 ----- clients/shared/merge.go | 2 -- 3 files changed, 8 deletions(-) diff --git a/clients/bigquery/dialect/dialect.go b/clients/bigquery/dialect/dialect.go index 2d1ae108..a6a316ff 100644 --- a/clients/bigquery/dialect/dialect.go +++ b/clients/bigquery/dialect/dialect.go @@ -43,7 +43,6 @@ func (BigQueryDialect) IsTableDoesNotExistErr(_ error) bool { func (bd BigQueryDialect) BuildIsNotToastValueExpression(tableAlias constants.TableAlias, column columns.Column) string { colName := sql.QuoteTableAliasColumn(tableAlias, column, bd) - switch column.KindDetails { case typing.Struct, typing.Array: return fmt.Sprintf(`TO_JSON_STRING(%s) NOT LIKE '%s'`, colName, "%"+constants.ToastUnavailableValuePlaceholder+"%") diff --git a/clients/bigquery/storagewrite.go b/clients/bigquery/storagewrite.go index e8e84b7c..6bbab9b9 100644 --- a/clients/bigquery/storagewrite.go +++ b/clients/bigquery/storagewrite.go @@ -244,11 +244,6 @@ func rowToMessage(row map[string]any, columns []columns.Column, messageDescripto return nil, err } - fmt.Println("Type of values", fmt.Sprintf("%T", values)) - for _, val := range values { - fmt.Println("value", val) - } - list := message.Mutable(field).List() for _, val := range values { list.Append(protoreflect.ValueOfString(val)) diff --git a/clients/shared/merge.go b/clients/shared/merge.go index 51392e31..743c7e31 100644 --- a/clients/shared/merge.go +++ b/clients/shared/merge.go @@ -151,8 +151,6 @@ func Merge(ctx context.Context, dwh destination.DataWarehouse, tableData *optimi return fmt.Errorf("failed to generate merge statements: %w", err) } - fmt.Println("mergeStatements", mergeStatements) - if err = destination.ExecStatements(dwh, mergeStatements); err != nil { return fmt.Errorf("failed to execute merge statements: %w", err) }