需要的 jar 包链接：https://pan.baidu.com/s/12225OO8tSKwz1fkRT5Q0AA?pwd=5zfx 提取码：5zfx

1、引言

1.1 数据的存储

我们在开发 Java 程序时，数据都是存储在内存中，属于临时存储，当程序停止或重启时，内存中的数据就丢失了！我们为了解决数据的长期存储问题，有如下解决方案：

数据通过 I/O 流技术，存储在本地磁盘中，解决了持久化问题，但是没有结构和逻辑，不方便管理和维护。
通过关系型数据库，将数据按照特定的格式交由数据库管理系统维护，关系型数据库是通过库和表分隔不同的数据，表中数据存储的方式是行和列，区分相同格式不同值的数据。

1.2 数据的操作

数据存储在数据库，仅仅解决了我们数据存储的问题，但当我们程序运行时，需要读取数据，以及对数据做增删改的操作，那么我们如何通过 Java 程序对数据库中的数据做增删改查呢？

2、JDBC 概述

2.1 什么是 JDBC

JDBC：Java Database Connectivity，意为 Java 数据库连接。
JDBC 是 Java 提供的一组独立于任何数据库管理系统的API。
Java 提供接口规范，由各个数据库厂商提供接口的实现，厂商提供的实现类封装成 jar 文件，也就是我们俗称的数据库驱动 jar 包。
学习 JDBC，充分体现了面向接口编程的好处，程序员只关心标准和规范，而无需关注实现过程。

2.2 JDBC 的核心组成

接口规范：
- 为了项目代码的可移植性，可维护性，SUN 公司从最初就制定了 Java 程序连接各种数据库的统一接口规范。这样的话，不管是连接哪一种 DBMS 软件，Java 代码可以保持一致性。
- 接口存储在 java.sql 和 javax.sql 包下。
实现规范：
- 因为各个数据库厂商的 DBMS 软件各有不同，那么各自的内部如何通过 SQL 实现增、删、改、查等操作管理数据，只有这个数据库厂商自己更清楚，因此把接口规范的实现交给各个数据库厂商自己实现。
- 厂商将实现内容和过程封装成 jar 文件，我们程序员只需要将 jar 文件引入到项目中集成即可，就可以开发调用实现过程操作数据库了。

3、快速入门

3.1 JDBC搭建步骤

准备数据库。
官网下载数据库连接驱动 jar 包。https://downloads.mysql.com/archives/c-j/
创建 Java 项目，在项目下创建 lib 文件夹，将下载的驱动 jar 包复制到文件夹里。
选中 lib 文件夹右键 -> Add as Library，与项目集成。
编写代码。

3.2 代码实现

（1）数据库准备

CREATE DATABASE atguigu;

use atguigu;

create table t_emp
(
    emp_id     int auto_increment comment '员工编号' primary key,
    emp_name   varchar(100)  not null comment '员工姓名',
    emp_salary double(10, 5) not null comment '员工薪资',
    emp_age    int           not null comment '员工年龄'
);

insert into t_emp (emp_name,emp_salary,emp_age)
values  ('andy', 777.77, 32),
        ('大风哥', 666.66, 41),
        ('康师傅',111, 23),
        ('Gavin',123, 26),
        ('小鱼儿', 123, 28);

（2）Java 代码

package com.atguigu.base;

import java.sql.*;

