手写JDBC:简单的连接MySQL数据库进行“增删改查”(CURD)

本文主要是介绍手写JDBC:简单的连接MySQL数据库进行“增删改查”(CURD),希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

大家都会用框架MyBtis,现在来回到我们最原始学习连接MySQL数据库的时候,对数据库里的表数据进行最简单的“增删改查”。

总体分为几个步骤:

1.加载驱动

2.拿到连接

3.编写SQL语句

4.预编译SQL

5.执行SQL

6.拿到结果集

7.处理结果集

8.资源释放

首先,去到Maven仓库找到MySQL的包:快捷链接https://mvnrepository.com/artifact/mysql/mysql-connector-java/8.0.28

复制里面的坐标:

   <dependency><groupId>mysql</groupId><artifactId>mysql-connector-java</artifactId><version>8.0.28</version></dependency>

再来一个测试的包,方便我们后续进行测试:

坐标在这里

<dependency><groupId>junit</groupId><artifactId>junit</artifactId><version>4.11</version><scope>test</scope></dependency>

把这两个坐标导入Pom文件,这样,环境就算搭建完了。

其次是打开MySQL数据库。。。我的是8.0版本,各位看版本选择合适的坐标进行导包!!!

创建实体InfoStudent:

package Entity;
public class InfoStudent {private String idCode;private String name;private String gender;public InfoStudent(String idCode, String name, String gender) {this.idCode = idCode;this.name = name;this.gender = gender;}public InfoStudent() {}public String getIdCode() {return idCode;}public void setIdCode(String idCode) {this.idCode = idCode;}public String getName() {return name;}public void setName(String name) {this.name = name;}public String getGender() {return gender;}public void setGender(String gender) {this.gender = gender;}@Overridepublic String toString() {return "InfoStudent{" +"身份证号:='" + idCode + '\'' +", 姓名:='" + name + '\'' +", 性别:='" + gender + '\'' +'}';}
}

创建DAO(data access object)接口:写上”增删改查“的四个方法

public interface InfoGetDao {//加载驱动时:抛出“类不存在”的异常和连接数据库时:的“SQL”的异常//selectInfoStudent query(String  name) throws ClassNotFoundException,SQLException;//insertint insert(InfoStudent info) throws ClassNotFoundException,SQLException;//deleteint delete(String id_code)throws ClassNotFoundException,SQLException;//updateint update(InfoStudent info)throws ClassNotFoundException,SQLException;
}

创建DAO的实现类:继承方法,写上调用Dao功能后返回

