首页
学习
活动
专区
圈层
工具
发布
社区首页 >专栏 >scala通过JDBC进行数据库操作

scala通过JDBC进行数据库操作

作者头像
栗筝i
发布2022-12-01 21:17:25
发布2022-12-01 21:17:25
9310
举报
文章被收录于专栏:迁移内容迁移内容

scala通过JDBC方式操作mysql (需要加载 mysql-connector-java 驱动)

maven依赖:

代码语言:javascript
复制
 <dependency>
      <groupId>mysql</groupId>
      <artifactId>mysql-connector-java</artifactId>
      <version>5.1.45</version>
    </dependency>

一、scala连接mysql(jdbc方式)

代码语言:javascript
复制
import java.sql.{ Connection, DriverManager }

object JBJDBC extends App {
  // 访问本地MySQL服务器,通过3306端口访问mysql数据库
  val url = "jdbc:mysql://localhost:3306/datassets_4300?useUnicode=true&characterEncoding=utf-8&useSSL=false"
  //驱动名称
  val driver = "com.mysql.jdbc.Driver"
  //用户名
  val username = "root"
  //密码
  val password = "123456"
  //初始化数据连接
  var connection: Connection = _
  try {
    //注册Driver
    Class.forName(driver)
    //得到连接
    connection = DriverManager.getConnection(url, username, password)
    val statement = connection.createStatement
    }
  }
}

前提:在我本地有一个Persion表,包括id和name两个字段

二、查询操作

通过connection.createStatement进行数据的查询操作

代码语言:javascript
复制
val statement = connection.createStatement
    //执行查询语句,并返回结果
    val rs = statement.executeQuery("SELECT id,name FROM persons")
    //打印返回结果
    while (rs.next) {
      val id = rs.getString("id")
      val name = rs.getString("name")
		//      println(name+"\t"+num)
      println("id = %s ,name = %s".format(id, name))
    }
    println("查询数据完成!")

三、增删改

代码语言:javascript
复制
val statement = connection.createStatement
    //执行查询语句,并返回结果
    val rs = statement.executeUpdate("SQL语句")
本文参与 腾讯云自媒体同步曝光计划,分享自作者个人站点/博客。
原始发表:2022-11-09,如有侵权请联系 cloudcommunity@tencent.com 删除
目录
  • 一、scala连接mysql(jdbc方式)
  • 二、查询操作
  • 三、增删改
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档