我使用的是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 }