基于JDBC的MySQL数据库编程

梦里梦外; 2023-09-25 14:03 53阅读 0赞

✨**博客主页:**[ **荣**][Link 1] ✨**系列专栏:**[ **MySQL**][_MySQL]  
✨**一句短话:** **难在坚持,贵在坚持,成在坚持!**

#### 文章目录 ####

*  一. JDBC概述
 *  二. JDBC前置工作
 *   *  1. 准备好MySQL驱动包
     *  2. 创建项目
 *  三. JDBC的使用步骤
 *   *  1. 创建数据源DataSourece
     *  2. 连接数据库
     *  3. 构造并执行sql语句
     *  4. 释放资源
     *  5. sql语句不要写死(以插入为例)
     *  6. JDBC修改操作
     *  7. JDBC删除操作
     *  8. JDBC查询操作
 *  四. 总结
 *   *  1. 数据库连接Connection
     *  2. Statement对象
     *  3. ResultSet对象

## 一. JDBC概述 ##

**JDBC**: JDBC(Java DataBase Connectivity Java数据库连接)就是使用java语言操作关系型数据库的一套API.

实际开发中, sql很少是手动去的输入的, 绝大多数的sql都是通过代码自动执行的, 这就需要我们使用其他编程语言来操作数据库服务器.

![img][]

各种数据库本身就都提供了一系列的API, 通过这些API就可以操作对应的数据库, 完成各种增删改查的操作; 同时也可以让我们比较方便的来实现客户端.

而每种数据库所提供的API都是一套单独的API, 是不相同的, 如果没有一个统一的标准, 要使用不同的数据库进行数据库编程, 就需要去学习好几套API, 这样就极大的提高了学习成本.

而这里所介绍的**JDBC, 是Java标准库为为我们所提供一套标准API, JDBC中约定了应该有哪些API, 应该怎么用, 各种数据库厂商都提供了能够活应JDBC相关的"驱动包(相当于API的具体实现)"**.

J**DBC屏蔽了不同数据库原生API之间的差异, 使用同一套API接口来规范了所有数据库的编程操作, 此时只要掌握了这套API, 无论操作哪个数据库, 操作的代码都是基本相同的**.

![img][img 1]

## 二. JDBC前置工作 ##

### 1. 准备好MySQL驱动包 ###

MySQL的jdbc驱动包我们可以去官网下载, 我们也可以maven中央仓库下载, maven中央仓库类似于一个 “应用商店”，里面有许多的API以及依赖包.

这个驱动包可以从Oracle官网下载, 但是可能不太好找, 所以更建议去maven中央仓库下载jdbc驱动包.

网址：[maven中央仓库][maven]

第一步, 点进网址进入maven中央仓库.

![img][img 2]

第二步, 搜索MySQL, 选择MySQL Connector java.

![img][img 3]

第三步, 点击进入, 找到对应大版本的jdbc驱动包, 比如我的MySQL是5版本的, 那驱动包也选择5版本的.

![img][img 4]

第四步, 第进去, 点击jar, 下载驱动包, 驱动包中有很多字节码文件(.class).

![img][img 5]

下载完成我们的驱动包就准备好了.

### 2. 创建项目 ###

使用IDEA编译器创建一个项目, 项目创建好后, 按照下面的步骤操作：

第一步, 创建一个目录, 名字随便起, 这里就叫lib目录.

![img][img 6]

第二步, 将下载好的驱动包拷贝到该目录.

![img][img 7]

第三步, 设置选项, 右键刚才创建并已经将驱动包拷贝的目录, 找到Add as Library…

![img][img 8]

![img][img 9]

此时, 驱动包就导进项目中了, idea就可以解析出jar包里面的内容, 然后就是写相关代码了.

## 三. JDBC的使用步骤 ##

写jdbc的代码时, 看起来挺复杂, 其实都有固定的格式, 套用即可.

### 1. 创建数据源DataSourece ###

第一步, 创建`DataSource`对象, 用来来描述数据库在哪.

DataSource dataSource = new MysqlDataSource();

其中`DataSource`为标准库中`java.sql`里面的一个jdbc接口, `MysqlDataSource`是来源于我们所下载驱动包中的一个实现`DataSource`接口的类.

第二步, 设置数据库的 “位置” (URL), 登录数据库的用户名和密码.