package Dao.Impl;import Dao.InfoGetDao;
import Entity.InfoStudent;
import java.sql.*;
public class InfoGetDaoImpl implements InfoGetDao {@Overridepublic InfoStudent query(String name) throws ClassNotFoundException, SQLException {String url = "jdbc:mysql://localhost:3306/info";String uName = "root";String pwd = "123456";//1.加载驱动Class.forName("com.mysql.cj.jdbc.Driver");//2.拿链接Connection conn = DriverManager.getConnection(url, uName, pwd);//3.sqlString sql = "select * from infoelec where name ='" + name + "'";//4.预编译PreparedStatement pr = conn.prepareStatement(sql);//5.拿到结果集ResultSet set = pr.executeQuery();boolean next = set.next();//6.处理结果集if (next) {String id_code = set.getString("id_code");String gender = set.getString("gender");InfoStudent info = new InfoStudent();info.setName(name);info.setIdCode(id_code);info.setGender(gender);return info;}pr.close();conn.close();return null;}@Overridepublic int insert(InfoStudent info) throws ClassNotFoundException, SQLException {String url = "jdbc:mysql://localhost:3306/info";String uName = "root";String pwd = "123456";//1.加载驱动Class.forName("com.mysql.cj.jdbc.Driver");//2.拿到链接Connection conn = DriverManager.getConnection(url, uName, pwd);//3.sql//String sql = "insert into infoelec(id_code,name,gender) values" + " ('" + info.getIdCode() + "'," + "'" + info.getName() + "'," + "'" + info.getGender() + "')";String sql="insert into infoelec(id_code,name,gender) values (?,?,?)";//4.预编译sqlPreparedStatement pr = conn.prepareStatement(sql);//5.填充占位符pr.setString(1,info.getIdCode());pr.setString(2,info.getName());pr.setString(3,info.getGender());//6.执行SQLint i = pr.executeUpdate();//7.拿到结果集//8.处理结果集//9.关闭资源pr.close();conn.close();if (i>0){return i;}else {return 0;}}@Overridepublic int delete(String id_code) throws ClassNotFoundException, SQLException {String url="jdbc:mysql://localhost:3306/info";String uName="root";String pwd="123456";//1.加载驱动类Class.forName("com.mysql.cj.jdbc.Driver");//2.拿到链接Connection conn = DriverManager.getConnection(url, uName, pwd);//3.SQLString sql="delete from infoelec where id_code=(?)";//4.预编译SQLPreparedStatement pr = conn.prepareStatement(sql);//5.填充占位符pr.setString(1,id_code);//6.执行SQLint i = pr.executeUpdate();//7.拿到结果集//8.处理结果集//9.关闭资源pr.close();conn.close();if (i>0){return i;}else {return 0;}}@Overridepublic int update(InfoStudent info) throws ClassNotFoundException, SQLException {String url="jdbc:mysql://localhost:3306/info";String uName="root";String pwd="123456";Class.forName("com.mysql.cj.jdbc.Driver");Connection conn = DriverManager.getConnection(url, uName, pwd);String sql="update infoelec set name=(?),gender=(?) where id_code=(?)";PreparedStatement pr = conn.prepareStatement(sql);pr.setString(1,info.getName());pr.setString(2,info.getGender());pr.setString(3,info.getIdCode());int i = pr.executeUpdate();pr.close();conn.close();if (i>0){return i;}else {return 0;}}
}

MySQL数据库连接的链接讲解:

String url="jdbc:mysql://localhost:3306/info";

jdbc:mysql:// :协议标识 其钟mysql是MySQL服务器,如果是Oracle的数据库服务器,可改成Oracle;

localhost :本机IP地址的俗称,专业名称是127.0.0.1;

:3306 :数据库的端口号,MySQL服务器默认是3306的映射端口;

/info :/数据库名称;固定的格式:“/”+“数据库名称”;

接下来是服务(Service)层的接口:对应“增删改查”的方法名称:

接口

package Service;import Entity.InfoStudent;
import java.sql.SQLException;
public interface InfoGetService {InfoStudent getInfo(String name) throws SQLException, ClassNotFoundException;int add(InfoStudent info)throws SQLException,ClassNotFoundException;int remove(String id_code)throws ClassNotFoundException,SQLException;int getUpdate(InfoStudent info)throws ClassNotFoundException,SQLException;
}

