MySQL-JDBC编程
文章目录
- MySQL-JDBC编程
- Java的数据库编程
- JDBC工作原理
- JDBC的使用
- 驱动包下载导入
- 代码编写
Java的数据库编程
JDBC,即Java Database Connectivity,java数据库连接。是一种用于执行SQL语句的Java API,它是
Java中的数据库连接规范。这个API由java.sql.*,javax.sql.*包中的一些类和接口组成,它为Java开发人员操作数据库提供了一个标准的API,可以为多种关系数据库提供统一访问.
通过Java代码操作MySQL数据库;
数据库编程,是需要数据库服务器,提供一些API(Application Programming Interface),应用程序编程接口~
JDBC工作原理
JDBC访问数据库层次结构:

JDBC与数据库关系:

JDBC的使用
驱动包下载导入
要想在程序中操作mysql就需要你先安装mysql的驱动包.
我们可以在中央仓库下载到驱动包:Maven Repository
-

-
因为我装的MySQL是5版本,所以对应驱动包也下载的5版本
要是你的MySQL版本是8系列,那么驱动包与之对应也是8版本

-
点击此处进行下载

-
下载完毕,我们在IDEA中导入我们下载的
jar,我们先创建一个项目,然后创建一个新目录,一般我们习惯命名lib,然后复制刚才下载的jar文件,导入即可~


-
最后我们将
lib这个目录标记为库,即完成操作

**注意!**再每次创建一个新工程的时候,我们都需要导入这个jar包~
代码编写
前戏做完🥵🫣,我们可以来开始编写代码噜~
-
先创建
DataSource-
创建
DataSource前我们要做的DataSource这个词,它描述“数据源头”,即数据库服务器所在的位置。javax.sql.DataSource;是属于jdbc的包~
而创建
DataSource有两种写法:- 写法一
DataSource dataSource = new MysqlDataSource(); ((MysqlDataSource) dataSource).setUrl();这种转型的写法的初心,是为了让
MysqlDataSource这个类名不要扩散到代码的其他地方,后续如果要修改数据库为别的数据库,代码改动比较 小.(mysql和我们程序之间的耦合比较低)最终目的就是为了能够进一步降低耦合
- 写法二
MysqlDataSource mysqlDataSource = new MysqlDataSource(); mysqlDataSource.setUrl();这种写法就是简单直观。
既然提到了耦合,这里我们也详细来看看内聚、耦合。
-
耦合:两个模块之间的关联关系是不是非常紧密,是不是这边的变化会影响到另外一边
举个例子:
假设你和你的朋友计划去旅行,你们决定一起订购机票和酒店。在订购过程中,你和朋友之间存在耦合关系。
- 强耦合:如果你们两个人的计划完全相同,你们只考虑彼此的意见,没有进行任何独立的研究和决策,那么你们之间的耦合是强耦合的。这种情况下,你们可能会错过其他更好的机票和酒店选择,因为你们只关心对方的意见,而忽略了其他的选项和可能性。
- 弱耦合:如果你和朋友之间保持一定的独立性,各自进行研究和对比,探索不同的机票和酒店选择,并在订购过程中保持一定的自主性,那么你们之间的耦合是弱耦合的。这种情况下,你们会有更多的选择,并能够做出更适合自己的决策
所以我们写代码的时候,追求的是低耦合~,要是耦合高了,随便改某个代码,可能会引起其他模块出现bug。
-
内聚:把相同的/相关联的功能,放到一起,内聚就高.零零散散哪里都有,内聚就低.
举个例子:
- 低内聚:好比你在家一直乱放东西,等到要一天你要找你想要的那个东西,你就不得不翻箱倒柜。
- 高内聚:反之你平时严格收纳好所有物品,这时候就会很容易找到你想要找的东西。
因此,综上,我们写代码的目标就是:高内聚,低耦合
所以这里我们选择写法一,因为它能够降低程序的耦合性,这也让我们的代码更加高效~
DataSource dataSource = new MysqlDataSource();((MysqlDataSource) dataSource).setUrl("jdbc:mysql://127.0.0.1:3306/test?characterEncoding=utf8&sueSSL=false");((MysqlDataSource) dataSource).setUser("root");((MysqlDataSource) dataSource).setPassword("123456");-
setUrl:这里的Url指的就是网络上的资源位置,也就是我们平常所说的网址~ -
"jdbc:mysql://127.0.0.1:3306/test?characterEncoding=utf8&sueSSL=false":这段Url是给jdbc操作mysql使用的。127.0.0.1:指的是IP地址,描述网络上一个主机所在的位置,这里的127.0.0.1是一个特殊的ip地址,叫做“环回ip”(loopback)- 由于我们的jdbc程序和mysql服务器都在同一个主机上面,所以我们就使用“环回ip”即可。
- 所谓“环回”,就是自己把数据发送给自己,虽然有这种专门环回的网线,但是我们也可以通过软件来实现环回的效果~
- 但是如果我们的数据库服务器和应用程序不在同一主机上,那么此时我们一个写对应主机的ip,而跨主机访问的相关操作需要我们掌握更多的网络原理的知识~
-
test:这里的test就是要访问mysql服务器上的哪个database -
utf8:这里不能写成utf8mb4,因为这里不是mysql服务器 -
false:这里就是是否要加密了 -
root:管理员mysql默认自带的用户 -
123456:我不告诉你~
-
-
和数据库服务器建立连接
Connection connection = dataSource.getConnection();不过这里会报错

