Databricks: Quote catalog and schema names in SQL statements (close #…

…1143)
snowplow · Dec 1, 2022 · 6fd6e71 · 6fd6e71
1 parent c283f9f
commit 6fd6e71
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...s-loader/src/main/scala/com/snowplowanalytics/snowplow/loader/databricks/Databricks.scala b/...s-loader/src/main/scala/com/snowplowanalytics/snowplow/loader/databricks/Databricks.scala
@@ -193,8 +193,8 @@ object Databricks {
             }
 
           private def qualify(tableName: String): String = tgt.catalog match {
-            case Some(catalog) => s"${catalog}.${tgt.schema}.$tableName"
-            case None => s"${tgt.schema}.$tableName"
+            case Some(catalog) => s"`${catalog}`.`${tgt.schema}`.$tableName"
+            case None => s"`${tgt.schema}`.$tableName"
           }
         }
         Right(result)