public class JdbcQuick {
    public static void main(String[] args) throws ClassNotFoundException, SQLException {
        //1.注册驱动
        Class.forName("com.mysql.cj.jdbc.Driver");
      
        //2.获取数据库连接
        String url = "jdbc:mysql://localhost:3306/atguigu";
        String user = "root";
        String password = "123456";
        Connection connection = DriverManager.getConnection(url, user, password);

        //3.创建Statement对象
        PreparedStatement preparedStatement = connection.prepareStatement("select emp_id,emp_name,emp_salary,emp_age from t_emp");

        //4.编写SQL语句并执行，获取结果
        ResultSet resultSet = preparedStatement.executeQuery();

        //5.处理结果
        while (resultSet.next()) {
            int empId = resultSet.getInt("emp_id");
            String empName = resultSet.getString("emp_name");
            String empSalary = resultSet.getString("emp_salary");
            int empAge = resultSet.getInt("emp_age");
            System.out.println(empId + "\t" + empName + "\t" + empSalary + "\t" + empAge);
        }

        //6.释放资源(先开后关原则)
        resultSet.close();
        preparedStatement.close();
        connection.close();
    }
}

（3）运行测试

3.3 步骤总结

注册驱动【依赖的驱动类，进行安装】
获取连接【Connection 建立连接】
创建发送 SQL 语句对象【Connection 创建发送 SQL 语句的 Statement】
发送 SQL 语句，并获取返回结果【Statement 发送 SQL 语句到数据库并且取得返回结果】
结果集解析【结果集解析，将查询结果解析出来】
资源关闭【释放 ResultSet、Statement 、Connection】

4、核心API

4.1 注册驱动

Class.forName("com.mysql.cj.jdbc.Driver");

在 Java 中，当使用 JDBC（Java Database Connectivity）连接数据库时，需要加载数据库特定的驱动程序，以便与数据库进行通信。加载驱动程序的目的是为了注册驱动程序，使得 JDBC API 能够识别并与特定的数据库进行交互。
从 JDK6 开始，不再需要显式地调用 Class.forName() 来加载 JDBC 驱动程序，只要在类路径中集成了对应的 jar 文件，会自动在初始化时注册驱动程序。

4.2 Connection

Connection 接口是 JDBC API 的重要接口，用于建立与数据库的通信通道。换而言之，Connection 对象不为空，则代表一次数据库连接。
在建立连接时，需要指定数据库 URL、用户名、密码参数。
- URL：jdbc:mysql://localhost:3306/atguigu
- 标准格式：jdbc:mysql://IP地址:端口号/数据库名称?参数键值对1&参数键值对2
Connection 接口还负责管理事务，Connection 接口提供了 commit 和 rollback 方法，用于提交事务和回滚事务。
可以创建 Statement 对象，用于执行 SQL 语句并与数据库进行交互。
在使用 JDBC 技术时，必须要先获取 Connection 对象，在使用完毕后，要释放资源，避免资源占用浪费及泄漏。

4.3 Statement

Statement 接口用于执行 SQL 语句并与数据库进行交互。它是 JDBC API 中的一个重要接口。通过 Statement 对象，可以向数据库发送 SQL 语句并获取执行结果。
结果可以是一个或多个结果。
- 增删改：受影响行数单个结果。
- 查询：单行单列、多行多列、单行多列等结果。
但是 Statement 接口在执行 SQL 语句时，会产生 SQL注入攻击问题：
- 当使用 Statement 执行动态构建的 SQL 查询时，往往需要将查询条件与 SQL 语句拼接在一起，直接将参数和 SQL 语句一并生成，让 SQL 的查询条件始终为 true 得到结果。

4.4 PreparedStatement

PreparedStatement 是 Statement 接口的子接口，用于执行 预编译 的 SQL 语句，作用如下：
- 预编译 SQL 语句：在创建 PreparedStatement 时，就会预编译 SQL 语句，也就是 SQL 语句已经固定。
  - 防止 SQL 注入：PreparedStatement 支持参数化查询，将数据作为参数传递到 SQL 语句中，采用 ? 占位符的方式，将传入的参数用一对单引号包裹起来 ''，无论传递什么都作为值。有效防止传入关键字或值导致 SQL 注入问题。
- 性能提升：PreparedStatement 是预编译 SQL 语句，同一 SQL 语句多次执行的情况下，可以复用，不必每次重新编译和解析。
后续的学习我们都是基于 PreparedStatement 进行实现，更安全、效率更高！

