scala 操作数据库的方法
更新时间：2019年06月19日 10:33:30 作者：张乐1993
这篇文章主要介绍了scala 操作数据库的方法，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
1、定义数据库连接
package com.web.dataSource
import com.alibaba.druid.pool.DruidDataSource
object MySqlDataSource {
val driver = "com.mysql.jdbc.Driver"
val url = "jdbc:mysql://127.0.0.1:3306"
val username = "root"
val password = "root"
val connectionPool = new DruidDataSource()
connectionPool.setUsername(username)
connectionPool.setPassword(password)
connectionPool.setDriverClassName(driver)
connectionPool.setUrl(url)
connectionPool.setValidationQuery("select 1")
connectionPool.setInitialSize(15)
connectionPool.setMinIdle(10)
connectionPool.setMaxActive(100)
connectionPool.setRemoveAbandoned(true)
connectionPool.setRemoveAbandonedTimeoutMillis(180000)
connectionPool.setMaxWait(5000)
connectionPool.setTestOnBorrow(false)
connectionPool.setTestOnReturn(false)
}
2、执行查询
def getOptions(uid:Int) ={
val connection = MySqlDataSource.connectionPool.getConnection
var sql =
s""" select username,password,sex
|from user
|where uid = ?
""".stripMargin
var stmt = connection.prepareStatement(sql)
stmt.setInt(1, uid)
var resultSet = stmt.executeQuery()
var resultListMap = List[Map[String,String]]()
//获取结果
while(resultSet.next()){
resultListMap = resultListMap :+ Map(
"username"->resultSet.getString("username"),
"password"->resultSet.getString("password"),
"sex"->resultSet.getInt("sex"),
)
}
//关闭连接
stmt.close()
connection .close()
//返回结果
resultListMap
}
3、插入数据
object UpdateLocation {
def main(args: Array[String]): Unit = {
val conf = new SparkConf().setAppName("UpdateLocation").setMaster("local[2]")
val sc = new SparkContext(conf)
var conn: Connection = null
var ps: PreparedStatement = null
try {
val sql = "INSERT INTO location_info(location,accesse_date,counts) VALUES (?,?,?)"
conn = DriverManager.getConnection("jdbc:mysql://192.168.126.31:3306/sparkdatabase?useUnicode=true&characterEncoding=utf-8", "root", "Zhm@818919")
ps = conn.prepareStatement(sql)
ps.setString(1, "深圳")
ps.setString(2, "2018-7-2")
ps.setInt(3, 122)
ps.execute()
} catch {
case e: Exception => println("myException")
} finally {
if (conn != null) {
conn.close()
}
if (ps != null) {
ps.close()
}
}
sc.stop()
}
}
4、删除操作
object DeleteLocation {
def main(args: Array[String]): Unit = {
val conf = new SparkConf().setAppName("UpdateLocation").setMaster("local[2]")
val sc = new SparkContext(conf)
var conn: Connection = null
var ps: PreparedStatement = null
try {
val sql = "delete from location_info where location = ?"
conn = DriverManager.getConnection("jdbc:mysql://192.168.126.31:3306/sparkdatabase?useUnicode=true&characterEncoding=utf-8", "root", "Zhm@818919")
ps = conn.prepareStatement(sql)
ps.setString(1, "深圳")
ps.execute()
} catch {
case e: Exception => println("myException")
} finally {
if (conn != null) {
conn.close()
}
if (ps != null) {
ps.close()
}
}
sc.stop()
}
}
5、更新操作
object InsertLocation {
def main(args: Array[String]): Unit = {
val conf = new SparkConf().setAppName("UpdateLocation").setMaster("local[2]")
val sc = new SparkContext(conf)
var conn: Connection = null
var ps: PreparedStatement = null
try {
val sql = "update location_info set location=? where id = ?";
conn = DriverManager.getConnection("jdbc:mysql://192.168.126.31:3306/sparkdatabase?useUnicode=true&characterEncoding=utf-8", "root", "Zhm@818919")
ps = conn.prepareStatement(sql)
ps.setString(1, "深圳")
ps.setInt(2,26)
ps.execute()
} catch {
case e: Exception => println("myException")
} finally {
if (conn != null) {
conn.close()
}
if (ps != null) {
ps.close()
}
}
sc.stop()
}
}
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持脚本之家。
相关文章
这篇文章主要介绍了idea out目录与target目录的区别详解，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧2021-02-02
这篇文章主要给大家介绍了关于Java中Calendar日期类用法详细介绍的相关资料,Calendar类是 Java 中用于处理日期和时间的抽象类,它提供了一种独立于特定日历系统的方式来处理日期和时间,需要的朋友可以参考下2023-12-12
这篇文章主要介绍了Java中的@PreAuthorize注解源码解析,@PreAuthorize注解会在方法执行前进行权限验证,支持Spring EL表达式,它是基于方法注解的权限解决方案,需要的朋友可以参考下2023-10-10
基于FeignException$InternalServerError的解决方案
这篇文章主要介绍了FeignException$InternalServerError的解决方案，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教2021-06-06
这篇文章主要介绍了微信公众号测试账号自定义菜单的实例代码,非常不错，具有参考借鉴价值，需要的朋友可以参考下2017-02-02
这篇文章主要为大家介绍了Netty学习之理解selector原理示例使用分析，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步，早日升职加薪<BR>2023-07-07
这篇文章主要介绍了Java获取文件ContentType案例，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧2020-08-08
这篇文章主要介绍了java读取JSON文件的多种实现方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教2024-06-06
这篇文章主要介绍了java中transient关键字分析,transient与类对象的序列化息息相关,序列化保存的是 类对象 状态,被transient关键字修饰的成员变量,在类的实例化对象的序列化处理过程中会被忽略,变量不会贯穿对象的序列化和反序列化,需要的朋友可以参考下2023-09-09
这篇文章主要为大家详细介绍了SpringBoot动态修改yml配置文件的方法，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下，希望能够给你带来帮助2022-03-03
最新评论