diff --git a/clients/bigquery/dialect/dialect.go b/clients/bigquery/dialect/dialect.go index a6a316ff..d528a3c8 100644 --- a/clients/bigquery/dialect/dialect.go +++ b/clients/bigquery/dialect/dialect.go @@ -43,12 +43,7 @@ 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+"%") - default: - return fmt.Sprintf("COALESCE(%s != '%s', true)", colName, constants.ToastUnavailableValuePlaceholder) - } + return fmt.Sprintf(`TO_JSON_STRING(%s) NOT LIKE '%s'`, colName, "%"+constants.ToastUnavailableValuePlaceholder+"%") } func (bd BigQueryDialect) BuildDedupeTableQuery(tableID sql.TableIdentifier, primaryKeys []string) string {