from pyspark import SparkContext, SparkConf
from pyspark.sql import SQLContext
import numpy as np
import pandas as pd 
conf = SparkConf()
conf.setAppName("appname")
conf.set("spark.jars","E:\\ojdbc6.jar") #開(kāi)始沒(méi)有配置這個(gè)，一直報(bào)錯(cuò)。
conf.setMaster("local[1]")
sc = SparkContext(conf=conf)
sqlContext = SQLContext(sc)
empDF = spark.read \
    .format("jdbc") \
    .option("url", "jdbc:oracle:thin:@//hostname:portnumber/SID") \
    .option("dbtable", "hr.emp") \
    .option("user", "db_user_name") \
    .option("password", "password") \
    .option("driver", "oracle.jdbc.driver.OracleDriver") \
    .load()

后來(lái)設(shè)置conf.set("spark.jars","E:\ojdbc6.jar") 這句話時(shí)，一開(kāi)始用的E:/ojdbc.jar，然后報(bào)錯(cuò)，后來(lái)竟然把/改成\就行了，，，不知道這是怎么回事，是java的問(wèn)題還是spark的問(wèn)題，之前我用jupyter都是用/的，，大神指點(diǎn)。