我有Spark 3.1.2和Scala 2.12.8。我想連接到oracle資料庫并讀取一個表,然后顯示它,使用以下代碼:
import org.apache.spark.sql.SparkSession
object readTable extends App{
val spark = SparkSession.
.建設者
.master("local[*]")
.appName("Spark SQL basic example")
.config("spark.some.config.option", "some-value")
.getOrCreate()
val jdbcDF = spark.read
.format("jdbc")
.option("url", "jdbc:oracle:thin:@x.x.x.x:1521:orcldb")
.option("dbtable"/span>, "orcl.brnc_grp"/span>)
.option("user", "orcl")
.option("password", "xxxxxx")
.加載()
jdbcDF.show()
}
在執行緒 "main "中出現例外 java.sql.SQLException。沒有合適的驅動程式
你能指導我如何解決這個問題嗎?
如果有任何幫助,我將非常感激。
uj5u.com熱心網友回復:
從這里下載oracle JDBC jar,并將這個JAR放在$SPARK_HOME/jars檔案夾中。
轉載請註明出處,本文鏈接:https://www.uj5u.com/ruanti/309113.html
標籤:
上一篇:根據地圖的內容更新資料框的行數
