From d51b538d456ebe6524fd2ff66b049ca5737db3a1 Mon Sep 17 00:00:00 2001 From: Robin Tang Date: Thu, 3 Oct 2024 16:00:52 -0700 Subject: [PATCH] Remove comment. --- clients/databricks/dialect/dialect.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/clients/databricks/dialect/dialect.go b/clients/databricks/dialect/dialect.go index c3f2bf42f..c43c6d534 100644 --- a/clients/databricks/dialect/dialect.go +++ b/clients/databricks/dialect/dialect.go @@ -62,7 +62,7 @@ func (d DatabricksDialect) BuildDedupeQueries(tableID, stagingTableID sql.TableI orderByCols = append(orderByCols, fmt.Sprintf("%s ASC", pk)) } - tempViewQuery := fmt.Sprintf(` + stagingTableQuery := fmt.Sprintf(` CREATE TABLE %s AS SELECT * FROM %s @@ -79,9 +79,9 @@ func (d DatabricksDialect) BuildDedupeQueries(tableID, stagingTableID sql.TableI stagingTableID.FullyQualifiedName(), strings.Join(whereClauses, " AND "), ) - // Insert deduplicated rows back into the original table + insertQuery := fmt.Sprintf("INSERT INTO %s SELECT * FROM %s", tableID.FullyQualifiedName(), stagingTableID.FullyQualifiedName()) - return []string{tempViewQuery, deleteQuery, insertQuery} + return []string{stagingTableQuery, deleteQuery, insertQuery} } func (d DatabricksDialect) BuildMergeQueries(