 实现

package Service.Impl;import Dao.Impl.InfoGetDaoImpl;
import Dao.InfoGetDao;
import Entity.InfoStudent;import java.sql.SQLException;
public class InfoGetServiceImpl implements Service.InfoGetService {@Overridepublic InfoStudent getInfo(String name) throws SQLException, ClassNotFoundException {InfoGetDao dao = new InfoGetDaoImpl();return dao.query(name);}@Overridepublic int add(InfoStudent info) throws SQLException, ClassNotFoundException {InfoGetDao dao =new InfoGetDaoImpl();return dao.insert(info);}@Overridepublic int remove(String id_code) throws ClassNotFoundException, SQLException {InfoGetDao dao = new InfoGetDaoImpl();return dao.delete(id_code);}@Overridepublic int getUpdate(InfoStudent info) throws ClassNotFoundException, SQLException {InfoGetDao dao = new InfoGetDaoImpl();return dao.update(info);}
}

开始测试:

前置条件:你数据库里有对应的数据库和与实体类对应的表乃至数据库表的字段类型要与你在Java中“增删改”传入的类型一直,及String对varchar/char或Integer对应int/Integer等等。如果类型不一致;MySQL会抛出Doule的异常错误提示:即“Data truncation: Truncated incorrect DOUBLE value”;

import Entity.InfoStudent;
import Service.Impl.InfoGetServiceImpl;
import Service.InfoGetService;
import java.sql.SQLException;/*** @version 1.0.0* @Author Jam·Li* @ Date 2024/8/24 16:57* @ Annotation:*/
public class Test {@org.junit.Testpublic void test() throws SQLException, ClassNotFoundException {//创建实体对象,承载数据InfoStudent info = new InfoStudent("520", "小美", "女");InfoStudent info2 = new InfoStudent("521", "小明", "男");//创建Service层对象InfoGetService service =new InfoGetServiceImpl();//调用service接口的增删改查;//增加int add = service.add(info);int add2 = service.add(info2);System.out.println(add);System.out.println(add2);//删除int remove = service.remove("521");System.out.println(remove);//修改InfoStudent infoChange = new InfoStudent("520", "小莉", "女");int change = service.getUpdate(infoChange);System.out.println(change);//查询InfoStudent selectInfo = service.getInfo("小莉");System.out.println(selectInfo);}}

测试结果:

1
1
1
1
InfoStudent{身份证号:='520', 姓名:='小莉', 性别:='女'}

数据库里的最终数据:

优化与改进 :

潜在问题:

性能瓶颈:频繁的数据库连接创建与销毁开销大。

安全性风险:明文密码在URL中传递。

优化建议:

使用连接池:如HikariCP、c3p0,减少连接创建成本。

环境变量或配置文件:敏感信息不在代码中硬编码。

拓展知识:

如果本文对你有帮助,请帮忙点赞收藏加作者关注一波;后续的作者会不断推出更精彩质量更高的文章哟!谢谢啦! 

这篇关于手写JDBC:简单的连接MySQL数据库进行“增删改查”(CURD)的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/1107774

相关文章

SpringBoot实现数据库读写分离的3种方法小结

《SpringBoot实现数据库读写分离的3种方法小结》为了提高系统的读写性能和可用性,读写分离是一种经典的数据库架构模式,在SpringBoot应用中,有多种方式可以实现数据库读写分离,本文将介绍三... 目录一、数据库读写分离概述二、方案一:基于AbstractRoutingDataSource实现动态

使用Jackson进行JSON生成与解析的新手指南

《使用Jackson进行JSON生成与解析的新手指南》这篇文章主要为大家详细介绍了如何使用Jackson进行JSON生成与解析处理,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一下... 目录1. 核心依赖2. 基础用法2.1 对象转 jsON(序列化)2.2 JSON 转对象(反序列化)3.

C#使用SQLite进行大数据量高效处理的代码示例

《C#使用SQLite进行大数据量高效处理的代码示例》在软件开发中,高效处理大数据量是一个常见且具有挑战性的任务,SQLite因其零配置、嵌入式、跨平台的特性,成为许多开发者的首选数据库,本文将深入探... 目录前言准备工作数据实体核心技术批量插入:从乌龟到猎豹的蜕变分页查询:加载百万数据异步处理:拒绝界面

MySQL双主搭建+keepalived高可用的实现

《MySQL双主搭建+keepalived高可用的实现》本文主要介绍了MySQL双主搭建+keepalived高可用的实现,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,... 目录一、测试环境准备二、主从搭建1.创建复制用户2.创建复制关系3.开启复制,确认复制是否成功4.同

Python使用自带的base64库进行base64编码和解码

《Python使用自带的base64库进行base64编码和解码》在Python中,处理数据的编码和解码是数据传输和存储中非常普遍的需求,其中,Base64是一种常用的编码方案,本文我将详细介绍如何使... 目录引言使用python的base64库进行编码和解码编码函数解码函数Base64编码的应用场景注意

MyBatis 动态 SQL 优化之标签的实战与技巧(常见用法)

《MyBatis动态SQL优化之标签的实战与技巧(常见用法)》本文通过详细的示例和实际应用场景,介绍了如何有效利用这些标签来优化MyBatis配置,提升开发效率,确保SQL的高效执行和安全性,感... 目录动态SQL详解一、动态SQL的核心概念1.1 什么是动态SQL?1.2 动态SQL的优点1.3 动态S

Mysql表的简单操作(基本技能)

《Mysql表的简单操作(基本技能)》在数据库中,表的操作主要包括表的创建、查看、修改、删除等,了解如何操作这些表是数据库管理和开发的基本技能,本文给大家介绍Mysql表的简单操作,感兴趣的朋友一起看... 目录3.1 创建表 3.2 查看表结构3.3 修改表3.4 实践案例:修改表在数据库中,表的操作主要

C# WinForms存储过程操作数据库的实例讲解

《C#WinForms存储过程操作数据库的实例讲解》:本文主要介绍C#WinForms存储过程操作数据库的实例,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录一、存储过程基础二、C# 调用流程1. 数据库连接配置2. 执行存储过程(增删改)3. 查询数据三、事务处

Java进行文件格式校验的方案详解

《Java进行文件格式校验的方案详解》这篇文章主要为大家详细介绍了Java中进行文件格式校验的相关方案,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一下... 目录一、背景异常现象原因排查用户的无心之过二、解决方案Magandroidic Number判断主流检测库对比Tika的使用区分zip

Java使用Curator进行ZooKeeper操作的详细教程

《Java使用Curator进行ZooKeeper操作的详细教程》ApacheCurator是一个基于ZooKeeper的Java客户端库,它极大地简化了使用ZooKeeper的开发工作,在分布式系统... 目录1、简述2、核心功能2.1 CuratorFramework2.2 Recipes3、示例实践3