MySQL的JDBC编程详解

ゞ浴缸里的玫瑰 2024-03-16 15:16 60阅读 0赞

## 1.JDBC编程概念 ##

在实际项目中，我们对于数据库的操作大部分是通过代码来完成的，各种数据库在开发的时候，都会提供一组编程接口API。所以不同公司使用不同的数据库软件，那么程序员学习成本是非常大的，因为要学习不同数据库对应的编程风格和相关语法。所以在java层面就进行了统一，这就是JDBC。各大数据库厂商在自身原生的API接口的基础上进行封装，形成数据库驱动包，在由各个数据库的数据库驱动包集合形成JDBC。  
JDBC，即Java Database Connectivity，java数据库连接。是一种用于执行SQL语句的Java API，它是  
Java中的数据库连接规范。这个API由 java.sql.\*,javax.sql.\*包中的一些类和接口组成，它为Java  
开发人员操作数据库提供了一个标准的API，可以为多种关系数据库提供统一访问。

### 1.1 JDBC的工作原理 ###

JDBC 为多种关系数据库提供了统一访问方式，作为特定厂商数据库访问API的一种高级抽象，它主要包  
含一些通用的接口类。  
**JDBC访问数据库层次结构:**

![在这里插入图片描述][c31c8b2288a2493c995ceb4bb800930f.png]

### 1.2 JDBC优势 ###

1.  Java语言访问数据库操作完全面向抽象接口编程
2.  开发数据库应用不用限定在特定数据库厂商的API
3.  程序的可移植性大大增强

## 2.JDBC使用 ##

### 2.1JDBC驱动包的下载 ###

首先是安装驱动包，驱动包可以从MySQL官网获取，但是oracle官网贼难用；或者可以去github下载，再者可以去maven中央仓库下载(这个maven就类似计算机系列软件程序的应用商店)  
这里我们使用maven去下载

1.  打开网站https://mvnrepository.com/
2.  搜索mysql的相关软件  
    ![在这里插入图片描述][38376a9a9cd24fc0bad37052d3ed515c.png]
3.  点击第一个或者第二个（mysql-connector-java）都可以  
    ![在这里插入图片描述][69586986500141b89aff4f4057565108.png]
4.  然后选择对应的版本，注意这里的大版本号一定要和数据库服务器版本匹配，比如我的mysql的数据库服务器用的是5版本，所以我的驱动包也必须用5版本  
    ![在这里插入图片描述][ba452e8ce6be4dd9ac88fdf7de69a2d4.png]
5.  进入下载页面  
    ![在这里插入图片描述][3cffcccb2eab4c4f981affe12aa891e6.png]
6.  我们下载的文件后缀是.jar,这个后缀可以理解为是多个.class文件合在一起的压缩包  
    ![在这里插入图片描述][3adad926cd9045e2b0f9278075f62f85.png]

### 2.2驱动包的安装、导入 ###

1.  下载好驱动包（一个.jar文件）后，首先我们我们在idea创建一个新的项目  
    ![在这里插入图片描述][016516995ded43128c8d913cc4e78976.png]
2.  在项目下面我们创建一个目录  
    ![在这里插入图片描述][ff2705ceb2654fa29b2f61718f78114b.png]
3.  然后将我们下载下来的.jar文件复制粘贴到该目录下  
    ![在这里插入图片描述][2976e0810cb74813a5d8e28d2c940838.png]  
    ![在这里插入图片描述][e4ac4f3a5cab49a5b7452ec698c9b8b6.png]
4.  将目录标记为库，标记为库后，idea就可以识别.jar文件了。从而就可以调用里面的类来写代码了。  
    ![在这里插入图片描述][b6cd1f54a27248628ab9510b8f5954e3.png]
5.  导入成功后我们就可以开始正常编程了，我们在src文件下创建类JDBCIsert  
    ![在这里插入图片描述][f210c8d96e0546348a3e9cf49455fece.png]

### 2.3 IDEA内JDBC的使用 ###