//设置数据库所在地址
    ((MysqlDataSource)dataSource).setUrl
    	("jdbc:mysql://127.0.0.1:3306/java_rong?characterEncoding=utf8&useSSL=false");
    //设置登录数据库的用户名
    ((MysqlDataSource)dataSource).setUser("root");
    //设置登录数据库的密码
    ((MysqlDataSource)dataSource).setPassword("111111");

`jdbc:mysql://127.0.0.1:3306/java_rong?characterEncoding=utf8&useSSL=false`是一个URL, 也叫唯一资源地址符.

具体含义对照: `URL类型声明://数据库的地址/数据库名?字符集编码&是否加密`.

![img][img 10]

上面的向上/向下转型是jdbc中比较常用的写法, 让后续的代码继续使用DataSoure类型的实例, 避免MysqlDataSource扩散到代码中的各个地方, 以此方便未来更换数据库, 更换时只需要修改一处代码即可.

User是用户名, root为数据库的默认用户名.

Password是登录数据库的密码, 即安装数据时, 我们自己所设的密码.

此时我们数据源创建的操作, 只是去描述了下服务器在那里, 访问哪个数据库, 编码方式是什么, 登陆账号密码是什么等等, 但还没有真正进行连接访问, 下面进行的连接操作, 是真正开始通过网络进行通信.

### 2. 连接数据库 ###

第三步, 和数据库服务器建立连接, 创建好数据源`DataSource`对象后, 调用该对象的`getConnection()`方法, 获取`java.sql.Connection`对象, 此时就可以与数据库建立连接了.

Connection是网络通信中的核心概念, 叫做"连接".

Connection connection = dataSource.getConnection();

还可以通过Connection实例去调用事务方法

//开启事务
    connection.setAutoCommit(boolean autoCommit);//是否自动提交事务,true是,false否
    //提交事务
    connection.commit();
    //回滚事务
    connection.rollback();

### 3. 构造并执行sql语句 ###

第四步, 构造`sql`语句字符串, 并将该语句包装成`PreparedStatement`对象, 即调用`Connection`对象的`prepareStatement`方法, 参数是`sql`字符串, 会返回一个`PreparedStatement`对象, 然后我们再调用`PreparedStatement`对象中的`executeUpdate`方法或`executeQuery`方法执行`sql`语句(执行其实就是在给服务器发送网络请求).

先在mysql客户端中创建一个学生表, 有id和name两个字段

mysql> create table student(
        ->      id int,
        ->   name varchar(20)
        -> );
    Query OK, 0 rows affected (0.03 sec)

这里的代码先以插入操作为例.

//构造的sql语句不需要带上;
    String sql = "insert into student values(1, '张三')";
    //将sql字符串包装成一个语句对象,表示待执行的sql的对象
    PreparedStatement statement = connection.prepareStatement(sql);
    //执行sql
    int ret = statement.executeUpdate();//返回值为受影响的行数

要注意如果待执行的sql语句操作是`insert`, `update`, `delete`, 使用`executeUpdate`方法执行即可，返回值为影响数据的行数;

而如果待执行的sql语句操作是`select`, 则使用`executeQuery`方法执行，返回值是一个`ResultSet`结果表对象, 其中储存了查询到的的结果, 我们可以通过遍历该结果表来获取查询到的数据.

### 4. 释放资源 ###

第五步, 释放资源, 我们执行完毕sql语句后需要及时地将资源释放, 在JDBC编程中, 最常见需要释放的类或接口有三个, 分别是`Connection`, `PreparedStatement`, `ResultSet`, 要注意的是释放资源的顺序和开启资源的的顺序是相反的, 也就是先开启的要后释放.

//此时sql语句已经执行完毕了，需要释放资源
    statement.close();
    connection.close();

