import org.apache.spark.sql.SparkSession
object SparkToOracle {
def main(args: Array[String]): Unit = {
val spark = SparkSession
.builder()
.master("local[2]")
.appName("OracleTest")
.getOrCreate()
val sqltext="(select * from TABLE_NAME) t"
val jdbcdf = spark
.read
.format("jdbc")
.option("url", "jdbc:oracle:thin:@IP:1521:SERVICE_NAME ")
.option("dbtable",sqltext)
.option("user","username")
.option("password","password").load()
print(jdbcdf)
jdbcdf.createOrReplaceTempView("ls")
spark.sql("select * from ls").show()
spark.stop()
}
}