【MySQL】使用 JDBC 连接数据库

JDBC 连接数据库

文章目录
  • 前言
  • 1. 认识 JDBC
    • 1.1 概念
    • 1.2 好处
  • 2. 使用 JDBC
    • 2.1 安装数据驱动包
    • 2.2 把 jar 包导入到项目中
    • 2.3 代码编写
    • 2.4 测试结果
  • 3. 代码优化
  • 4. 源码展示
  • 结语

前言

在 MySQL 系列中,我们介绍了很多内容,包括但不限于建库建表,增删查改等等,但是这些操作都是直接在本机上的 MySQL 进行的,而在实际的开发过程中,我们很少会这样做,更多的是通过代码(C++、Java、Python……)来操作数据库的。今天我们就会简单介绍如何通过 Java 代码来操作数据库


1. 认识 JDBC

1.1 概念

JDBC(Java Database Connectivity)是一个 Java API,它提供了一种标准的方法,用于 Java 程序与各种数据库进行交互。简单来说,JDBC 是一个桥梁,使得 Java 应用程序能够执行 sql 语句,以查询、更新和管理数据库中的数据


1.2 好处

  1. 平台无关性:JDBC 使我们可以在任何支持 Java 的平台上运行的数据库访问代码,而无需关心底层数据库的类型
  2. 数据库无关性:JDBC 提供了统一的 API,使得我们可以使用相同的代码结构来访问不同类型的数据库,如 MySQL、Oracle、SQL Server 等
  3. 简化数据库访问:JDBC 简化了数据库访问的过程,我们不需要深入了解底层数据库的复杂性,就可以通过 JDBC 提供的接口轻松地执行数据库操作

2. 使用 JDBC

2.1 安装数据驱动包

