Update.

artie-labs · Oct 3, 2024 · 759db4d · 759db4d
1 parent 3d831f7
commit 759db4d
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 2 deletions.
diff --git a/clients/databricks/dialect/dialect.go b/clients/databricks/dialect/dialect.go
@@ -38,7 +38,11 @@ func (DatabricksDialect) BuildAlterColumnQuery(tableID sql.TableIdentifier, colu
 }
 
 func (DatabricksDialect) BuildIsNotToastValueExpression(tableAlias constants.TableAlias, column columns.Column) string {
-	panic("not implemented")
+	colName := sql.QuoteTableAliasColumn(tableAlias, column, sd)
+	if column.KindDetails == typing.Struct {
+		return fmt.Sprintf("COALESCE(%s != {'key': '%s'}, true)", colName, constants.ToastUnavailableValuePlaceholder)
+	}
+	return fmt.Sprintf("COALESCE(%s != '%s', true)", colName, constants.ToastUnavailableValuePlaceholder)
 }
 
 func (DatabricksDialect) BuildDedupeTableQuery(tableID sql.TableIdentifier, primaryKeys []string) string {

diff --git a/lib/config/constants/constants.go b/lib/config/constants/constants.go
@@ -77,7 +77,6 @@ const (
 	Snowflake  DestinationKind = "snowflake"
 )
 
-// TODO: Add Databricks to this list once it's ready
 var ValidDestinations = []DestinationKind{
 	BigQuery,
 	Databricks,