Scala Spark SQL with IntelliJ,如何链接JDBC jar文件并运行Scala代码



>我最近将我的代码从python转移到scala,并使用包括Spark的scala环境创建了一个项目,我编写了一个简单的代码来读取SQL数据库表并将其添加为数据帧,并希望使用.show((打印前20条记录

dataframe_mysql = sc.read.format("jdbc").option("url", "jdbc:mysql://localhost:3306/new_schema").option("driver", "com.mysql.jdbc.Driver").option("dbtable", "testing").option("user", "root").option("password", "").load()

我无法运行代码并获取表记录,以前在 python 中,我曾经在终端上运行 python 时将 JDBC 驱动程序作为参数附加,所以我如何使用 intellij 作为我的 IDE 在 scala iam 中实现相同的内容。

如果使用 SBT,则可以将其导入到项目中:

"mysql" % "mysql-connector-java" % "5.1.46" % "provided"

最终,您还可以通过以下步骤手动包含它:

  1. 右键单击项目并打开模块设置

  2. 然后转到库并将其添加到 JAR 中。

最新更新