Scala实战—连接oracle及mysql数据库
主要介绍在Scala中如何实现oracle及mysql的连接。
·
作者: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/
更多推荐
已为社区贡献4条内容
所有评论(0)