我能够写入 SQL 表,如下所示。
%scala
// WRITE FROM CONFIG
val writeToSQL = Config(Map(
"url" -> url,
"databaseName" -> database,
"dbTable" -> "tableName",
"accessToken" -> accessToken,
"trustServerCertificate" -> "true",
"encrypt" -> "true",
"connectTimeout" -> "50",
"queryTimeout" -> "50"
))
df.write.mode(SaveMode.Append).sqlDB(writeConfig)
基本上我有 SQL 表和相应的 View 。每次我进行数据刷新(从databricks)时,我想删除并写入最新的记录或覆盖sql和 View 中的记录。
请告诉我这两个步骤是否可以通过databricks笔记本实现?
最佳答案
您可以在 sql 单元中使用类似以下内容的内容:
%sql
drop table database_1.tableName_1
关于sql - 从databricks中删除或覆盖sql表和 View ,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/64595565/