4.5 ResultSet

ResultSet是 JDBC API 中的一个接口，用于表示从数据库中执行查询语句所返回的结果集。它提供了一种用于遍历和访问查询结果的方式。
遍历结果：ResultSet 可以使用 next() 方法将游标移动到结果集的下一行，逐行遍历数据库查询的结果，返回值为 boolean 类型，true 代表有下一行结果，false 则代表没有。
获取单列结果：可以通过 getXxx 的方法获取单列的数据，该方法为重载方法，支持索引和列名进行获取。

5、基于 PreparedStatement 实现 CRUD

为方便进行测试，这里引入两个 jar 包：

5.1 查询单行单列

    @Test
    public void querySingleRowAndColumn() throws SQLException {
        //1.注册驱动
//        Class.forName("com.mysql.cj.jdbc.Driver");

        //2.获取数据库连接
        Connection connection = DriverManager.getConnection("jdbc:mysql://localhost:3306/atguigu", "root","123456");

        //3.创建PreparedStatement对象，并预编译SQL语句
        PreparedStatement preparedStatement = connection.prepareStatement("select count(*) as count from t_emp");

        //4.执行SQL语句，获取结果
        ResultSet resultSet = preparedStatement.executeQuery();

        //5.处理结果
        while (resultSet.next()){
            int count = resultSet.getInt("count");
            System.out.println("count = " + count);
        }

        //6.释放资源(先开后关原则)
        resultSet.close();
        preparedStatement.close();
        connection.close();
    }

5.2 查询单行多列

    @Test
    public void querySingleRow() throws SQLException {
        //1.注册驱动
//        Class.forName("com.mysql.cj.jdbc.Driver");

        //2.获取数据库连接
        Connection connection = DriverManager.getConnection("jdbc:mysql://localhost:3306/atguigu","root","123456");

        //3.创建PreparedStatement对象，并预编译SQL语句，使用?占位符
        PreparedStatement preparedStatement = connection.prepareStatement("select emp_id,emp_name,emp_salary,emp_age from t_emp where emp_id = ?");

        //4.为占位符赋值，索引从1开始，执行SQL语句，获取结果
        preparedStatement.setInt(1,1);
        ResultSet resultSet = preparedStatement.executeQuery();

        //5.处理结果
        while (resultSet.next()){
            int empId = resultSet.getInt("emp_id");
            String empName = resultSet.getString("emp_name");
            String empSalary = resultSet.getString("emp_salary");
            int empAge = resultSet.getInt("emp_age");
            System.out.println(empId+"\t"+empName+"\t"+empSalary+"\t"+empAge);
        }

        //6.释放资源(先开后关原则)
        resultSet.close();
        preparedStatement.close();
        connection.close();
    }

5.3 查询多行多列

@Test
public void queryMoreRow() throws SQLException {
    //1.注册驱动
    //        Class.forName("com.mysql.cj.jdbc.Driver");

    //2.获取数据库连接
    Connection connection = DriverManager.getConnection("jdbc:mysql://localhost:3306/atguigu","root","123456");

    //3.创建Statement对象
    PreparedStatement preparedStatement = connection.prepareStatement("select emp_id,emp_name,emp_salary,emp_age from t_emp");

    //4.编写SQL语句并执行，获取结果
    ResultSet resultSet = preparedStatement.executeQuery();

    //5.处理结果
    while (resultSet.next()){
        int empId = resultSet.getInt("emp_id");
        String empName = resultSet.getString("emp_name");
        String empSalary = resultSet.getString("emp_salary");
        int empAge = resultSet.getInt("emp_age");
        System.out.println(empId+"\t"+empName+"\t"+empSalary+"\t"+empAge);
    }

    //6.释放资源(先开后关原则)
    resultSet.close();
    preparedStatement.close();
    connection.close();
}

5.4 新增

