sparksession访问oracle

要使用SparkSession访问Oracle数据库，需要先将Oracle JDBC驱动程序添加到Spark的classpath中。可以通过以下方式在Spark中添加Oracle JDBC驱动程序：

1. 将Oracle JDBC驱动程序（例如ojdbc8.jar）放在Spark的Jars目录中

2. 在Spark shell或应用程序中使用--jars选项指定Oracle JDBC驱动程序的路径，例如：

$ spark-shell --jars /path/to/ojdbc8.jar

3. 在Spark应用程序中，可以使用以下代码加载Oracle JDBC驱动程序：

Class.forName("oracle.jdbc.driver.OracleDriver")

加载完驱动程序后，可以使用SparkSession连接到Oracle数据库并读取数据。以下示例代码演示了如何使用SparkSession从Oracle数据库中读取数据：

import org.apache.spark.sql.SparkSession

val spark = SparkSession.builder()
  .appName("Read from Oracle")
  .config("spark.driver.extraClassPath", "/path/to/ojdbc8.jar")
  .getOrCreate()

val jdbcUrl = "jdbc:oracle:thin:@//localhost:1521/ORCLPDB1"
val jdbcUsername = "username"
val jdbcPassword = "password"

val df = spark.read
  .format("jdbc")
  .option("url", jdbcUrl)
  .option("dbtable", "TABLE_NAME")
  .option("user", jdbcUsername)
  .option("password", jdbcPassword)
  .load()

df.show()

在代码中，通过SparkSession.builder()创建了一个SparkSession实例，并指定了应用程序名。然后，通过.config()方法将Oracle JDBC驱动程序的路径添加到Spark的classpath中。接下来，定义了连接Oracle数据库的JDBC URL、用户名和密码。最后，使用SparkSession的read()方法从Oracle数据库中读取数据，并使用show()方法显示读取的数据。