时间戳

首页 > 解决方案 > 如何将 MS SQL 数据库与 Azure Databricks 连接并运行命令

sql-server - 如何将 MS SQL 数据库与 Azure Databricks 连接并运行命令

问题描述

我想通过 python spark 将 Azure MS SQL 数据库与 Azure Databricks 连接起来。如果我运行 Select * from...，我可以使用 pushdown_query 来做到这一点。但我需要运行ALTER DATABASE以扩大/缩小规模。

我必须改变这部分

spark.read.jdbc(url=jdbcUrl, table=pushdown_query, properties=connectionProperties)

否则我会在关键字“ALTER”附近收到此错误错误语法。

任何人都可以帮助我。非常感激。

jdbcHostname = "xxx.database.windows.net"
jdbcDatabase = "abc"
jdbcPort = 1433


jdbcUrl = "jdbc:sqlserver://{0}:{1};database={2}".format(jdbcHostname, jdbcPort, jdbcDatabase)
connectionProperties = {
  "user" :  "..............",
  "password" : "............",
  "driver" : "com.microsoft.sqlserver.jdbc.SQLServerDriver"
}

pushdown_query = "(ALTER DATABASE [DBNAME] MODIFY (SERVICE_OBJECTIVE = 'S0')) dual_down" 
df = spark.read.jdbc(url=jdbcUrl, table=pushdown_query, properties=connectionProperties)
display(df)

标签： sql-serverjdbcpysparkdatabricks

解决方案

推荐阅读