作者: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/

Logo

更多推荐