99网
您的当前位置:首页sparkSQL 3.2.1查询远程Oracle

sparkSQL 3.2.1查询远程Oracle

来源:99网
val spark = SparkSession
.builder()
.appName("Oracle")
.master("local[*]")
.getOrCreate()

spark.read
.format("jdbc")
.option("url","jdbc:oracle:thin:@10.2.22.222:orcl")
.option("dbtable","TABLE_NAME")
.option("user","AAA")
.option("password","PWD")
.option("driver","orcle.jdbc.driver.OracleDriver")
.load()
.createOrReplaceTempView("TABLE_NAME")

spark.sql("SELECT * FROM TABLE_NAME ").show()


spark.stop()

因篇幅问题不能全部显示,请点此查看更多更全内容