Mysql的JDBC连接和CRUD操作

2024-06-16 20:48
文章标签 mysql 操作 连接 jdbc database crud

本文主要是介绍Mysql的JDBC连接和CRUD操作，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

本文目的:演示用Eclipse编写Java项目实现数据库的连接和基本的增删改查操作

项目结构如下图所示：

这里写图片描述

数据库结构如下：

CREATE TABLE `stu` (`id` int(11) NOT NULL AUTO_INCREMENT,`name` varchar(20) COLLATE utf8_bin DEFAULT NULL,`age` int(3) DEFAULT NULL,`gradeid` int(11) DEFAULT NULL,PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=17 DEFAULT CHARSET=utf8 COLLATE=utf8_bin

这里写图片描述

database-info.properties配置文件如下：

driver=com.mysql.jdbc.Driver
#tcjt084 is your database's name
url=jdbc:mysql://localhost:3306/tcjt084
#root is your database username
user=root
#admin is your database password
password=admin

Student.java建实体类如下

package entity;//实体类
public class Stu {private int id;private String name;private int age;public Stu() {}public Stu(int id, String name, int age) {super();this.id = id;this.name = name;this.age = age;}public int getId() {return id;}public void setId(int id) {this.id = id;}public String getName() {return name;}public void setName(String name) {this.name = name;}public int getAge() {return age;}public void setAge(int age) {this.age = age;}@Overridepublic String toString() {return "Stu [id=" + id + ", name=" + name + ", age=" + age + "]";}}

ReadDBInfo.java工具类读取数据库信息如下：

package jdbc;import java.io.FileNotFoundException;
import java.io.FileReader;
import java.io.IOException;
import java.util.Properties;public class ReadDBInfo {// 单例模式对象声明 静态私有private static ReadDBInfo prop = null;// Properties对象Properties p = new Properties();// 私有构造方法，一定要是私有的，私有外部就不能直接new本类对象了，实现单例模式目的private ReadDBInfo() {}/*** 单例模式* @return 本类的对象*/public static ReadDBInfo getInstance() {if (prop == null) {prop = new ReadDBInfo();}return prop;}/*** @param key:关键字* @return String 根据key读取到的properties中的值*/public String getDBInfo(String key) {try {// Creates a new FileReader, //given the name of the file to read from.//创建一个新的FileReader，给定要读取的文件的名称。FileReader fr = new FileReader("src/database-info.properties");// Reads a property list (key and element pairs) from //the input character stream in a simple line-oriented format. //从输入字符流中读取一个属性列表(键和元素对)，以一个简单的行为导向的格式p.load(fr);// 根据properties 返回key的值/*Searches for the property with the specified key in this property list.If the key is not found in this property list, the default property list, and its defaults, recursively, are then checked. The method returns null if the property is not found.*///在属性列表中搜索具有指定键的属性。//如果在此属性列表中没有找到该键，则会对默认属性列表及其默认值进行递归检查。//如果没有找到该属性，该方法将返回null。return p.getProperty(key);} catch (FileNotFoundException e) {e.printStackTrace();} catch (IOException e) {e.printStackTrace();}return null;}
}

BaseDao.java如下：

package dao;import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;import jdbc.ReadDBInfo;public class BaseDao {ReadDBInfo prop = ReadDBInfo.getInstance();// 获取driver url user password值,从properties文件中String driver = prop.getDBInfo("driver");String url = prop.getDBInfo("url");String user = prop.getDBInfo("user");String password = prop.getDBInfo("password");// 数据库连接对象Connection conn = null;// sql语句处理对象PreparedStatement ps = null;// 结果集对象ResultSet rs = null;/*** 与数据库建立起连接* @return void*/public void getConn() {try {//加载驱动//使用给定的字符串名称返回与类或接口关联的类对象。//调用此方法等价于：类。//forName(className,true,currentLoader)：//当前加载器表示当前类的定义类装入器。Class.forName(driver);//获取与数据库的连接//尝试建立与给定数据库URL的连接。//DriverManager试图从注册的JDBC驱动程序中选择适当的驱动程序。//注意:如果用户或密码属性也被指定为url的一部分，//那么它将被定义为哪个值优先。//为了获得最大的可移植性，应用程序应该只指定一次属性。conn = DriverManager.getConnection(url, user, password);} catch (ClassNotFoundException e) {e.printStackTrace();} catch (SQLException e) {e.printStackTrace();}}/*** 关闭rs,ps,conn* @return void*/public void closeAll() {if (rs != null) {try {rs.close();} catch (SQLException e) {e.printStackTrace();}}if (ps != null) {try {ps.close();} catch (SQLException e) {e.printStackTrace();}}if (conn != null) {try {conn.close();} catch (SQLException e) {e.printStackTrace();}}}/*** 执行sql语句获取查找到的结果集* @param objs* obj数组 用来存放sql中?的值* @param sql* sql语句* @return ResultSet 返回结果集*/public ResultSet baseSelect(Object[] objs, String sql) {getConn();/* * 创建一个PreparedStatement对象，用于向数据库发送参数化的SQL语句。* 具有或不带参数的SQL语句可以预编译并存储在PreparedStatement对象中。* 然后可以使用此对象多次有效地执行此语句。*/ps = conn.prepareStatement(sql);for (int i = 0; i < objs.length; i++) {/** 使用给定对象设置指定参数的值。* JDBC规范指定了从Java对象类型到SQL类型的标准映射。* 在发送到数据库之前，给定的参数将转换为相应的SQL类型。*/ps.setObject(i + 1, objs[i]);}/** 在这个PreparedStatement对象中执行SQL查询，* 并返回由查询生成的ResultSet对象。* 返回类型：包含查询生成的数据的ResultSet对象;没有空*/rs = ps.executeQuery();return rs;} catch (SQLException e) {e.printStackTrace();}return null;}/*** 执行sql语句对数据库中的数据进行操作，增删改* @param objs* obj数组 用来存放sql中?的值* @param sql* sql语句* @return int 有多少条数据被修改*/public int baseUpdate(Object[] objs, String sql) {getConn();try {ps = conn.prepareStatement(sql);for (int i = 0; i < objs.length; i++) {ps.setObject(i + 1, objs[i]);}/** 在这个PreparedStatement对象中执行SQL语句，* 它必须是一个SQL数据操作语言(DML)语句，如插入、更新或删除;* 或者一个没有返回任何内容的SQL语句，比如DDL语句。*/int lines = ps.executeUpdate();return lines;} catch (SQLException e) {e.printStackTrace();}return 0;}
}

StuDao接口如下：

package dao;import java.util.List;import entity.Stu;public interface StuDao {List<Stu> getAll();Stu getStuById(int id);int getCount();boolean update(Stu s);boolean delete(int id);boolean add(Stu s);
}

StuDaoImpl实现StuDao接口：

package dao;import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;import entity.Stu;public class StuDaoImpl extends BaseDao implements StuDao {/*** 查找所有信息* @return Stu类的List*/@Overridepublic List<Stu> getAll() {String sql = "select * from stu";ResultSet rs = baseSelect(new Object[] {}, sql);//构造一个初始容量为10的空列表。存放Student对象List<Stu> list = new ArrayList<>();try {//rs.next():/** 将光标从当前位置向前移动一行。* 一个ResultSet游标最初定位在第一行之前;* 第一个对方法的调用使第一行成为当前行;* 第二个调用使第二行变成当前行，以此类推。* 当对下一个方法的调用返回false时，光标将位于最后一行之后。*/while (rs.next()) {Stu s = new Stu();/** 在这个ResultSet对象的当前行中检索指定列的值，* 作为Java编程语言中的int类型。*/s.setId(rs.getInt("id"));s.setName(rs.getString("name"));s.setAge(rs.getInt("age"));list.add(s);}return list;} catch (SQLException e) {e.printStackTrace();}return null;}/*** 根据id查找Stu* @param id* @return Stu对象*/@Overridepublic Stu getStuById(int id) {String sql = "select * from stu where id=?";Object[] objs = new Object[] { id };ResultSet rs = baseSelect(objs, sql);Stu s = new Stu();try {while (rs.next()) {s.setId(rs.getInt("id"));s.setName(rs.getString("name"));s.setAge(rs.getInt("age"));}return s;} catch (SQLException e) {e.printStackTrace();}return null;}/*** 一共有多少条信息* @return int*/@Overridepublic int getCount() {String sql = "select count(*) from stu";ResultSet rs = baseSelect(new Object[] {}, sql);int count = 0;try {while (rs.next()) {count = rs.getInt(1);}return count;} catch (SQLException e) {e.printStackTrace();}return 0;}/*** 更新Stu信息* @param Stu s:Stu对象* @return boolean true 成功 false 失败*/@Overridepublic boolean update(Stu s) {String sql = "update stu set name=?,age=? where id=?";Object[] objs = new Object[] { s.getName(), s.getAge(), s.getId() };int lines = baseUpdate(objs, sql);if (lines > 0) {return true;}return false;}/*** 根据id删除信息* @param id:id * @return boolean true 成功 false 失败*/@Overridepublic boolean delete(int id) {String sql = "delete from stu where id=?";Object[] objs = new Object[] { id };int lines = baseUpdate(objs, sql);if (lines > 0) {return true;}return false;}/*** 添加Stu信息* @param s:要添加的对象* @return boolean true 成功 false 失败*/@Overridepublic boolean add(Stu s) {String sql = "insert into stu values(null,?,?)";Object[] objs = new Object[] { s.getName(), s.getAge() };int lines = baseUpdate(objs, sql);if (lines > 0) {return true;}return false;}
}

Test类 测试如下：

package test;import java.util.List;
import java.util.Scanner;import org.junit.Before;
import org.junit.Test;import dao.StuDao;
import dao.StuDaoImpl;
import entity.Stu;public class Tests {private StuDao dao;@Beforepublic void init() {dao = new StuDaoImpl();}// 查所有@Testpublic void testGetAll() {List<Stu> list = dao.getAll();for (Stu s : list) {System.out.println(s);}}// 查记录数@Testpublic void testGetCounts() {System.out.println(dao.getCount());}// 根据id查找@Testpublic void testGetStuById() {Scanner input = new Scanner(System.in);System.out.println("请输入要查询的id:");int id = input.nextInt();Stu s = dao.getStuById(id);if (s == null) {System.out.println("未查询到结果！");} else {System.out.println(s);}input.close();}// 新增学生信息@Testpublic void testAdd() {Scanner input = new Scanner(System.in);System.out.println("请输入姓名:");String name = input.next();System.out.println("请输入年龄:");String ageStr = input.next();int age = Integer.parseInt(ageStr);System.out.println(dao.add(new Stu(0, name, age)));input.close();}// 删除学生信息@Testpublic void testDel() {Scanner input = new Scanner(System.in);System.out.println("请输入要删除的id:");int id = input.nextInt();System.out.println(dao.delete(id));input.close();}// 修改学生信息@Testpublic void testUpd() {Scanner input = new Scanner(System.in);System.out.println("请输入ID:");int id = input.nextInt();System.out.println("请输入姓名:");String name = input.next();System.out.println("请输入年龄:");String ageStr = input.next();int age = Integer.parseInt(ageStr);System.out.println(dao.update(new Stu(id, name, age)));input.close();}
}

测试结果：查所有getAll
这里写图片描述

测试结果：查条数getCounts
这里写图片描述

测试结果：根据id查找getById
这里写图片描述

增删改就不贴出来了都是可行的~

这篇关于Mysql的JDBC连接和CRUD操作的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/1067515。

相关文章

Python正则表达式匹配和替换的操作指南

Python正则表达式匹配和替换的操作指南

《Python正则表达式匹配和替换的操作指南》正则表达式是处理文本的强大工具,Python通过re模块提供了完整的正则表达式功能,本文将通过代码示例详细介绍Python中的正则匹配和替换操作,需要的朋... 目录基础语法导入re模块基本元字符常用匹配方法1. re.match() - 从字符串开头匹配2.
阅读更多...
MySQL的JDBC编程详解

MySQL的JDBC编程详解

《MySQL的JDBC编程详解》：本文主要介绍MySQL的JDBC编程,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录前言一、前置知识1. 引入依赖2. 认识 url二、JDBC 操作流程1. JDBC 的写操作2. JDBC 的读操作总结前言本文介绍了mysq
阅读更多...
java.sql.SQLTransientConnectionException连接超时异常原因及解决方案

java.sql.SQLTransientConnectionException连接超时异常原因及解决方案

《java.sql.SQLTransientConnectionException连接超时异常原因及解决方案》：本文主要介绍java.sql.SQLTransientConnectionExcep... 目录一、引言二、异常信息分析三、可能的原因3.1 连接池配置不合理3.2 数据库负载过高3.3 连接泄漏
阅读更多...
Linux下MySQL数据库定时备份脚本与Crontab配置教学

Linux下MySQL数据库定时备份脚本与Crontab配置教学

《Linux下MySQL数据库定时备份脚本与Crontab配置教学》在生产环境中,数据库是核心资产之一,定期备份数据库可以有效防止意外数据丢失,本文将分享一份MySQL定时备份脚本,并讲解如何通过cr... 目录备份脚本详解脚本功能说明授权与可执行权限使用 Crontab 定时执行编辑 Crontab添加定
阅读更多...
Java实现在Word文档中添加文本水印和图片水印的操作指南

Java实现在Word文档中添加文本水印和图片水印的操作指南

《Java实现在Word文档中添加文本水印和图片水印的操作指南》在当今数字时代,文档的自动化处理与安全防护变得尤为重要,无论是为了保护版权、推广品牌,还是为了在文档中加入特定的标识,为Word文档添加... 目录引言Spire.Doc for Java：高效Word文档处理的利器代码实战：使用Java为Wo
阅读更多...
MySQL中On duplicate key update的实现示例

MySQL中On duplicate key update的实现示例

《MySQL中Onduplicatekeyupdate的实现示例》ONDUPLICATEKEYUPDATE是一种MySQL的语法,它在插入新数据时,如果遇到唯一键冲突,则会执行更新操作,而不是抛... 目录1/ ON DUPLICATE KEY UPDATE的简介2/ ON DUPLICATE KEY UP
阅读更多...
MySQL分库分表的实践示例

MySQL分库分表的实践示例

《MySQL分库分表的实践示例》MySQL分库分表适用于数据量大或并发压力高的场景,核心技术包括水平/垂直分片和分库,需应对分布式事务、跨库查询等挑战,通过中间件和解决方案实现,最佳实践为合理策略、备... 目录一、分库分表的触发条件1.1 数据量阈值1.2 并发压力二、分库分表的核心技术模块2.1 水平分
阅读更多...
Python与MySQL实现数据库实时同步的详细步骤

Python与MySQL实现数据库实时同步的详细步骤

《Python与MySQL实现数据库实时同步的详细步骤》在日常开发中,数据同步是一项常见的需求,本篇文章将使用Python和MySQL来实现数据库实时同步,我们将围绕数据变更捕获、数据处理和数据写入这... 目录前言摘要概述：数据同步方案1. 基本思路2. mysql Binlog 简介实现步骤与代码示例1
阅读更多...
sysmain服务可以禁用吗? 电脑sysmain服务关闭后的影响与操作指南

sysmain服务可以禁用吗? 电脑sysmain服务关闭后的影响与操作指南

《sysmain服务可以禁用吗?电脑sysmain服务关闭后的影响与操作指南》在Windows系统中，SysMain服务（原名Superfetch）作为一个旨在提升系统性能的关键组件，一直备受用户关... 在使用 Windows 系统时，有时候真有点像在「开盲盒」。全新安装系统后的「默认设置」，往往并不尽编
阅读更多...
Python自动化处理PDF文档的操作完整指南

Python自动化处理PDF文档的操作完整指南

《Python自动化处理PDF文档的操作完整指南》在办公自动化中,PDF文档处理是一项常见需求,本文将介绍如何使用Python实现PDF文档的自动化处理,感兴趣的小伙伴可以跟随小编一起学习一下... 目录使用pymupdf读写PDF文件基本概念安装pymupdf提取文本内容提取图像添加水印使用pdfplum
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2