PySpark连接Oracle数据库报错求助（Spark 3.1.2版本）

以下是针对性的排查和解决步骤：

• 检查JDBC驱动版本兼容性
  Spark 3.1.2默认适配Java 8运行环境，而ojdbc11是为Java 11及以上版本设计的驱动。如果你的Spark环境使用Java 8，需替换为ojdbc8.jar，将其放入Spark的jars目录后，重启Spark服务或PySpark会话。可通过执行java -version命令确认当前Java版本。

• 修正JDBC驱动类名
  ojdbc11的官方驱动类已更新为oracle.jdbc.OracleDriver，而非旧版的oracle.jdbc.driver.OracleDriver。修改代码中的driver选项：

  .option("driver", "oracle.jdbc.OracleDriver")
  

• 验证JDBC URL格式
  Oracle JDBC URL的服务名格式需注意前缀：如果使用的是数据库服务名，正确格式应为jdbc:oracle:thin:@//10.0.1.1:1521/sbank（添加双斜杠）；如果是SID，格式为jdbc:oracle:thin:@10.0.1.1:1521:sbank（使用冒号分隔端口和SID）。请根据你的Oracle数据库配置调整URL。

• 确认数据库权限与连通性
  使用SQL*Plus或其他数据库客户端测试用户权限：

  sqlplus g/zxc@10.0.1.1:1521/sbank
  

  登录后执行select * from sa.a;，确认用户g有权限访问sa.a表，且数据库地址、端口、服务名/SID均正确。

• 确保驱动被Spark正确加载
  如果是使用PySpark交互式环境，可在启动时显式指定驱动路径，避免jars目录的驱动未被加载：

  pyspark --jars /usr/local/spark/jars/ojdbc11.jar
  

  若使用集群模式，需确保所有Worker节点的jars目录都放置了对应驱动，并重启集群服务。

内容的提问来源于stack exchange，提问作者Huy Nguyen Ngoc