下面是jdbc完成插入操作的完整代码:

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 JDBCInsertDemo {
        public static void main(String[] args) throws SQLException {
            //1. 创建数据源
            DataSource dataSource = new MysqlDataSource();
            //设置数据库所在地址
            ((MysqlDataSource)dataSource).setUrl
                    ("jdbc:mysql://127.0.0.1:3306/java_rong?characterEncoding=utf8&useSSL=false");
            //设置登录数据库的用户名
            ((MysqlDataSource)dataSource).setUser("root");
            //设置登录数据库的密码
            ((MysqlDataSource)dataSource).setPassword("111111");
    
            //2. 和数据库建立连接
            Connection connection = dataSource.getConnection();//会报异常,需要处理
    
            //3. 构造sql语句
            //要注意sql字符串中不需要带上;
            String sql = "insert into student values(1, '张三')";
            //将sql字符串包装成一个语句对象,表示待执行的sql的对象
            PreparedStatement statement = connection.prepareStatement(sql);
            //4. 执行sql
            int ret = statement.executeUpdate();
            System.out.println(ret);
    
            //5. 释放资源
            //此时sql语句已经执行完毕了，需要释放资源
            statement.close();
            connection.close();
        }
    }

执行结果:

显示1行受到了影响

![img][img 11]

此时再来观察数据库中的student, 插入是成功了的.

mysql> show tables;
    +---------------------+
    | Tables_in_java_rong |
    +---------------------+
    | account             |
    | student             |
    +---------------------+
    2 rows in set (0.00 sec)
    
    mysql> select * from student;
    +------+--------+
    | id   | name   |
    +------+--------+
    |    1 | 张三   |
    +------+--------+
    1 row in set (0.00 sec)

### 5. sql语句不要写死(以插入为例) ###

观察上面的插入操作代码, 其中构造的sql语句是完全写死的, 造成了这个程序只能执行一次, 无法多次动态执行, 其实改善这一点很简单, 我们可以使用Scanner类通过控制台来让用户进行字段信息输入的操作, 然后将输入的信息整合到到sql字符串中.

那么如何整合呢, 最容易想到的就是字符串拼接, 也很容易实现, 代码如下:

System.out.println("请输入学号: ");
    int id = scanner.nextInt();
    System.out.println("请输入姓名: ");
    String name = scanner.next();
    
    // 3. 构造 SQL 语句
    String sql = "insert into student values("+ id +", '" + name + "')";

执行结果:

![img][img 12]  
此时程序也可以完成操作, 但是这么做是有缺陷的, 首先这个字符串就很容易写错, 特别是单双引号比较多的情况, 还有这种写法是很不安全的是, 黑客可以使用sql注入的方式来修改数据库.

所以不建议使用上面的方法, 更好的方法就是把sql字符串中待输入的信息使用`?`来进行替换(占位), 然后通过`PreparedStatement`中的`setXXX`系列方法来逐个设置每个`?`的内容;

这个系列的方法, 第一个参数表示sql待执行对象中第多少个`?`，第二个参数表示将这个`?`设置的内容, 需要注意`?`占位符的编号是从1开始的, 而不是从0开始的.

此时使用这种方式完成插入操作, 代码如下:

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 JdbcInsertDemo {
        public static void main(String[] args) throws SQLException {
            //1. 创建数据源
            DataSource dataSource = new MysqlDataSource();
            ((MysqlDataSource)dataSource).setUrl
                    ("jdbc:mysql://127.0.0.1:3306/java_rong?characterEncoding=utf8&useSSL=false");
            ((MysqlDataSource)dataSource).setUser("root");
            ((MysqlDataSource)dataSource).setPassword("111111");
            
            //2. 和数据库建立连接
            Connection connection = dataSource.getConnection();
    
            Scanner scanner = new Scanner(System.in);
            System.out.println("请输入学号:");
            int id = scanner.nextInt();
            System.out.println("请输入姓名");
            String name = scanner.next();
    
            //3. 构造sql语句
            String sql = "insert into student values (?, ?)";
            PreparedStatement statement = connection.prepareStatement(sql);
            statement.setInt(1, id);
            statement.setString(2, name);
            System.out.println("sql: "+statement);
            
            //4. 执行sql
            int ret = statement.executeUpdate();
            System.out.println("ret= " + ret);
            
            //5. 断开连接,释放资源
            statement.close();
            connection.close();
        }
    }

执行结果:

![img][img 13]

### 6. JDBC修改操作 ###

