Spark:連接oracle


代碼:

val file = "/root/dir/jhzf.properties"
val tableName = "spark_timetime"
import java.util.Properties
val properties = new Properties()
import java.io.FileInputStream
properties.load(new FileInputStream(file))
properties.setProperty("dbtable", tableName)
import scala.collection.JavaConversions.propertiesAsScalaMap
// import org.apache.spark.sql.SQLContext
// val sqlContext = new SQLContext(sc)
// val df = sqlContext.read.options(properties).format("jdbc").load()
val df = spark.read.options(properties).format("jdbc").load()

執行:

spark-submit --master local[*] \
--class com.xjb.task.Test \
--jars ojdbc6.jar \
orcltest_2.11-1.0.jar \
args

## cat jhzf.properties
driver=oracle.jdbc.driver.OracleDriver
url=jdbc:oracle:thin:@10.18.2.3:1521:orcl
user=****
password=****
dbtable=table_name #或sql子語句如: (select * from table) a


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM