Scala實戰—連線oracle及mysql資料庫
阿新 • • 發佈:2018-12-08
作者:WenWu_Both
出處:http://blog.csdn.net/wenwu_both/article/
版權:本文版權歸作者和CSDN部落格共有
轉載:歡迎轉載,但未經作者同意,必須保留此段宣告;必須在文章中給出原文連結;否則必究法律責任
Scala連線oracle資料庫是通過Java的JDBC的方式實現的,具體實現方式如下:
1.在工程目錄中新增oracle_jdbc的jar包
‘build_path’-‘configure build path…’-‘libraries’-‘add exteral JARs’,新增oracle安裝目錄中的ojdbc6.jar包。
2.相關程式碼
import java.sql.Connection
import java.sql.DriverManager
import scala.collection.mutable.ArrayBuffer
object get_oracle{
def main(args:Array[String]){
val url = "jdbc:oracle:thin:@xx.x.xx.xxx:port/database"
// 驅動名稱
val = driver = "oracle.jdbc.driver.OracleDriver"
// 使用者名稱
val username = "********"
// 密碼
val password = "********"
// 初始化資料連線
val connection:Connection = null
// 初始化查詢結果
val result = ArrayBuffer[String]()
try{
// 註冊Driver
Class.forName(driver)
println("開始嘗試連線資料庫" )
// 連線資料庫
connection = DriverManager.getConnection(url, username, password)
println("資料庫連線成功")
// 初始化查詢語句
val statement = connection.createStatement
// 執行查詢結果,並返回結果
val rs = statement.executeQuery("select t.* from test")
// 列印返回結果
var i = 1
while(rs.next){
val item = rs.getString("name")
result.append(item)
i = i + 1
}
println("查詢資料條數:" + result.length)
println("具體資料如下:"){
println(f"第${i + 1}條資料為:${result(i)}")
}
}
finally{
// connection.close
println("資料查詢成功")
}
}
}
連線MySQL資料庫與oracle資料庫類似,區別在於連結和驅動不一樣,載入相應的mysql驅動的jar包即可。
// 不同於Oracle的部分
val url = "jdbc:mysql://localhost:3306/sys?useSSL=True"
// useSSL=True主要是因為mysql在高版本中需要指明是否進行SSL連線
var driver = com.mysql.jdbc.Driver
mysql驅動下載地址: https://dev.mysql.com/downloads/connector/j/