jdbc的修改代码和插入操作是一样的, 只需要修改sql语句即可.

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 JdbcUpdateDemo {
        public static void main(String[] args) throws SQLException {
           //1. 创建数据源
            DataSource dataSource = new MysqlDataSource();
            ((MysqlDataSource)dataSource).setUrl
                    ("jdbc:mysql://127.0.0.1:3306/java_rong?characterEncoding=utf8&useSSL=false");
            ((MysqlDataSource)dataSource).setUser("root");
            ((MysqlDataSource)dataSource).setPassword("111111");
    
            //2. 和数据库建立连接
            Connection connection = dataSource.getConnection();
    
            Scanner scanner = new Scanner(System.in);
            System.out.println("请输入要修改学生的学号:");
            int oldId = scanner.nextInt();
            System.out.println("请输入修改值(学号):");
            int newId = scanner.nextInt();
            System.out.println("请输入修改值(姓名):");
            String newName = scanner.next();
    
            //3. 构造sql语句
            String sql = "update student set id = ?, name = ? where id = ?";
            PreparedStatement statement = connection.prepareStatement(sql);
            statement.setInt(3, oldId);
            statement.setInt(1, newId);
            statement.setString(2, newName);
            System.out.println("sql: "+statement);
    
            //4. 执行sql
            int ret = statement.executeUpdate();
            System.out.println("ret= "+ret);
    
            //5. 断开连接,关闭资源
            statement.close();
            connection.close();
        }
    }

执行结果:

![img][img 14]

### 7. JDBC删除操作 ###

同样的, jdbc的删除代码和插入操作也是一样的, 只需要修改sql语句即可.

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 JdbcDeleteDemo {
        public static void main(String[] args) throws SQLException {
            //1. 创建数据源
            DataSource dataSource = new MysqlDataSource();
            ((MysqlDataSource)dataSource).setUrl
                    ("jdbc:mysql://127.0.0.1:3306/java_rong?characterEncoding=utf8&useSSL=false");
            ((MysqlDataSource)dataSource).setUser("root");
            ((MysqlDataSource)dataSource).setPassword("111111");
    
            //2. 和数据库建立连接
            Connection connection = dataSource.getConnection();
    
            Scanner scanner = new Scanner(System.in);
            System.out.println("请输入要删除记录的姓名:");
            String name = scanner.next();
    
            //3. 构造sql语句
            String sql = "delete from student where name = ?";
            PreparedStatement statement = connection.prepareStatement(sql);
            statement.setString(1, name);
            System.out.println("sql: "+statement);
    
            //4. 执行sql
            int ret = statement.executeUpdate();
            System.out.println("ret= "+ret);
    
            //5. 断开连接,关闭资源
            statement.close();
            connection.close();
        }
    }

执行结果:

![img][img 15]

### 8. JDBC查询操作 ###

jdbc的查询操作与插入删除修改操作代码稍有不同, 执行查询sql语句的时候是调用`executeQuery`方法来执行语句的, 并且会返回查询到的结果集(`ResultSet对象`), 我们可以通过类似于迭代器的操作来获取查询到的数据, 最后`ResultSet对象`使用完后需要进行资源释放.

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 JdbcSelectDemo {
        public static void main(String[] args) throws SQLException {
            //1. 创建数据源
            DataSource dataSource = new MysqlDataSource();
            ((MysqlDataSource)dataSource).setUrl
                    ("jdbc:mysql://127.0.0.1:3306/java_rong?characterEncoding=utf8&useSSL=false");
            ((MysqlDataSource)dataSource).setUser("root");
            ((MysqlDataSource)dataSource).setPassword("111111");
    
            //2. 和数据库建立连接
            Connection connection = dataSource.getConnection();
    
            //3. 构造sql
            String sql = "select * from student";
            PreparedStatement statement = connection.prepareStatement(sql);
    
            //4. 执行获取结果集合
            ResultSet resultSet = statement.executeQuery();
            while (resultSet.next()) {
                int id = resultSet.getInt("id");
                String name = resultSet.getString("name");
                System.out.println("id: "+id+" name: "+name);
            }
    
            //5. 断开连接,释放资源
            resultSet.close();
            statement.close();
            connection.close();
        }
    }

执行结果:

![img][img 16]

## 四. 总结 ##

### 1. 数据库连接Connection ###

Connection接口实现类由数据库提供，获取Connection对象通常有两种方式：

*  一种是通过`DriverManager` (驱动管理类) 的静态方法获取:

// 加载JDBC驱动程序
    Class.forName("com.mysql.jdbc.Driver");
    // 创建数据库连接
    Connection connection = DriverManager.getConnection(url);

