scala如何连接和操作mysql/oracle/sqlserver数据库

时间:2021-08-13 13:15:24
  • 【问题场景】

  在scala中怎么连接mysql/oracle/sqlserver数据库,进行数据库操作。
【解决思路】

  了解scala的强大特性我们会发现java中的东西,scala基本可以拿来使用,那么要解决scala连接数据库的问题,自然是可以通过java最经典的JDBC方式来解决,当然了现在针对scala操作数据库的,已经有涌现出了很多封装框架如ScalaQuery、O/R Broker 、Squeryl 、Slick(typesafe公司开发)、ScalaActiveRecord (基于Squeryl之上)、circumflex-orm以及activate-framework(Scala版的Hibernate)等。

 当然了在一些简单业务场景下,使用JDBC来得直接简单,例如使用scala以jdbc的方式连接mysql(同样对于oracle/sqlserver数据库也是类似)的主要代码实现如下:

import java.sql.{Connection, DriverManager, ResultSet};
// DB Connect Info
val conn_str = "jdbc:mysql://localhost:3306/DBNAME?user=rscala_db&password=rscala_db"

// Load the driver
classOf[com.mysql.jdbc.Driver]

// Setup the connection
val conn = DriverManager.getConnection(conn_str)
try {
// Configure to be Read Only
val statement = conn.createStatement(ResultSet.TYPE_FORWARD_ONLY, ResultSet.CONCUR_READ_ONLY)

// Execute Query
val rs = statement.executeQuery("SELECT username,pwd FROM rscala_users LIMIT 5")

// Iterate Over ResultSet
while (rs.next) {
println(rs.getString("username"))
}
}
finally {
conn.close
}

本文转自:rscala.com版权所有,本文scala如何连接和操作mysql/oracle/sqlserver数据库转载请注明出处:http://rscala.com/index.php/385.html

该文章归档分类于 scala实践大数据基础