在新建好类，以及main方法后，我们开始编程。JDBC需要通过已下步骤来完成开发

#### 2.3.1 创建并初始化一个数据源 ####

1.  创建并初始化MysqlDataSource  
    所谓数据源就是数据从哪里来，也就是描述数据库服务器在哪里，我们通过DataSource这个接口来描述。  
    但是DataSource本身是接口，是一个抽象类，不能直接new,所以实际上我们是new他的子类MysqlDataSource对象，来实现DataSource这个接口。

![在这里插入图片描述][ef7a8be2049443539352965a12de1b91.png]

DataSource dataSource = new MysqlDataSource();//这里实际是向上转型，子类实现父类接口

但是这样还不够，还需要向下转型一次，转回来，因为我们需要使用setUrl、setUser、setPassword方法，这个方法是子类MysqlDataSource独有的，父类并没有，所以进行向下转型。

1.  设置Url

((MysqlDataSource)dataSource).setUrl("jdbc:mysql://127.0.0.1:3306/JDBC?characterEncoding=utf8&useSSL=false);

所以上述两行代码实际上也可以写成以下代码

MysqlDataSource mysqlDataSource = new MysqlDataSource();
    mysqlDataSource.setUrl("jdbc:mysql://127.0.0.1:3306/JDBC?characterEncoding=utf8&useSSL=false);

URL是唯一资源定位符，是一个计算机网络中的常见术语，用于标记网络资源的位置。  
我们这里输入`"jdbc:mysql://127.0.0.1:3306/JDBC?characterEncoding=utf8&useSSL=false"`  
首先`jdbc`是固定的，`mysql`是我们使用的数据库，`127.0.0.1:3306`是IP地址，mysql数据库是一个“客户端服务器”结构，客户端和服务器端通过网络通信，网络上确定主机位置就是通过IP地址来确定，而127.0.0.1表示环回地址，表示本地Ip因为我们测试的mysql的服务器端和客户端在同一台设备上（我们自己的主机）。3306是端口号，用于区别不同的应用程序，数据库服务器的默认端口号是3306。`base1`是数据库名字，也就是我们用SQL语句写时`create database 数据库名`里面的数据库名字。`characterEncoding=utf8`表示字符集使用utf8，`useSSL=false`中SSL是一个加密协议，这里表示不加密。

1.  设置用户名和密码

((MysqlDataSource)dataSource).setUser("root");
    ((MysqlDataSource)dataSource).setPassword("120198087zbh");

用户名统一写成默认值root,不要写其他值；密码对应的是我们在装mysql时写入的密码。

#### 2.3.2 建立连接 ####

Connection connection = dataSource.getConnection();

![在这里插入图片描述][ff2e437f431d46d49b5791c4c2ac1021.png]  
但是这里是会报错的，这是一个受查异常，我们直接给他抛出，注意要抛出，还要导入这个异常的包。

然后我们用Conenction接口接收。注意Conection接收时我们一定使用java.sql这里包里面的Conection否则编译不了，千万不要使用mysql包里面的。

![在这里插入图片描述][2018dbc69d6c4924979432b0084642f0.png]

到这里的代码就可以先执行一下，判断是否有错误。

import com.mysql.jdbc.jdbc2.optional.MysqlDataSource;
    import javax.sql.DataSource;
    import java.sql.SQLException;
    
    public class JDBCInsert {
        
        public static void main(String[] args) throws SQLException {
        
            //JDBC需要通过以下步骤来完成开发
            //1.创建并初始化一个数据源
    //        MysqlDataSource mysqlDataSource = new MysqlDataSource();
    //        mysqlDataSource.setUrl();
            DataSource dataSource = new MysqlDataSource();
            ((MysqlDataSource)dataSource).setUrl("jdbc:mysql://127.0.0.1:3306/base1?characterEncoding=utf8&useSSL=false");
            ((MysqlDataSource)dataSource).setUser("root");
            ((MysqlDataSource)dataSource).setPassword("120198087zbh");
            //2.建立连接
            Connection connection = dataSource.getConnection();
        }
    }

#### 2.3.3构造sql语句 ####

在dos环境下我们打开我们的mysql,构建数据库，创建表。

Enter password: ************
    Welcome to the MySQL monitor.  Commands end with ; or \g.
    Your MySQL connection id is 3
    Server version: 5.7.27-log MySQL Community Server (GPL)
    
    Copyright (c) 2000, 2019, Oracle and/or its affiliates. All rights reserved.
    
    Oracle is a registered trademark of Oracle Corporation and/or its
    affiliates. Other names may be trademarks of their respective
    owners.
    
    Type 'help;' or '\h' for help. Type '\c' to clear the current input statement.
    mysql> create database base1 character set utf8mb4;
    Query OK, 1 row affected (0.00 sec)
    mysql> use base1;
    Database changed
    mysql> create table student(student_id int primary key auto_increment,student_name varchar(20));
    Query OK, 0 rows affected (0.02 sec)

假如我现在要在java里去新增数据，那么在IDEA里面写下如下代码

//3.构造SQL语句
    String sql = "insert into student values(1,'张三')";//创建一个sql语句
    PreparedStatement statement = connection.prepareStatement(sql);//使用PreparedStatement接口进行提前预编译我们的sql

让客户端进行预编译，服务器做的工作就简单一些，压力会小一些。PreparedStatement中Prepared可以理解为提前准备的，Statement语句

#### 2.3.4执行sql语句 ####

在构造好sql语句后（预编译）我们要将其发送给服务器端，并执行该语句

int ret  = statement.executeUpdate();//executeUpdate的返回值为int
    System.out.println("ret = "+ ret);

insert、updata、delete操作都使用executeUpate方法,其返回值为int,表示影响了几行，实际上就是我们在dos环境下（如下图）这个里面的0 rows affected 里面的0就是这个返回值。  
而select 操作使用的是executeQuery方法

![在这里插入图片描述][d967ec722d77413991b007653014a780.png]  
在执行完这一句之后就我们可以去MySQL验证一下，是不是插入了数据

mysql> select * from student;
    +------------+--------------+
    | student_id | student_name |
    +------------+--------------+
    |          1 | 张三         |
    +------------+--------------+
    1 row in set (0.01 sec)

发现确实是插入了的。

#### 2.3.5 释放资源 ####

1.  数据库的客户端和服务器之间进行通信的时候，是要消耗一定资源（包括cpu,内存，硬盘，带宽等）的。当客户端数量够大的时候，一定不能让客户端随意的占用消耗，也就是不用的时候要感觉释放。
2.  语句（statement）和链接（connection）的释放是有一定顺序的，谁先创建谁后释放。

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

#### 2.3.6 细节补充 ####

在本例子中我们插入数据是通过`nsert into student values(1,'张三')`这样写死的硬编码去完成的，但是实际项目中，这个输入肯定是需要用户在控制台输入才对。  
所以代码可以这样去改写

import javax.sql.DataSource;
    import java.sql.Connection;
    import java.sql.PreparedStatement;
    import java.sql.SQLException;
    import java.util.Scanner;
    
    public class JDBCInsert {
        
        public static void main(String[] args) throws SQLException {
        
    
            Scanner scanner = new Scanner(System.in);
            //JDBC需要通过以下步骤来完成开发
            //1.创建并初始化一个数据源
    //        MysqlDataSource mysqlDataSource = new MysqlDataSource();
    //        mysqlDataSource.setUrl();
            DataSource dataSource = new MysqlDataSource();
            ((MysqlDataSource)dataSource).setUrl("jdbc:mysql://127.0.0.1:3306/base1?characterEncoding=utf8&useSSL=false");//设置url
            ((MysqlDataSource)dataSource).setUser("root");//设置用户名
            ((MysqlDataSource)dataSource).setPassword("120198087zbh");//设置密码
            //2.建立连接
            Connection connection = dataSource.getConnection();//异常抛出
            //3.控制台输入
            System.out.println("请输入学号：");
            int student_id  = scanner.nextInt();
            System.out.println("请输入姓名：");
            String student_name = scanner.next();
            //4.构造SQL语句
            String sql = "insert into student values(" + student_id+ ",'" + student_name + "')";//创建一个sql语句
            PreparedStatement statement = connection.prepareStatement(sql);//使用PreparedStatement接口进行提前预编译我们的sql
            //5.执行SQL语句
            int ret  = statement.executeUpdate();//executeUpdate的返回值为int
            System.out.println("ret = "+ ret);
            //6.释放资源
            statement.close();
            connection.close();
        }
    }

但是这个代码还是比较丑陋的。

有更好的写法，可以借助PreparedStaterment的拼装功能来实现。

String sql = "insert into student values(?,?)";//用？(占位符)来先取代两个参数的位置
    PreparedStatement statement = connection.prepareStatement(sql);//使用PreparedStatement接口进行提前预编译我们的sql
    statement.setInt(1,student_id);//将第一个占位符所表示的整型参数替换为student_id
    statement.setString(2,student_name);//将第二个占位符所表示的字符串参数替换为student_name

那么我们的完整的代码可以就如下：

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 JDBCInsert {
        
        public static void main(String[] args) throws SQLException {
        
    
            Scanner scanner = new Scanner(System.in);
            //JDBC需要通过以下步骤来完成开发
            //1.创建并初始化一个数据源
    //        MysqlDataSource mysqlDataSource = new MysqlDataSource();
    //        mysqlDataSource.setUrl();
            DataSource dataSource = new MysqlDataSource();
            ((MysqlDataSource)dataSource).setUrl("jdbc:mysql://127.0.0.1:3306/base1?characterEncoding=utf8&useSSL=false");//设置url
            ((MysqlDataSource)dataSource).setUser("root");//设置用户名
            ((MysqlDataSource)dataSource).setPassword("120198087zbh");//设置密码
            //2.建立连接
            Connection connection = dataSource.getConnection();//异常抛出
            //3.控制台输入
            System.out.println("请输入学号：");
            int student_id  = scanner.nextInt();
            System.out.println("请输入姓名：");
            String student_name = scanner.next();
            //4.构造SQL语句
    //        String sql = "insert into student values(" + student_id + ",'" + student_name + "')" ;//创建一个sql语句
            String sql = "insert into student values(?,?)";//用？(占位符)来先取代两个参数的位置
            PreparedStatement statement = connection.prepareStatement(sql);//使用PreparedStatement接口进行提前预编译我们的sql
            statement.setInt(1,student_id);//将第一个占位符所表示的整型参数替换为student_id
            statement.setString(2,student_name);//将第二个占位符所表示的字符串参数替换为student_name
            //5.执行SQL语句
            int ret  = statement.executeUpdate();//executeUpdate的返回值为int
            System.out.println("ret = "+ ret);
            System.out.println(statement);//如果我们发现出错，我们可以将statement打印出来，观察一下是不是我们的SQL语句写错了；
            //6.释放资源
            statement.close();
            connection.close();
        }
    }

同时如果在项目开发中出错，我们可以通过打印statement看到我的SQL语句有么有出错。  
执行结果  
![在这里插入图片描述][f2bca4184bac4b72accca6146358dadf.png]  
![在这里插入图片描述][da4a1c2b6f1d4f6d9f6e9b816c505875.png]

当前我们的JDBC是使用DataSourse 这样的方式来进行编写。  
还有一种写法DriveManager,通过反射的方式加载驱动包中的类，进一步进行后续操作。  
但是还是推荐DataSourse，因为反射的代码可读性是非常差的，编译器难以对代码的正确性进行检查。此外，DataSource内置了数据库连接池，可以复用连接，提高连接服务器的效率。  
计算机中池的本质是一种预申请机制，利用空间换时间。

### 2.4 IDEA实现MySQL查询操作 ###

示例

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;
    import java.util.Scanner;
    
    public class JDBCSelect {
        
        public static void main(String[] args) throws SQLException {
        
            Scanner scanner = new Scanner(System.in);
            //1.创建并初始化数据源
            DataSource dataSource = new MysqlDataSource();
            ((MysqlDataSource)dataSource).setUrl("jdbc:mysql://127.0.0.1:3306/base1?characterEncoding=utf8&useSSL=false");
            ((MysqlDataSource)dataSource).setUser("root");
            ((MysqlDataSource)dataSource).setPassword("120198087zbh");
            //2.建立连接
            Connection connection = dataSource.getConnection();
            //3.构造SQL
            System.out.println("请输入查询语句");
            String sql = scanner.nextLine();
    //        String sql  = "select * from student";
            //4.预执行
            PreparedStatement statement = connection.prepareStatement(sql);
            //5.执行SQL语句
            ResultSet resultSet = statement.executeQuery();//resultSet就是select里面创建的临时表
            //6.遍历结果集合
            while(resultSet.next()){
        //这个效果和迭代器类似
                //把resultSet想象成一个表格，同时有一个光标指向表格的最上面
                //每一次调用next,光标都会往下走一行
                //当光标指向某一行的时候就可以通过getXXX等方法来获取当前行对应的列里面的数据。
                //当这个表都遍历完了，next就会返回false;
                int id = resultSet.getInt("student_id");
                //getXXX方法必须类型匹配
                //getXXX方法的参数可以是列名，也可以是下标
                String name = resultSet.getString("student_name");
                System.out.println("id = " + id +", name - " + name );
            }
            //7.释放资源
            resultSet.close();
            statement.close();
            connection.close();
        }
    }

结果  
![在这里插入图片描述][5d3344ac79a64a4eb470856e0e06d8c1.png]

[c31c8b2288a2493c995ceb4bb800930f.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/16/021a34ab0e4842cf8676dac2722bda21.png
[38376a9a9cd24fc0bad37052d3ed515c.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/16/f4a70e7bcd1b463385956bc81817d5ea.png
[69586986500141b89aff4f4057565108.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/16/55ed26c6f7614c7d8823456d058b9e47.png
[ba452e8ce6be4dd9ac88fdf7de69a2d4.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/16/cf4e20a2e57b40859bc987e3aa28bd7a.png
[3cffcccb2eab4c4f981affe12aa891e6.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/16/6dc80c704d95440fbf656bbbb45415b0.png
[3adad926cd9045e2b0f9278075f62f85.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/16/b981b4d2374b490caecd29bf2b912b3d.png
[016516995ded43128c8d913cc4e78976.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/16/90f637993d444098bf7723cbda1784b1.png
[ff2705ceb2654fa29b2f61718f78114b.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/16/69355e51005d401ab643a39575ba7078.png
[2976e0810cb74813a5d8e28d2c940838.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/16/09291146170d492cb36108221942542f.png
[e4ac4f3a5cab49a5b7452ec698c9b8b6.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/16/037264f228aa4943b44fab6ce6b3fe69.png
[b6cd1f54a27248628ab9510b8f5954e3.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/16/d61cd7a8e3b047ada3c1255782708ad7.png
[f210c8d96e0546348a3e9cf49455fece.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/16/9e23f10265974755b05ebd09ab71f76a.png
[ef7a8be2049443539352965a12de1b91.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/16/99f77134189d474f9ad0468c7bb05c5d.png
[ff2e437f431d46d49b5791c4c2ac1021.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/16/d28a470360e547e3ac90533e36b5edf5.png
[2018dbc69d6c4924979432b0084642f0.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/16/79cdd567f20841e792834053d4de24aa.png
[d967ec722d77413991b007653014a780.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/16/b33ed280dabc477e8267e693fc73b7a7.png
[f2bca4184bac4b72accca6146358dadf.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/16/5a6dc7af2a2e49d2a9db512bc159b738.png
[da4a1c2b6f1d4f6d9f6e9b816c505875.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/16/f876d5bbfb7c4a5ab8bb798ed8a62cba.png
[5d3344ac79a64a4eb470856e0e06d8c1.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/16/35459534deb94554bee15ac59528c784.png