Java Scala实现数据库增删查改操作详解
作者：你∈我 发布时间：2022-02-03 05:09:22
标签：Java,Scala,增删查改,数据库
添加jar包
这里的Scala不是maven工程所以要找到项目结构（快捷键：同时按住Ctrl+shift+Alt+s）在模块里面添加添加MySQL的jar包，如果是Maven工程可以直接在pom里面直接加即可
实现操作数据库需要两个类，一个用于测试的Demo，一个用于实现增删查改的Util方法
在MysqlDemo在这里需要用到伴生类和伴生对象，伴生类主要是实现连接数据库
class MysqlDemo {
// 连接数据库 底层原理还是jdbc
//驱动名称
var driver = "com.mysql.cj.jdbc.Driver"
// 访问MySQL服务器，通过3306端口访问mysql数据库
var url = "jdbc:mysql://192.168.152.184:3306/exam"
//用户名
var user = "root"
//密码
var password = "123456"
//辅助构造器
def this(driver: String, url: String, user: String, pwd: String) {
this()
this.driver = driver
this.url = url
this.user = user
this.password = pwd
}
}
伴生对象则主要是实现操作数据库 ，需要先实现apply方法，主函数里面创建对象调用apply方法，调用连接方法和释放资源
object MysqlDemo {
// 实现apply方法
def apply(): MysqlDemo = new MysqlDemo()
def apply(driver: String, url: String, user: String, pwd: String): MysqlDemo = new MysqlDemo(driver, url, user, pwd)
def main(args: Array[String]): Unit = {
//创建对象，调用apply方法
val demo = MysqlDemo()
//导入MySQLUtil包
import MysqlUtil._
//调用创建连接的方法
demo.conn()
// 调用释放资源方法
demo.close(connection)
/**操作数据库代码*/
}
Util则需要先初始化数据库连接，注册驱动，得到数据库连接，释放资源
import java.sql.{Connection, DriverManager, PreparedStatement, ResultSet}
object MysqlUtil {
implicit class MysqlOp(obj: MysqlDemo) {
//初始化数据连接
private var connection: Connection = _
def conn(): Connection = {
//注册driver
Class.forName(obj.driver)
//得到数据库连接
val connection: Connection = DriverManager.getConnection(obj.url, obj.user, obj.password)
connection
}
//释放资源
def close(conn: Connection): Unit = {
if (conn != null) {
conn.close()
}
}
}
准备工作已做完下面要实现对数据库的增删查改
添加数据
方法一
//Util代码
//添加数据方法一
def insertStudent: Int = {
val insertSqlStr = "insert into student(name, age, gender, telephone, email, classid)" +
"values ('周七', 6, '男', '13888888888', '346497@qq.com', 2)"
val i: Int = conn().createStatement.executeUpdate(insertSqlStr)
i
}
//Demo测试代码
//添加数据方法一
val i: Int = demo.insertStudent
if (i == 1) {
println("添加成功")
} else if (i == 0) {
println("添加失败")
}
方法二
//Util代码
//添加数据方法二
def insertStudent(name: String, age: Int, gender: String, telephone: String, email: String, classid: Int): Int = {
val insertSqlStr = "insert into student(id,name, age, gender, telephone, email, classid)" +
"values (null,?,?,?,?,?,?)"
val preStmt: PreparedStatement = conn().prepareStatement(insertSqlStr)
preStmt.setString(1, name)
preStmt.setInt(2, age)
preStmt.setString(3, gender)
preStmt.setString(4, telephone)
preStmt.setString(5, email)
preStmt.setInt(6, classid)
val i: Int = preStmt.executeUpdate()
i
}
//Demo测试代码
//添加数据方法二
val i: Int = demo.insertStudent("aaa", 18, "男", "12345678910", "34649756@qq.com", 1)
if (i == 1) {
println("添加成功")
} else if (i == 0) {
println("添加失败")
}
删除数据
//Util代码
def deleteStudent(id: Int): Int = {
val deleteSql = "delete from student where id= ?"
val preStmt: PreparedStatement = conn().prepareStatement(deleteSql)
preStmt.setInt(1, id)
val i: Int = preStmt.executeUpdate()
i
}
//Demo测试代码
val i: Int = demo.deleteStudent(21)
if (i == 1) {
println("删除成功")
} else if (i == 0) {
println("删除失败")
}
查询数据
//Util代码
def selectStudent: Unit = {
val selectSql = "select id,name, age, gender, telephone, email, classid from student"
val rs: ResultSet = conn().createStatement().executeQuery(selectSql)
println("学号\t姓名\t年龄\t性别\t手机号\t邮箱\t班级编号")
while (rs.next()) {
val id: Int = rs.getInt("id")
val name: String = rs.getString("name")
val age: Int = rs.getInt("age")
val gender: String = rs.getString("gender")
val telephone: String = rs.getString("telephone")
val email: String = rs.getString("email")
val classid: String = rs.getString("classid")
println(id + "\t" + name + "\t" + age + "\t" + gender + "\t" + telephone + "\t" + email + "\t" + classid)
}
}
//Demo测试代码
demo.selectStudent
修改数据
//Util代码
def updateStudent(id: Int, name: String, age: Int, gender: String, telephone: String, email: String, classid: Int): Int = {
val updateSql = "update student set name=?," + "age=?, " + "gender=?," +
"telephone=?," + "email=?, " + "classid=? where id=?"
val preStmt: PreparedStatement = conn().prepareStatement(updateSql)
preStmt.setString(1, name)
preStmt.setInt(2, age)
preStmt.setString(3, gender)
preStmt.setString(4, telephone)
preStmt.setString(5, email)
preStmt.setInt(6, classid)
preStmt.setInt(7, id)
val i: Int = preStmt.executeUpdate()
i
}
//Demo测试代码
val i: Int = demo.updateStudent(22, "test", 25, "女", "123456789", "369852@qq.com", 2)
if (i == 1) {
println("修改成功")
} else if (i == 0) {
println("修改失败")
}
完整代码
MysqlUtil代码
import java.sql.{Connection, DriverManager, PreparedStatement, ResultSet}
object MysqlUtil {
implicit class MysqlOp(obj: MysqlDemo) {
//初始化数据连接
private var connection: Connection = _
def conn(): Connection = {
//注册driver
Class.forName(obj.driver)
//得到数据库连接
val connection: Connection = DriverManager.getConnection(obj.url, obj.user, obj.password)
connection
}
//释放资源
def close(conn: Connection): Unit = {
if (conn != null) {
conn.close()
}
}
//添加数据方法一
def insertStudent: Int = {
val insertSqlStr = "insert into student(name, age, gender, telephone, email, classid)" +
"values ('bbb', 6, '男', '13852277346', '3464975236@qq.com', 2)"
val i: Int = conn().createStatement.executeUpdate(insertSqlStr)
i
}
//添加数据方法二
def insertStudent(name: String, age: Int, gender: String, telephone: String, email: String, classid: Int): Int = {
val insertSqlStr = "insert into student(id,name, age, gender, telephone, email, classid)" +
"values (null,?,?,?,?,?,?)"
val preStmt: PreparedStatement = conn().prepareStatement(insertSqlStr)
preStmt.setString(1, name)
preStmt.setInt(2, age)
preStmt.setString(3, gender)
preStmt.setString(4, telephone)
preStmt.setString(5, email)
preStmt.setInt(6, classid)
val i: Int = preStmt.executeUpdate()
i
}
//删除数据
def deleteStudent(id: Int): Int = {
val deleteSql = "delete from student where id= ?"
val preStmt: PreparedStatement = conn().prepareStatement(deleteSql)
preStmt.setInt(1, id)
val i: Int = preStmt.executeUpdate()
i
}
//修改数据
def updateStudent(id: Int, name: String, age: Int, gender: String, telephone: String, email: String, classid: Int): Int = {
val updateSql = "update student set name=?," + "age=?, " + "gender=?," +
"telephone=?," + "email=?, " + "classid=? where id=?"
val preStmt: PreparedStatement = conn().prepareStatement(updateSql)
preStmt.setString(1, name)
preStmt.setInt(2, age)
preStmt.setString(3, gender)
preStmt.setString(4, telephone)
preStmt.setString(5, email)
preStmt.setInt(6, classid)
preStmt.setInt(7, id)
val i: Int = preStmt.executeUpdate()
i
}
//查询数据
def selectStudent: Unit = {
val selectSql = "select id,name, age, gender, telephone, email, classid from student"
val rs: ResultSet = conn().createStatement().executeQuery(selectSql)
println("学号\t姓名\t年龄\t性别\t手机号\t邮箱\t班级编号")
while (rs.next()) {
val id: Int = rs.getInt("id")
val name: String = rs.getString("name")
val age: Int = rs.getInt("age")
val gender: String = rs.getString("gender")
val telephone: String = rs.getString("telephone")
val email: String = rs.getString("email")
val classid: String = rs.getString("classid")
println(id + "\t" + name + "\t" + age + "\t" + gender + "\t" + telephone + "\t" + email + "\t" + classid)
}
}
}
}
MysqlDemo代码
import java.sql.Connection
class MysqlDemo {
// 连接数据库 底层原理还是jdbc
//驱动名称
var driver = "com.mysql.cj.jdbc.Driver"
// 访问MySQL服务器，通过3306端口访问mysql数据库
var url = "jdbc:mysql://192.168.152.184:3306/exam"
//用户名
var user = "root"
//密码
var password = "123456"
//辅助构造器
def this(driver: String, url: String, user: String, pwd: String) {
this()
this.driver = driver
this.url = url
this.user = user
this.password = pwd
}
}
object MysqlDemo {
// 实现apply方法
def apply(): MysqlDemo = new MysqlDemo()
def apply(driver: String, url: String, user: String, pwd: String): MysqlDemo = new MysqlDemo(driver, url, user, pwd)
def main(args: Array[String]): Unit = {
//创建对象，调用apply方法
val demo = MysqlDemo()
//导入MySQLUtil包
import MysqlUtil._
//调用创建连接的方法
val connection: Connection = demo.conn()
// 调用释放资源方法
demo.close(connection)
//添加数据方法一
val i: Int = demo.insertStudent
if (i == 1) {
println("添加成功")
} else if (i == 0) {
println("添加失败")
}
//添加数据方法二
val i: Int = demo.insertStudent("aaa", 18, "男", "12345678910", "34649756@qq.com", 1)
if (i == 1) {
println("添加成功")
} else if (i == 0) {
println("添加失败")
}
//查询数据
demo.selectStudent
// 修改数据
val i: Int = demo.updateStudent(22, "test", 25, "女", "123456789", "369852@qq.com", 2)
if (i == 1) {
println("修改成功")
} else if (i == 0) {
println("修改失败")
}
//删除数据
val i: Int = demo.deleteStudent(21)
if (i == 1) {
println("删除成功")
} else if (i == 0) {
println("删除失败")
}
}
}
来源：https://blog.csdn.net/qq_57151931/article/details/129802346
0
投稿猜你喜欢
- 本文实例讲述了Java泛型类与泛型方法的定义。分享给大家供大家参考，具体如下：Java泛型类的定义一 点睛泛型类定义的语法如下：[访问修饰符
前言：sleep 方法和 wait 方法都是用来将线程进入休眠状态的，并且 sleep 和 wait 方法都可以响应 interrupt 中- web.xml中设置：<servlet> <servlet-name>DisplayChart</servle
- [LeetCode] 2. Add Two Numbers 两个数字相加You are given two non-empty&n
- 一、先看下项目结构CodeGenerator：生成器主类resources下的mapper.java.vm：一个模板类，用以在生成dao层时
- spring开启声明式事务导入依赖pom.xml<dependencies>
- 摘要：其实两种方法归结起来看还是一种，都是利用Thread的构造器进行创建，区别就是一种是无参的，一种是有参的。一、继承Thread线程类：
- 首先，这两者是完全不同的概念，绝对不能混为一谈。1.什么是Java内存模型？Java内存模型是Java语言在多线程并 * 况下对于共享变量读写
- 之前在Spring Boot启动过程（二）提到过createEmbeddedServletContainer创建了内嵌的Servlet容器，
- 前言JAVA缓存实现方案有很多，最基本的自己使用Map去构建缓存，或者使用memcached或Redis，但是上述两种缓存框架都要搭建服务器
- 本文实例讲述了Java构造代码块，静态代码块原理与用法。分享给大家供大家参考，具体如下：本文内容：局部代码块构造代码块静态代码块补充&nbs
- 需求描述：企业开发过程中，经常需要将一些静态文本数据放到Resources目录下，项目启动时或者程序运行
- 1、原理事务的概念想必大家都很清楚，其ACID特性在开发过程中占有重要的地位。同时在并发过程中会出现一些一致性问题，为了解决一致性问题，也出
- instanceof关键字的使用1. 语法格式x instanceof A：检验x是否为类A的对象，返回值为boolean类型，如果是，返回
- 前言最常用的对字符串操作的类有三个，分别是String,StringBuilder,StringBuffer，下面将会详细的说说这三个类..
- substring(参数)是java截取字符串的一个方法。它有两种传参的方式：第一种：public String substring(int
- 基本概念：类加载的过程大致分为三个阶段1、加载阶段：本阶段主要把class的二进制代码加载进入JVM，并且进行常量池（类名，方法名，字段名）
- 1：同步调用：一种阻塞式调用，调用方要等待对方执行完毕才返回，它是一种单向调用 2：回调：一种双向调用模式，也就是说，被调用方在接口被调用时
- 前言很多时候，当你以为掌握了事实真相的时间，如果你能再深入一点，你可能会发现另外一些真相。比如面向切面编程的最佳编程实践是AOP，AOP的主
- 1. 插入排序步骤：1.从第一个元素开始，该元素可以认为已经被排序2.取下一个元素tem，从已排序的元素序列从后往前扫描3.如果该元素大于t