*  一种是通过`DataSource` (数据源) 对象获取, 即上面篇幅锁介绍的, **实际应用中会使用DataSource对象**.

以上两种方式的区别是:

1.  `DriverManager`类来获取的Connection连接, 是无法重复利用的, 每次使用完以后释放资源时, 通过connection.close()都是关闭物理连接。
2.  `DataSource`提供连接池的支持, 连接池在初始化时将创建一定数量的数据库连接, 这些连接是可以复用的, 每次使用完数据库连接, 释放资源调用connection.close()都是将Conncetion连接对象回收.

### 2. Statement对象 ###

`Statement`对象主要是将SQL语句发送到数据库中, JDBC API中主要提供了三种Statement对象.

![img][img 17]

实际开发中最常用的是`PreparedStatement`对象

![img][img 18]主要掌握两种执行SQL的方法：

*  `executeQuery()`方法执行后返回单个结果集的，通常用于`select`语句
 *  `executeUpdate()`方法返回值是一个整数，指示受影响的行数，通常用于`update`、`insert`、`delete` 语句

### 3. ResultSet对象 ###

`ResultSet`对象它被称为结果集, 它代表符合SQL语句条件的所有行, 并且它通过一套`getXXX`方法提供了对这些行中数据的访问.

`ResultSet`里的数据一行一行排列, 每行有多个字段, 并且有一个记录指针, 指针所指的数据行叫做当前数据行, 我们只能来操作当前的数据行; 我们如果想要取得某一条记录, 就要使用`ResultSet`的`next()`方法, 如果我们想要得到`ResultSet`里的所有记录, 就应该使用`while`循环.

[Link 1]: https://blog.csdn.net/Trong_?spm=1000.2115.3001.5343
[_MySQL]: https://blog.csdn.net/trong_/category_12083042.html?spm=1001.2014.3001.5482
[img]: https://img-blog.csdnimg.cn/img_convert/622385da39fb5bf5f4d1398b45039e3a.png
[img 1]: https://img-blog.csdnimg.cn/img_convert/3da0194af134aa53f1b2e01f618773d5.png
[maven]: https://mvnrepository.com/
[img 2]: https://img-blog.csdnimg.cn/img_convert/afd1a69ce31d31d6bbc15e0720a17df5.png
[img 3]: https://img-blog.csdnimg.cn/img_convert/897e7431cfd6f40d0f004eba89be3f4b.png
[img 4]: https://img-blog.csdnimg.cn/img_convert/da79d867a572675a6b654cf6d5651811.png
[img 5]: https://img-blog.csdnimg.cn/img_convert/3494c115915666fad54f1b69ad1073a8.png
[img 6]: https://img-blog.csdnimg.cn/img_convert/af1b4172024651c3b68afd3307ce8fcd.png
[img 7]: https://img-blog.csdnimg.cn/img_convert/ea5cc966fa64dcafab89f2ecf3a960b2.png
[img 8]: https://img-blog.csdnimg.cn/img_convert/1ca3e510736cbefcc200416879556d4e.png
[img 9]: https://img-blog.csdnimg.cn/img_convert/07a629698f439166aa1778f6d8a315d8.png
[img 10]: https://img-blog.csdnimg.cn/img_convert/78a8d7ce0548867fab292f83ae86868a.png
[img 11]: https://img-blog.csdnimg.cn/img_convert/f07923ae182700b3ba22f9001b2d6a83.png
[img 12]: https://img-blog.csdnimg.cn/img_convert/25e04c1e458f51ca3b23fb9d0598c0f5.png
[img 13]: https://img-blog.csdnimg.cn/img_convert/7060de42a573864fb31dc0d02e34bbdc.png
[img 14]: https://img-blog.csdnimg.cn/img_convert/0649ee71aff77544afb4943df836a7de.png
[img 15]: https://img-blog.csdnimg.cn/img_convert/983b84fa39f6fcfcef2d51c59526f517.png
[img 16]: https://img-blog.csdnimg.cn/img_convert/07b3a1d355479e15554266f3f133e308.png
[img 17]: https://img-blog.csdnimg.cn/img_convert/a5408c1486086445f82b6ce490185867.png
[img 18]: https://img-blog.csdnimg.cn/img_convert/2f3bdba1efba006610c4048d0f701920.png