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。

相关文章

Linux使用fdisk进行磁盘的相关操作

Linux使用fdisk进行磁盘的相关操作

《Linux使用fdisk进行磁盘的相关操作》fdisk命令是Linux中用于管理磁盘分区的强大文本实用程序,这篇文章主要为大家详细介绍了如何使用fdisk进行磁盘的相关操作,需要的可以了解下... 目录简介基本语法示例用法列出所有分区查看指定磁盘的区分管理指定的磁盘进入交互式模式创建一个新的分区删除一个存
阅读更多...
Golang操作DuckDB实战案例分享

Golang操作DuckDB实战案例分享

《Golang操作DuckDB实战案例分享》DuckDB是一个嵌入式SQL数据库引擎,它与众所周知的SQLite非常相似,但它是为olap风格的工作负载设计的,DuckDB支持各种数据类型和SQL特性... 目录DuckDB的主要优点环境准备初始化表和数据查询单行或多行错误处理和事务完整代码最后总结Duck
阅读更多...
MySQL中时区参数time_zone解读

MySQL中时区参数time_zone解读

《MySQL中时区参数time_zone解读》MySQL时区参数time_zone用于控制系统函数和字段的DEFAULTCURRENT_TIMESTAMP属性,修改时区可能会影响timestamp类型... 目录前言1.时区参数影响2.如何设置3.字段类型选择总结前言mysql 时区参数 time_zon
阅读更多...
Python MySQL如何通过Binlog获取变更记录恢复数据

Python MySQL如何通过Binlog获取变更记录恢复数据

《PythonMySQL如何通过Binlog获取变更记录恢复数据》本文介绍了如何使用Python和pymysqlreplication库通过MySQL的二进制日志（Binlog）获取数据库的变更记录... 目录python mysql通过Binlog获取变更记录恢复数据1.安装pymysqlreplicat
阅读更多...
使用SQL语言查询多个Excel表格的操作方法

使用SQL语言查询多个Excel表格的操作方法

《使用SQL语言查询多个Excel表格的操作方法》本文介绍了如何使用SQL语言查询多个Excel表格,通过将所有Excel表格放入一个.xlsx文件中,并使用pandas和pandasql库进行读取和... 目录如何用SQL语言查询多个Excel表格如何使用sql查询excel内容1. 简介2. 实现思路3
阅读更多...
C# 读写ini文件操作实现

C# 读写ini文件操作实现

《C#读写ini文件操作实现》本文主要介绍了C#读写ini文件操作实现,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧... 目录一、INI文件结构二、读取INI文件中的数据在C#应用程序中，常将INI文件作为配置文件，用于存储应用程序的
阅读更多...
Python使用qrcode库实现生成二维码的操作指南

Python使用qrcode库实现生成二维码的操作指南

《Python使用qrcode库实现生成二维码的操作指南》二维码是一种广泛使用的二维条码,因其高效的数据存储能力和易于扫描的特点,广泛应用于支付、身份验证、营销推广等领域,Pythonqrcode库是... 目录一、安装 python qrcode 库二、基本使用方法1. 生成简单二维码2. 生成带 Log
阅读更多...
Java操作ElasticSearch的实例详解

Java操作ElasticSearch的实例详解

《Java操作ElasticSearch的实例详解》Elasticsearch是一个分布式的搜索和分析引擎,广泛用于全文搜索、日志分析等场景,本文将介绍如何在Java应用中使用Elastics... 目录简介环境准备1. 安装 Elasticsearch2. 添加依赖连接 Elasticsearch1. 创
阅读更多...
java Stream操作转换方法

java Stream操作转换方法

《javaStream操作转换方法》文章总结了Java8中流(Stream)API的多种常用方法,包括创建流、过滤、遍历、分组、排序、去重、查找、匹配、转换、归约、打印日志、最大最小值、统计、连接、... 目录流创建1、list 转 map2、filter（）过滤3、foreach遍历4、groupingB
阅读更多...
Java操作PDF文件实现签订电子合同详细教程

Java操作PDF文件实现签订电子合同详细教程

《Java操作PDF文件实现签订电子合同详细教程》：本文主要介绍如何在PDF中加入电子签章与电子签名的过程,包括编写Word文件、生成PDF、为PDF格式做表单、为表单赋值、生成文档以及上传到OB... 目录前言：先看效果：1.编写word文件1.2然后生成PDF格式进行保存1.3我这里是将文件保存到本地后
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2