Clean up.

artie-labs · Dec 12, 2024 · 4deafce · 4deafce
1 parent bc49b78
commit 4deafce
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 3 deletions.
diff --git a/clients/mssql/dialect/dialect.go b/clients/mssql/dialect/dialect.go
@@ -46,7 +46,7 @@ func (MSSQLDialect) IsTableDoesNotExistErr(err error) bool {
 func (md MSSQLDialect) BuildIsNotToastValueExpression(tableAlias constants.TableAlias, column columns.Column) string {
 	toastedValue := "%" + constants.ToastUnavailableValuePlaceholder + "%"
 	colName := sql.QuoteTableAliasColumn(tableAlias, column, md)
-	return fmt.Sprintf("COALESCE(%s NOT LIKE '%s', TRUE)", colName, toastedValue)
+	return fmt.Sprintf("COALESCE(%s, '') NOT LIKE '%s'", colName, toastedValue)
 }
 
 func (MSSQLDialect) BuildDedupeTableQuery(_ sql.TableIdentifier, _ []string) string {

diff --git 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)
 	}