这个是jdbc中常见的异常,如果执行sql或者操作数据库过程中出现问题,一般都会抛出这个异常。此时我们只需要引入这个包
import java.sql.SQLException;然后throws SQLException即可~ -
构造sql语句
String sql = "insert into student values(1, '张三')"; PreparedStatement statement = connection.prepareStatement(sql);-
PreparedStatement:Prepared:预处理的、Statement:语句这里的预处理:先解析检查sql,看看sql是不是有啥问题~~解析完毕之后,也会得到结构化数据,直接把解析好的结构化数据发给数据库服务器,服务器就省下了这部分解析的工作
-
-
将sql发送给服务器,执行sql
int n = statement.executeUpdate(); System.out.println("n = " + n);这里的n其实就对应我们MySQL那里的行数。
-
执行完毕之后,最后一个步骤,关闭连接,释放资源
程序通过代码和服务器进行通信,是需要消耗一定的硬件/软件资源
在程序结束的时候就需要告知服务器,释放这些资源/客户端也需要释放资源.
有借有还再借不难.statement.close(); connection.close();
总代码:
import com.mysql.jdbc.jdbc2.optional.MysqlDataSource;import javax.sql.DataSource;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.SQLException;//通过这个代码,往数据库的表中,插入一行记录
public class Demo1 {public static void main(String[] args) throws SQLException {//1.先创建 DataSourceDataSource dataSource = new MysqlDataSource();((MysqlDataSource) dataSource).setUrl("jdbc:mysql://127.0.0.1:3306/test?characterEncoding=utf8&sueSSL=false");((MysqlDataSource) dataSource).setUser("root");((MysqlDataSource) dataSource).setPassword("123456");//2.建立和数据库服务器之间的连接,连接好了之后, 才能进行后续的 请求-响应 交互Connection connection = dataSource.getConnection();//3.构造sqlString sql = "insert into student values(1, '杨洋')";PreparedStatement statement = connection.prepareStatement(sql);//4.把sql发送给服务器,返回值是一个整数,表示影响到的行数int n = statement.executeUpdate();System.out.println("n = " + n);//5.释放资源,关闭连接,释放顺序,是获取到的资源先释放statement.close();connection.close();}
}
执行效果如下:

这是我们表里目前的数据,下面我们Java代码操作数据库~

此时我们再看表:

不过这里我们需要注意的是,修改和删除的代码写法和插入是非常类似的~
只要调整sql内容即可~
String sql = "delete from student where id = 1 ";
String sql = "update student set name = '张三' where id = 100";
这里抛出个问题,我们上述的语句是写死的,那么我们怎么在程序运行时输入id ,name,来进行插入?
如下:
Scanner scanner = new Scanner(System.in);System.out.println("请输入学号:>");int id = scanner.nextInt();System.out.println("请输入姓名:>");String name = scanner.next();
String sql = "insert into student values(" + id + ",'"+ name +"')";


但是这种写法不优雅,也不安全,可能会导致sql注入攻击
要是在这个语句中把name,写成以下这样子:
'); drop database xxx;
阁下应该怎么应对呢?看我把你的库都删完了~🥵🥵🥵🥵
所以我们推荐以下这种写法:
String sql = "insert into student values(?,?)";
使用?作为占用符~
String sql = "insert into student values(?,?)";PreparedStatement statement = connection.prepareStatement(sql);statement.setInt(1,id);statement.setString(2,name);
针对占用符进行替换~


查询:
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;//jdbc 查询写法
public class Demo2 {public static void main(String[] args) throws SQLException {//1. 创建DataSourceDataSource dataSource = new MysqlDataSource();((MysqlDataSource) dataSource).setUrl("jdbc:mysql://127.0.0.1:3306/test?characterEncoding=utf8&sueSSL=false");((MysqlDataSource) dataSource).setUser("root");((MysqlDataSource) dataSource).setPassword("123456");//2. 建立连接Connection connection = dataSource.getConnection();//3.构造sqlString sql = "select * from student";PreparedStatement statement = connection.prepareStatement(sql);//4.执行sql//ResultSet 表示查询的结果集合(临时表)此处就需要针对这个表进行遍历ResultSet resultSet = statement.executeQuery();//resultSet提供了getXXX方法.(列是啥类型,就使用哪个方法)根据列名就可以取出对应的值了.//5.遍历 结果集合//通过 next 代码,就可以获得临时表中的每一行数据,如果获取到最后一行,再执行 next 返回 false 循环结束while (resultSet.next()){// 针对这一行进行处理了// 取出列的数据int id = resultSet.getInt("id");String name = resultSet.getString("name");System.out.println("id = " + id +", name = "+name);}//6.释放资源resultSet.close();statement.close();connection.close();}
}
