Py4JJavaError：使用 PySpark 从 SQL Server 加载数据库

问题描述

我正在尝试使用 PySpark 连接和读取两个 sql Server 数据库，每个数据库具有不同的服务器名称和端口号。我尝试了很多解决方案，但两个数据库都出现相同的错误。

我使用不同主机名、数据库名、端口号、用户名和密码的两台服务器的代码：

jdbcHostname = "XXXXXXXXX"
jdbcDatabase = "XXXX"
jdbcPort = "XXXX"
username = "XXXXXX"
password = "XXXXXXXXXX"
jdbcUrl = "jdbc:sqlserver://{0}:{1};database={2}".format(jdbcHostname,jdbcPort,jdbcDatabase)
connection_details = {
   "user" : username,"password" : password,"driver" : "com.microsoft.sqlserver.jdbc.sqlServerDriver"
 }
query = """(Select * from [jdbcDatabase].[schema].[tablename])"""
df = spark.read.jdbc(url=jdbcUrl,table=query,properties=connection_details)

我得到的错误如下：

它要求我验证连接属性。

请注意，我能够使用脚本所在的同一设备通过 Microsoft sql Server Management Studio 成功运行 sql 查询。

有什么帮助吗？

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）