利用scala实现jdbc对mysql增删改查

发布时间：2020-12-16 18:44:07 所属栏目：安全来源：网络整理

导读：我使用的是idea进行实验的，首先要进行MySQL连接的驱动jar包加载，见如图操作： Scala编程实现与数据库连接并实现增删改查和Java没有很大区别，区别也在两者语言的差异我做的是对数据库表进行插入，并对数据进行查询最大年龄及年龄和基本思路：1.建立与MyS

我使用的是idea进行实验的，首先要进行MySQL连接的驱动jar包加载，见如图操作：

Scala编程实现与数据库连接并实现增删改查和Java没有很大区别，区别也在两者语言的差异

我做的是对数据库表进行插入，并对数据进行查询最大年龄及年龄和

基本思路：1.建立与MySQL的链接：

2.写对应的增删改查操作：

总的来说有之前Java的基础和数据库的基本语句使用基础，这部分内容就很容易了。

下面是我实现任务要求的代码：

package com.shiyan

import java.sql.{PreparedStatement,Connection}
import java.sql.{ Connection,DriverManager }

object Test5_3 extends App{

  // 访问本地MySQL服务器，通过3306端口访问mysql数据库
  val url = "jdbc:mysql://localhost:3306/sparktest?useUnicode=true&characterEncoding=utf-8&useSSL=false"
  //驱动名称
  val driver = "com.mysql.jdbc.Driver"
  //用户名
  val username = "root"
  //密码
  val password = "root"
  //初始化数据连接
  var connection: Connection = _
  try {
    //注册Driver
    Class.forName(driver)
    //得到连接
    connection = DriverManager.getConnection(url,username,password)
    val statement = connection.createStatement
    //执行查询语句，并返回结果
    val rs = statement.executeQuery("SELECT sum(age),max(age) FROM employee")
    //打印返回结果
   while (rs.next) {
      val sum = rs.getString("sum(age)")
      val max = rs.getString("max(age)")
           println(sum+"t"+max)
     // println("name = %s".format(name))
   }

    println("查询数据完成！")
    //    执行插入操作
    val rs2 = statement.executeUpdate("INSERT INTO employee (id,name,gender,age) VALUES (‘4‘,‘Tom‘,‘F‘,‘23‘)")
    println("插入数据完成")
  }catch {
    case e: Exception => e.printStackTrace
  }
  //关闭连接，释放资源
  connection.close

}

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!