@Test
public void insert() throws SQLException {
    //1.注册驱动
    //        Class.forName("com.mysql.cj.jdbc.Driver");

    //2.获取数据库连接
    Connection connection = DriverManager.getConnection("jdbc:mysql://localhost:3306/atguigu","root", "123456");

    //3.创建Statement对象
    PreparedStatement preparedStatement = connection.prepareStatement("insert into t_emp (emp_name,emp_salary,emp_age)values  (?, ?,?)");

    //4.为占位符赋值，索引从1开始，编写SQL语句并执行，获取结果
    preparedStatement.setString(1,"rose");
    preparedStatement.setDouble(2,666.66);
    preparedStatement.setDouble(3,28);
    int result = preparedStatement.executeUpdate();

    //5.处理结果
    if(result>0){
        System.out.println("添加成功");
    }else{
        System.out.println("添加失败");
    }

    //6.释放资源(先开后关原则)
    preparedStatement.close();
    connection.close();
}

5.5 修改

@Test
public void update() throws SQLException {
    //1.注册驱动
    //        Class.forName("com.mysql.cj.jdbc.Driver");

    //2.获取数据库连接
    Connection connection = DriverManager.getConnection("jdbc:mysql://localhost:3306/atguigu", "root", "123456");

    //3.创建Statement对象
    PreparedStatement preparedStatement = connection.prepareStatement("update t_emp set emp_salary = ? where emp_id = ?");

    //4.为占位符赋值，索引从1开始，编写SQL语句并执行，获取结果
    preparedStatement.setDouble(1,888.88);
    preparedStatement.setDouble(2,8);
    int result = preparedStatement.executeUpdate();

    //5.处理结果
    if(result>0){
        System.out.println("修改成功");
    }else{
        System.out.println("修改失败");
    }

    //6.释放资源(先开后关原则)
    preparedStatement.close();
    connection.close();
}

5.6 删除

@Test
public void delete() throws SQLException {
    //1.注册驱动
    //        Class.forName("com.mysql.cj.jdbc.Driver");

    //2.获取数据库连接
    Connection connection = DriverManager.getConnection("jdbc:mysql://localhost:3306/atguigu", "root", "123456");

    //3.创建Statement对象
    PreparedStatement preparedStatement = connection.prepareStatement("delete from t_emp where emp_id = ?");

    //4.为占位符赋值，索引从1开始，编写SQL语句并执行，获取结果
    preparedStatement.setInt(1,8);
    int result = preparedStatement.executeUpdate();

    //5.处理结果
    if(result>0){
        System.out.println("删除成功");
    }else{
        System.out.println("删除失败");
    }

    //6.释放资源(先开后关原则)
    preparedStatement.close();
    connection.close();
}

6、常见问题

6.1 资源的管理

在使用 JDBC 的相关资源时，比如 Connection、PreparedStatement、ResultSet，使用完毕后，要及时关闭这些资源以释放数据库服务器资源和避免内存泄漏是很重要的。

6.2 SQL 语句问题

java.sql.SQLSyntaxErrorException：SQL 语句错误异常，一般有几种可能：

SQL 语句有错误，检查 SQL 语句！建议 SQL 语句在 SQL 工具中测试后再复制到 Java 程序中！
连接数据库的 URL 中，数据库名称编写错误，也会报该异常！

6.3 SQL 语句未设置参数问题

java.sql.SQLException：No value specified for parameter 1

在使用预编译 SQL 语句时，如果有 ? 占位符，要为每一个占位符赋值，否则报该错误！

6.4 用户名或密码错误问题

连接数据库时，如果用户名或密码输入错误，也会报 SQLException，容易混淆！所以一定要看清楚异常后面的原因描述！

6.5 通信异常

在连接数据库的 URL 中，如果 IP 或端口写错了，会报如下异常：

com.mysql.cj.jdbc.exceptions.CommunicationsException: Communications link failure