所谓的数据驱动包,实际上就是包含了 JDBC 操作数据库的 API 的一个 jar 包,里面有很多的 .class 文件,我们可以在官网下载驱动包 (https://dev.mysql.com/downloads/)

也可以在 Maven 中央仓库下载(https://mvnrepository.com/),此处我们简单演示一下在 Maven 下载数据驱动包

  • 打开 Maven 网址,搜索栏输入“Mysql”,此时最上面会出现两个结果。因为博主使用的 MySQL 版本比较老,所以选择 “经典版”

    请添加图片描述

  • 点进去后就是各种版本的驱动包了。这里需要下载和你 MySQL 安装的版本一致才可,我的MySQL是 5.7 的,所以要选择 5.1 开头的,后面的小版本无所谓;如果你的 MySQL 是 8.x 版本的,那你就要选择 8 开头的驱动包了

    image-20241007201415044

  • 博主这里选择 5.1.49 这个版本,点进去后下载 jar

    请添加图片描述

  • 这样就下载好啦~

    image-20241007202832069


2.2 把 jar 包导入到项目中

  • 先新建一个 Java 项目,并在这个项目下右键建立一个目录,命名为 lib(注意不要带有中文/特殊字符)

    请添加图片描述

  • 接着找到我们下载好的 jar 包,直接复制然后粘贴到 lib 目录中(ctrl c 和 ctrl v 即可),点击 OK

    image-20241007202911979

  • 然后右键 lib 目录,点击 add as library,再点击 OK 就行了。此时 idea 就能自动分析出 jar 包里有什么内容了

    image-20241007203302880

    image-20241007203404120

  • 这样就大功告成啦

    image-20241007203514612


2.3 代码编写

1. 创建数据源:要连接数据库时,我们需要知道这个数据库的位置;我们可以通过 DataSource 对象来获取

        DataSource dataSource = new MysqlDataSource();((MysqlDataSource)dataSource).setURL("jdbc:mysql://127.0.0.1:3306/javatest?characterEncoding=utf8&useSSL=false"); // “Javatest”是数据库名((MysqlDataSource)dataSource).setUser("root");((MysqlDataSource)dataSource).setPassword("xxxxxxxxx"); // 根据你安装是设置的密码填入
  • DataSourse 是 Java 中的一个接口,不能直接创建对象,因此我们使用 MysqlDataSource 这个子类来创建对象
  • 接下来是 setURL( )、setUser( )、setPassWord( ),它们都是 MysqlDataSource 中的方法,分别服务器的 url(统一资源定位符)、服务器的账号、服务器的密码()
  • 此处我们还使用了向上转型和向下转型,目的是为了降低耦合。若之后我们使用的数据库不是 MySQL,那修改代码就十分方便

2. 和数据库服务器建立网络连接

Connection connection = dataSource.getConnection();
  • 要注意此处的导入的包是 import java.sql.Connection 这个,不要选错了
  • 此处的 Connection 对象,表示的就是一个数据库连接(抽象的客户端服务器连接)
  • 此处的异常可以使用 throw 直接抛出

3. 构造 SQL 语句

比如我们现在想要在表中插入一条信息,就可以使用字符串来表示

String sql = "insert into student values ('qiqi', 77)";

接着使用 PreparedStatement 来预编译这个 sql 语句

PreparedStatement statement = connection.prepareStatement(sql);
  • 我们写的 sql 语句就可以放在 statement 这个对象里面
  • 预编译指的是它可以在客户端发送 sql 语句前,先解析一下,从而降低服务器的工作压力

4. 执行 SQL 语句

我们需要把 sql 发送到服务器上进行执行,可以使用 statement 里的方法

  • 如果我们要执行的是增、删、改的操作,那就使用 executeUpdate 方法

    statement.executeUpdate();
    
  • 如果我们要执行的是操作,那就使用 executeQuery 方法

    statement.executeQuery();
    

5. 断开连接,释放资源

在进行类似的网络通信时,在使用完后一定要记得释放资源。我们上面创建了 connectionstatement 两个对象,它们都需要释放,我们按照创造顺序的相反来关闭(先 statement,后 connection

statement.close();
connection.close();

完整代码如下:

package jdbc;import com.mysql.jdbc.jdbc2.optional.MysqlDataSource;import javax.sql.DataSource;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.SQLException;
import java.util.Scanner;public class TestUpdate {public static void main(String[] args) throws SQLException {//1.创建数据源对象(基本是默认的)DataSource dataSource = new MysqlDataSource();((MysqlDataSource)dataSource).setURL("jdbc:mysql://127.0.0.1:3306/javatest?characterEncoding=utf8&useSSL=false");((MysqlDataSource)dataSource).setUser("root");((MysqlDataSource)dataSource).setPassword("xxxxxxxxx");//2.和数据库服务器建立网络连接(选择Connection java.sql包)Connection connection = dataSource.getConnection();//System.out.println(connection);//测试连接是否成功//3.构造sql语句(基于PreparedStatement预处理)String sql = "insert into student values ('qiqi', 77)";//写死的//4.把sql发送到服务器上进行执行//statement.executeQuery()查询//statement.executeUpdate()增删改int n = statement.executeUpdate();//影响的行数System.out.println(n);//5.释放上述资源(倒着释放)statement.close();connection.close();}
}

2.4 测试结果

image-20241007213728395

最终打印 1,即影响的行数,表示插入成功


3. 代码优化

String sql = "insert into student values ('qiqi', 77)";//写死的
  • 我们这里是把插入的 sql 给写死了,如果我们能够在控制台输入我们需要插入的信息,岂不美哉。因此得把代码修改一下

        //用户输入Scanner scanner = new Scanner(System.in);System.out.println("请输入姓名:");String name = scanner.nextLine();System.out.println("请输入分数:");int grade = scanner.nextInt();//修改sql语句String sql = "insert into a values ('"+ name +"',"+ grade +")";
    
  • 这时候就可以通过控制台输入信息了。但是此处还有点小瑕疵,它有可能会引起 sql 注入攻击,别人可以通过代码直接拼接构造 sql 语句导致 sql 语句被恶意篡改(有一篇 2012 年的新闻报道了 sql 注入事件,感兴趣的可以看一下( 网传技术流号牌遮挡能干掉交警数据库 警方辟谣)

  • 所以我们可以把 sql 语句再修改一下,使用占位符 “ ?”

    String sql = “insert into a values (?,?)”;//?为占位符

接着通过 statement 对象里面的 setInt() 和 setString() 方法来设置这两个字段,从而将这个 sql 语句构造完整,这样就能防止 sql 注入攻击啦

PreparedStatement statement = connection.prepareStatement(sql);
statement.setInt(1, id);
statement.setString(2, name);

补充:数据库的查找操作

上面我们提到了,如果我们要执行的是操作,那就得使用 executeQuery 方法

除此之外,返回的结果也不一样:

  • 如果是增、删、改操作的话,返回的就只是一个 int 类型的值,表示影响的行数,可以检验 sql 语句是否执行成功

  • 但是对于操作,它会返回一个结果集,也就是我们查询的结果,因此我们可以使用ResultSet 对象来进行接收,接着遍历里面的内容。最后也要记得关闭它哦

  • 其他的代码就和上面的插入是一样的

    package jdbc;

    import com.mysql.jdbc.jdbc2.optional.MysqlDataSource;

    import javax.sql.DataSource;
    import java.sql.Connection;
    import java.sql.PreparedStatement;
    import java.sql.ResultSet;
    import java.sql.SQLException;

    public class Testselect {
    public static void main(String[] args) throws SQLException {
    DataSource dataSource = new MysqlDataSource();
    ((MysqlDataSource)dataSource).setURL(“jdbc:mysql://127.0.0.1:3306/javatest?characterEncoding=utf8&useSSL=false”);
    ((MysqlDataSource)dataSource).setUser(“root”);
    ((MysqlDataSource)dataSource).setPassword(“xxxxxxxxx”);

        Connection connection = dataSource.getConnection();String sql = "select * from student";PreparedStatement statement = connection.prepareStatement(sql);//一个集合类,可以遍历得到ResultSet resultSet = statement.executeQuery();//遍历结果while (resultSet.next()) {System.out.println(resultSet.getString("name"));System.out.println(resultSet.getInt("grade"));}resultSet.close();statement.close();connection.close();
    }
    

    }

运行结果如下:

image-20241007215847008


4. 源码展示

插入操作

package jdbc;import com.mysql.jdbc.jdbc2.optional.MysqlDataSource;import javax.sql.DataSource;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.SQLException;
import java.util.Scanner;public class TestUpdate {public static void main(String[] args) throws SQLException {//0.用户输入Scanner scanner = new Scanner(System.in);System.out.println("请输入姓名:");String name = scanner.nextLine();System.out.println("请输入分数:");int grade = scanner.nextInt();//1.创建数据源对象(基本是默认的)DataSource dataSource = new MysqlDataSource();((MysqlDataSource)dataSource).setURL("jdbc:mysql://127.0.0.1:3306/javatest?characterEncoding=utf8&useSSL=false");((MysqlDataSource)dataSource).setUser("root");((MysqlDataSource)dataSource).setPassword("xxxxxxxxx");//2.和数据库服务器建立网络连接(选Connection java.sql包)Connection connection = dataSource.getConnection();//System.out.println(connection);//测试连接是否成功//3.构造sql语句(基于PreparedStatement预处理)//String sql = "insert into student values ('qiqi', 77)";//写死的//String sql = "insert into student values ('"+name+"',"+grade+")";//代码看起来乱,而且可能会被“sql注入攻击”---> ');drop database xxx;String sql = "insert into student values (?,?)";//?为占位符//String sql = "delete from a where name = ?";//删除也是一样PreparedStatement statement = connection.prepareStatement(sql); //预编译statement.setString(1,name); //1表示第一个问号statement.setInt(2,grade);//4.把sql发送到服务器上进行执行//executeQuery()查询//executeUpdate()增删改int n = statement.executeUpdate();//影响的行数System.out.println(n);//5.释放上述资源(倒着释放)statement.close();connection.close();}
}

查询操作

package jdbc;import com.mysql.jdbc.jdbc2.optional.MysqlDataSource;import javax.sql.DataSource;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;public class Testselect {public static void main(String[] args) throws SQLException {DataSource dataSource = new MysqlDataSource();((MysqlDataSource)dataSource).setURL("jdbc:mysql://127.0.0.1:3306/javatest?characterEncoding=utf8&useSSL=false");((MysqlDataSource)dataSource).setUser("root");((MysqlDataSource)dataSource).setPassword("xxxxxxxxx");Connection connection = dataSource.getConnection();String sql = "select * from student";PreparedStatement statement = connection.prepareStatement(sql);//一个集合类,可以遍历得到ResultSet resultSet = statement.executeQuery();//遍历结果while (resultSet.next()) {System.out.println(resultSet.getString("name"));System.out.println(resultSet.getInt("grade"));}resultSet.close();statement.close();connection.close();}
}

结语

今天我们介绍了如何使用 JDBC 连接数据库,通过代码来直接操作 MySQL 数据库,上面展示的操作方法还是比较粗糙的,而且随着技术的不断更新,我们也很少会直接使用 JDBC 了。但是理解上述的操作方法对我们来说肯定是有作用,在后续使用框架的时候,底层原理还是离不开这个操作思路的。接下来是博主的一些碎碎念 (●’’●)

一个月没写博客了,有点生疏,加上需要回顾前面的知识以及查阅资料,确实需要消耗更多的时间。不知道值不值得继续,但是总觉得学习完一个知识点后不总结篇博客就不得劲,自己写的东西到时候来回顾应该也更加得心应手吧。接下来我更加努力更新博客,加油 ( _)

希望大家能够喜欢本篇博客,有总结不到位的地方还请多多谅解。若有纰漏,希望大佬们能够在私信或评论区指正,博主会及时改正,共同进步

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.rhkb.cn/news/19526.html

如若内容造成侵权/违法违规/事实不符,请联系长河编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

matlab模拟风场的随机脉动风

1、内容简介 matlab137-模拟风场的随机脉动风 可以交流、咨询、答疑 2、内容说明 略 模拟风场的随机脉动风,并进行相关的统计分析和计算,包括风速谱、空间相关性、自谱、互谱、以及POD(Proper Orthogonal Decomposition)分解等…

API 接口自动化

HTTP协议 - 白月黑羽 HTTP协议简介 如果客户端是浏览器,如何在chrome浏览器中查看 请求和响应的HTTP消息?按f12-》network 清除当前信息 响应的消息体在Response里看 点preview,可以看响应的消息体展开的格式 HTTP请求消息 请求头 reques…

(四)Axure学习图文教程

Axure中文学习网: Axure中文网 – 交互原型设计软件Axure RP中文正版支持 – 北京口耳相传科技有限公司 一、界面介绍 工具栏:主要操作功能。 站点地图:类似大纲界面,方便理清原型框架及逻辑关系。 元件库:调用所需…

2025年 Java 面试八股文

第一章-Java基础篇 1. Java中的基本数据类型有哪些?⭐ Java中有8种基本数据类型(Primitive Types),分别是: byte:8位,-128 ~ 127short:16位,-32,768 ~ 32,767int&…

基于Docker-compose的禅道部署实践:自建MySQL与Redis集成及故障排查指南

基于Docker-compose的禅道部署实践:自建MySQL与Redis集成及故障排查指南 禅道镜像版本:easysoft/zentao:21.4 Redis版本:redis:6.2.0 Mysql版本:mysql:8.0.35 文章目录 **基于Docker-compose的禅道部署实践:自建MySQL与…

【Java八股文】01-Java基础面试篇

【Java八股文】01-Java基础面试篇 概念Java特点Java为什么跨平台JVM、JDK、JRE关系 面向对象什么是面向对象,什么是封装继承多态?多态体现的方面面向对象设计原则重载重写的区别抽象类和实体类区别Java抽象类和接口的区别抽象类可以被实例化吗 深拷贝浅拷…

基于Qt 和微信小程序的用户管理系统:WebSocket + SQLite 实现注册与登录

目录 一. 概要 二. 技术栈 三. 系统功能设计 3.1 功能模块 3.2 数据表设计 四. 具体实现 4.1 Qt 服务端 4.1.1 初始化 WebSocket 服务器 4.1.2 用户管理界面 4.2 微信小程序端 4.2.1 注册功能 4.2.2 登录功能 五. 运行效果 六. 源码下载 一. 概要 在物联网和智能设备…

【STM32】舵机SG90

1.舵机原理 舵机内部有一个电位器,当转轴随电机旋转,电位器的电压会发生改变,电压会带动转一定的角度,舵机中的控制板就会电位器输出的电压所代表的角度,与输入的PWM所代表的角度进行比较,从而得出一个旋转…

PostgreSQL:备库的延迟问题处理步骤

目录标题 1. 查看主备状态计算方式:实际情况:举个例子: 2. 查看历史状态3. 分析日志文件4. 查看数据库层面的复制状态5. 检查活动事务6. 检查系统资源7. 检查网络状况8. 检查复制槽状态9. 检查未提交的两阶段事务 要排查 PostgreSQL 备库的延…

【重构谷粒商城】06:Maven快速入门教程

重构谷粒商城06——Maven快速入门教程 前言:这个系列将使用最前沿的cursor作为辅助编程工具,来快速开发一些基础的编程项目。目的是为了在真实项目中,帮助初级程序员快速进阶,以最快的速度,效率,快速进阶到…

【Python】错误异常

个人主页:Guiat 归属专栏:Python 文章目录 1. 错误和异常的概念1.1 错误1.2 异常 2. 常见的内置异常类型2.1 ZeroDivisionError2.2 IndexError2.3 KeyError2.4 TypeError 3. 异常处理机制3.1 try-except 语句3.2 try-except-else 语句3.3 try-except-fin…

Win11 远程 连接 Ubuntu20.04(局域网)

Win11 远程 连接 Ubuntu20.04(局域网) 0. Ubuntu 开启共享1. Ubuntu系统中安装RDP服务器2.windows中连接使用方式1:远程桌面连接(winr: mstsc)方式2:mobaXterm 3 问题远程连接后出现黑屏 参考文献: 0. Ubuntu 开启共享 在ubunt设置中&#x…

visutal studio 2022使用qcustomplot基础教程

编译 下载,2.1.1版支持到Qt6.4 。 拷贝qcustomplot.h和qcustomplot.cpp到项目源目录(Qt project)。 在msvc中将它俩加入项目中。 使用Qt6.8,需要修改两处代码: L6779 # if QT_VERSION > QT_VERSION_CHECK(5, 2, …

ElasticSearch详解

声明 内容来源尚硅谷知识星球谷粒随享项目,部分概念性的内容,就使用对应文档填写了,若有侵权联系作者删除。 检索模块 技术栈:ElasticSearch ElasticSearch介绍 1.1 elasticsearch 简介 官网: https://www.elastic.co/ Ela…

250214-java类集框架

引言 类集框架本质上相当于是容器,容器装什么东西由程序员指定 1.单列集合 单列集合是list和set,list的实现类有ArrayList和LinkedList,前者是数组实现,后者是链表实现。list和set,前者有序、可重复,后者…

Vue3(3)

一.具体业务功能实现 (1)登录注册页面 [element-plus 表单 & 表单校验] 功能需求说明: 1.注册登录 静态结构 & 基本切换 2.注册功能 (校验 注册) 3.登录功能 (校验 登录 存token) import request from /utils/request// 注册接…

数据结构 day05

数据结构 day05 5. 队列5.3. 链式队列5.3.1. 特征5.3.2. 代码实现 6. 双向链表6.1. 特性6.2. 代码实现 5. 队列 5.3. 链式队列 5.3.1. 特征 逻辑结构:线性结构 存储结构:链式存储 操作:创建、入列、出列、判空、清空 5.3.2. 代码实现 头文…

Uniapp 短视频去水印解析工具开发实现

最近搞了一个有意思的小工具——短视频去水印解析器!这玩意儿可以把短视频中的水印给抹掉,还能提取视频、封面等资源。整个项目用了 Uniapp 开发,做完后体验了一下,发现还挺顺手。今天就来跟大家聊聊实现思路和代码细节~ 需求分析…

HTML【详解】input 标签

input 标签主要用于接收用户的输入,随 type 属性值的不同,变换其具体功能。 通用属性 属性属性值功能name字符串定义输入字段的名称,在表单提交时,服务器通过该名称来获取对应的值disabled布尔值禁用输入框,使其无法被…

什么是MVC?什么是SpringMVC?什么是三层架构?

文章目录 应用分层什么是MVC?什么是 SpringMVC?三层架构三层架构和MVC的关系 应用分层 在讲解什么是MVC之前,先来理解一下什么是应用分层。 应用分层是一种软件开发设计思想,将应用程序划分成N个层次,每个层次都分别负责自己…