三、使用jdbc连接mysql数据库【✔】

1、安装对应数据驱动包

那有同学就问了，数据驱动包是什么？

对于数据驱动包而言，其实就是上面我所说到的各个【数据库厂商】所提供给我们的JDBC驱动程序，因为只有数据库厂商那边提供给了我们加载数据库的驱动，我们才能去获取到数据库中的数据表然后进行CRUD等操作

• 这样说呢可能还不是很好理解，我们可以通过画图来帮助理解，知道了JDBC的工作原理后，我们还要去了解什么去驱动包

接下去就要去下载这个驱动包，去哪里下呢？当然是官网！

• 但是呢，官网很麻烦，你要一个个地去找，不知道要下那个才好，下面是MySQL的官网的驱动下载处，很好找。但若是你用的是Oracle数据库的话，就会很麻烦了，因为它们这家公司很大，产品也很多，所以官网中会很很多东西，你很难去找到自己想要的驱动程序

难道这就没办法了吗？要一个个找吗当然有，那就是我们心爱的【Maven】

• 对于Maven而言，学Java的同学一定不陌生，它是一个 “中央仓库”，Maven 作为 Java 项目管理工具，它不仅可以用作包管理，还有许多的插件，可以支持整个项目的开发、打包、测试及部署等一系列行为，简直是居家旅行、杀人灭口必备良药！
• 咳咳，然后我们就可以去下载MySQL对应的驱动包了，按照下图指示来即可

• 点进去之后就可以选择对应的驱动包版本了，但是这里在选择的时候要注意了，需要和你MySQL安装的版本一致才可，我的MySQL是5.7的，所以这里大版本不能变，要选择5.1开头的，后面的小版本没关系；当然如果你的MySQL是8.x版本的，你就要选择8开头的驱动包了

• 点进去之后我们看到有个jar，点一下它，你就可以拥有一个MySQL相关的驱动包了，就和我们平常使用的.rar、.zip压缩包没什么区别，就是Java的压缩包以.jar结尾

• 下载好了之后就是这个样子的

2、将jar包导入项目中

现在我们有了这个jar后，就要把它用起来

• 那现在我们去新建一个项目，然后把这个包导进来，不过在此之前要新建一个名为lib的目录，它是library库的缩写，当然你也可以写其他的名称

• 然后右键这个目录选择【添加为库…】

• 此时这个MySQL的驱动库就导入到我们的项目中了

3、编写代码连接数据库【⭐】

加载完MySQL的驱动包之后，我们就可以使用一些API去操作数据库了，准备好了吗，发车了:car:

1️⃣ 创建数据源

首先第一点，要连接数据库的话，我们就要知道这个数据库在哪里

• 这里我会介绍两种方式，一个是通过DataSource（数据源）对象获取，另一种则是通过DriverManager（驱动管理类）的静态方法获取，不过重点在于第一种

①DataSource（数据源）对象获取

• 下面是创建数据源的相关代码，我使用到了Java中的向上转型和向下转型，不是很清楚的同学可以先去了解一下

java复制代码DataSource dataSource = new MysqlDataSource();
((MysqlDataSource)dataSource).setURL("jdbc:mysql://127.0.0.1:3306/test?characterEncoding=utf8&useSSL=false");
((MysqlDataSource)dataSource).setUser("root");
((MysqlDataSource)dataSource).setPassword("xxxxxxxxxxx");

• 也就是这一句我使用到了向上转型，DataSource是Java中的一个接口，MysqlDataSource则是它的实现类，下面这种便是很典型的使用接口来实现==向上转型==

java复制代码DataSource dataSource = new MysqlDataSource();

• 然后下面的setURL()、setUser()、setPassWord()都是【MysqlDataSource】这个接口实现类中的一些方法，但是由于向上转型后父类无法去调用子类独有的方法，所以我们还要去进行一个==向下转型==
• 通过去进行一个强制类型转换就可以做到，此时我们便能调用到实现类中的方法了

java复制代码((MysqlDataSource)dataSource).setURL(...)
((MysqlDataSource)dataSource).setUser(...)
((MysqlDataSource)dataSource).setPassWord(...)

那有同学问：为什么要这么麻烦呢？转上又转下？直接使用MysqlDataSource不就好了

• 道理确实是这样，如果我们直接将代码写成下面这样子，那么就可以直接去调用这个类中的方法了，无需再去做一个向下转型，但是这却隐藏着巨大的隐患…

java复制代码MysqlDataSource dataSource1 = new MysqlDataSource();

可能没有真正做过开发的同学还体会不到这一点，因为我们在设计一些接口、类的时候始终要遵循【高内聚 · 低耦合】的思想，==即类的内部各个方法之间要紧密关联，但类与类之间不要产生太大的依赖==

• 光这么说可能说不太清楚，有兴趣的同学可以先去了解一下高内聚 · 低耦合
• 因为在上面我们使用的是【MysqlDataSource 】，所以在程序的其他方法中，我们可能也需要使用到这个类去做一个接受，就是因为这种==高内聚==的原因，导致了【MysqlDataSource 】被大量地进行扩散，此危害性就在于后续我们的项目要更换数据库的就需要改动很多的代码，加大了工作量！！！

java复制代码void func1(MysqlDataSource dataSource1){}
void func2(MysqlDataSource dataSource2){}

---

然后呢我们再来说说为什么要去调用这些API

• 首先的话是serURL()，对于【URL】来说，学习过HTTP协议的同学应该是非常熟悉，对于浏览器发送的HTTP请求中第一行就是URL，它叫做 统一资源定位符，也就是我们日常生活中所说的【网址】，描述了互联网上唯一一个资源的位置

我们可以来解读一下这个所传入的这个URL

• 那对于下面的User和PassWord就很清楚了，就是用户名和密码，MySQL用户名固定就是【root】，密码的话就是你安装MySQL的时候手动设置的密码。
• 虽然很多数据库是根据用户名和密码来进行认证的，但是有些数据库，向SQLite就不是用的这个进行认证，所以这就是为什么这些方法均在【MysqlDataSource 】里的原因了，每个数据库都有它们独特的验证方式，所以我们在使用不同数据库时加载不同的驱动包即可

2️⃣ 和数据库建立网络连接

在上面呢，我们只是进行了数据源的创建操作，只是描述了服务器在哪，并没有真正得进行访问，那现在我们所要做的操作就是【连接】，通过网络去进行一个通信

• 然后我们就可以通过【DataSource】接口中一个方法叫做getConnection()这个方法去建立一个网络连接，它会返回一个实例为【Connection】的对象，不过从下图可以看到很多种类的Connection，那我们选哪个呢？
• 这里要注意，选择这个java.sql的，这才是我们想要的Connection

java复制代码Connection connection = dataSource.getConnection();

• 要注意这里了连接（Connection），而不是链接（Link），对于连接而言并不复杂，因为只有这么一句代码，因为在网络中客户端和服务器之间要去建立一个连接，就只是找个地方记录下而已，并不需要非常繁琐的步骤
• 而且还要注意的是这个getConnection()还需要去处理异常，一般来说像我们在进行文件读取、数据库操作都是需要去捕获这个异常的，这里我直接【throws】了，你也可以【try..catch】，如果异常还不是很了解的同学再去学习一下

打个比方说，就像民政局登记结婚一样，只是找个地方登记一下我们结婚了，也无需像婚礼那样大动干戈

②DriverManager（驱动管理类）的静态方法获取

讲了这么多，别忘了我们只讲了一种数据库连接方式，别忘了还有第二种，那就是使用DriverManager

• 但是我并不打算讲解这种方式，因为它需要借助我们在JavaSE中所学习的【反射】，但是对于反射来说其实是不属于常规的编程手段，不在特殊的情况下还是不推荐使用的。你可以在看了下面这两种连接方式的区别后再来回顾

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

区别：

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

可能有同学对这个【数据库连接池】不太理解，我们这里来讲一讲（doge）

• 在Java中呢我们学习过很多的池，比方说：String字符串常量池、进程池、线程池、内存池，它们都是池
• 那谈到池这个东西我们就想到了【池塘】，那假设呢你现在是个妹子，长得好看，又有才华，所以追求者就与很多，但是呢同一时间只能谈一个对象，但是你又不想拒绝其他的追求者，因为如果当前这个对象谈到后面谈不来的话，就需要再换一个，此时的话就会有很多的成本，因为需要重新培养感情

• 那于是你就想了一个很不错的办法来提高效率，那就是【养鱼】
• 怎么养鱼呢？也就是在和A谈对象的同时和B搞暧昧，同时培养感情基础，一旦你和A分手了，就可以立马和B在一起，此时大大提高了效率，那么这个B就被亲切地称之为【备胎】

• 但是你的备胎可能还不只B这一个，可能还有CDEFGHI…..，此时它们就构成了一个“备胎池”，若是B不合适了还可以换其他人上位，而且呢，这个时候A也还在池子里，若是你和其他人都不和的时候，又想到A了，此时你就可以再和A在一起

当然，上面只是举一个小小的案例，现实生活中我们不提倡这么去做~ 但是在计算机里这种做法还是很常见的，可以了解一下

3️⃣ 构造SQL语句

接下去呢，我们就要去构造SQL语句了

• 首先定义一个字符串表示一条插入语句

sql复制代码String sql = "insert into student values (1, 'zhansan')";

• 但是呢有这条语句还不够，在JDBC中，我们还需要搭配一个对象去描述这里的sql情况

java复制代码PreparedStatement statement = connection.prepareStatement(sql);

这里主要讲一下这个PreparedStatement ，可能有很多同学看懵了。首先对于【startment】对象来说，是将SQL语句发送到数据库中。JDBC API中主要提供了三种Statement对象

1. Statement
2. PreparedStatement
3. CallableStartment

不过我们在工作中用得最多的还是PreparedStatement，字面意思的话就是【预处理语句】

• 对于PreparedStatement来说，它其实在底层帮我们做了许多事情，不过这里不做详解，有兴趣的同学可以去了解一下 Java数据库JDBC——prepareStatement的用法和解释

4️⃣ 执行SQL语句

在构造完SQL语句后，我们就可以去通过这个statement对象去执行SQL语句了

• 只需要调用这个类中的executeUpdate()即可，如果你要执行的SQL语句是【增】、【删】、【改】操作的话，那么你的SQL执行语句就写下面这一条就可以了

java复制代码statement.executeUpdate();

• 但若是你执行的是【查】操作的话，结果就不是这样了，而是要写成下面这句

java复制代码statement.executeQuery();

5️⃣ 断开连接，释放资源

当然在执行完了之后还要再断开连接，释放掉必要的资源

• 可以看到我们上面所创建出来的两个对象connection和statement，但是你自己观察就可以发现我在关闭资源的时候是反着来的，这就是因为==资源释放的顺序和创建的顺序是相反的==

java复制代码statement.close();
connection.close();

• 如果读者学习过C++的话就会很好理解了，因为C++类和对象中存在【析构函数】，对象销毁的时候是存在顺序的；但是因为Java中有GC（垃圾自动回收机制），所以我们一般不需要自己去释放申请的空间，编译器会去做这件事的

这里我还是来讲一下这个构造析构的顺序，帮助读者来进行理解

• 不知道你去过东北没有，反正那边是冬天是挺冷的❄，零下三四十度，不过北方的房子还是很有意思的，一般我们家里都是只有一个院子的，但是在北方一般都有两个院子，而且有两个门，你跨入第一个门相当于进入外院，再跨一个门才算是进入了内院（主院）
• 那此时也就是意味着你要进入内院的话就需要先通过【大门】，然后再通过【二门】；但若是你要出来的话肯定就得先通过【二门】，才能到达【大门】（假设你不会飞）
• 那通过上面这样已说明，相信你对构造、析构的这么一个过程很熟悉了，后构造的对象就需要先析构才可以

4、测试观察

写好了JDBC连接MySQL数据库的代码逻辑，接下去我们就来测试一下是否真的可以去操作数据库

• 首先可以看到的是当前这个数据表studennt中是不存在任何记录的

• 然后我们到IDEA中去执行一下这段代码的话就可以看到ret的结果为1，表名SQL语句执行成功

• 然后我们再到数据库中去查看的时候就可以发现有一条记录被插入进来了，这也就实现了用JDBC去操作数据表的功能

如果你是第一次看到的话，一定会觉得很神奇，就像我在第一次看到后端代码可以与前端进行交互的时候，我也很吃惊；现在又看到可以通过后端的代码来操作数据库，又让我觉得耳目一新

5、代码优化

上面只是做了基本的测试，代表我们的代码可以去连接到数据库，但是这份代码还不够【完善】，我们再来完善一下~

1️⃣灵活变通SQL

• 这是我们写的SQL语句，但你是否觉得这样去写太死了，通常我们在操作数据库的时候都会写很多SQL语句，是非常灵活的，但是就下面这样的话确实是不太好

java复制代码String sql = "insert into student values (1, 'zhansan')";

• 所以我们可以将代码改为下面这样，记录中的【学号】和【姓名】字段我们可以通过自己输入来进行控制

java复制代码// 3.输入学号和姓名
System.out.println("请输入学号：");
Scanner sc1 = new Scanner(System.in);
int id = sc1.nextInt();
System.out.println("请输入姓名：");
Scanner sc2 = new Scanner(System.in);
String name = sc2.next();

// 4.构造一个 SQL 语句，来完成插入操作
//String sql = "insert into student values (1, 'zhansan')";
String sql = "insert into student values (" + id + ", '" + name + "')";

• 此时我们通过控制台去进行输入就后构造出SQL语句然后执行就可以发现也是可以插入一条记录的，

2️⃣防止SQL注入攻击

但是对于上面这样的SQL语句构造你可以看出来是比较丑的，不方便阅读与理解，不仅如此，它还容易引起【SQL注入攻击】

• 可能有的同学不太清楚这个【SQL注入攻击】，它是黑客入侵服务器的一种形式，黑客可以通过代码直接拼接构造sql语句导致sql语句结构可被恶意篡改，有兴趣的同学可以去了解一下 链接

对于上面这种危害，我们进行预防最靠谱的方案，就是使用PreparedStatement中占位符替换的方式，来实现SQL的构造~

• 我们可以把SQL语句构造成下面这样，两个【?】就相当于是占位符

java复制代码String sql = "insert into student values (?, ?)";       //通过占位符进行替换

• 还记得我们上面使用到的那个statement对象吗，它可以用来描述SQL的情况，我们可以通过里面的【setInt()】和【setString()】方法来设置记录中的两个字段，从而将这个SQL语句构造完整

java复制代码// jdbc中还需要搭配一个特定的对象，来搭配描述这里的sql情况
PreparedStatement statement = connection.prepareStatement(sql);
statement.setInt(1, id);
statement.setString(2, name);

• 然后再去运行的话就可以看到也是可以把记录插入到数据表中的

对于上面这种形式，就是较为安全的SQL语句写法，代码会在文末给出，可供读者参考

6、SQL查找的写法

上面的话就只是SQL的插入，学习过CRUD的同学们一定还会其他操作，对于【删除】、【修改】的话和插入是一模一样的，只需要修改一下SQL语句的构造即可。

但是对于【查找】操作就不一样了，和上面的这些操作相比，多了一个遍历结果集

• 首先的话我们要去修改一下SQL语句，改为查询的语句

java复制代码String sql = "select * from student";

• 然后在执行SQL语句的时候就不能写成executeUpdate()了，而是要写成executeQuery()，而且返回的结果也不一样，若是【增】、【删】、【改】的话返回的就只是一个【int】类型的值，表示SQL语句是否执行成功
• 但是对于【查】的话就不一样了，因为一个数据表中的记录不止一条，所以它查找就会返回一个结果集，我们要使用[ResultSet]来进行接受

java复制代码ResultSet ret = statement.executeQuery();

• 那既然这是一个集合的话，我们要看到里面的内容就要去进行一个遍历的操作，此时，和【迭代器】的遍历很相似，通过ret.next()去进行判断是否还有下一条记录需要遍历即可，内部去获取到记录中的相关字段，然后显示打印出来即可

java复制代码while(ret.next())
{
    int id = ret.getInt("id");
    String name = ret.getString("name");
    System.out.println("id = " + id + "; name = " + name);
}

• 执行程序就可以看到，遍历出了这张表中的所有内容

四、整体代码展示

上面就是通过JDBC连接数据库的这么一套流程，你学会了吗

JDBC往数据表插入记录

java复制代码public class JDBCInsertDemo {
    public static void main(String[] args) throws SQLException {
        /**
         * 使用 JDBC 往数据库中插入一个记录
         * 需要提前准备好数据库(java106) 和 数据表(student)
         */

        // 1.创建数据源，描述了数据库服务器在哪
        DataSource dataSource = new MysqlDataSource();
        ((MysqlDataSource)dataSource).setURL("jdbc:mysql://127.0.0.1:3306/test?characterEncoding=utf8&useSSL=false");
        ((MysqlDataSource)dataSource).setUser("root");
        ((MysqlDataSource)dataSource).setPassword("panjialie1218");

        // 2.和数据库建立网络连接 (写JDBC实际上是实现一个MySQL客户端，通过网络和服务器进行通讯)
        Connection connection = dataSource.getConnection();

        // 3.输入学号和姓名
        System.out.println("请输入学号：");
        Scanner sc1 = new Scanner(System.in);
        int id = sc1.nextInt();
        System.out.println("请输入姓名：");
        Scanner sc2 = new Scanner(System.in);
        String name = sc2.next();

        // 4.构造一个 SQL 语句，来完成插入操作
        //String sql = "insert into student values (1, 'zhansan')";     -- 太死板
        //String sql = "insert into student values (" + id + ", '" + name + "')";   -- 会SQL注入攻击
        String sql = "insert into student values (?, ?)";       //通过占位符进行替换
        // jdbc中还需要搭配一个特定的对象，来搭配描述这里的sql情况
        PreparedStatement statement = connection.prepareStatement(sql);
        statement.setInt(1, id);
        statement.setString(2, name);

        // 5.执行 SQL 语句 (控制客户端给服务器发送请求)
        int ret = statement.executeUpdate();
        System.out.println("ret = " + ret);

        // 6.断开和数据库的连接，并且释放掉必要的资源
        statement.close();
        connection.close();
    }
}

JDBC查询数据表记录

java复制代码public class JDBCSelectDemo {
    public static void main(String[] args) throws SQLException {
        /**
         * 使用 JDBC 往数据库中插入一个记录
         * 需要提前准备好数据库(java106) 和 数据表(student)
         */

        // 1.创建数据源，描述了数据库服务器在哪
        DataSource dataSource = new MysqlDataSource();
        ((MysqlDataSource)dataSource).setURL("jdbc:mysql://127.0.0.1:3306/test?characterEncoding=utf8&useSSL=false");
        ((MysqlDataSource)dataSource).setUser("root");
        ((MysqlDataSource)dataSource).setPassword("panjialie1218");

        // 2.和数据库建立网络连接 (写JDBC实际上是实现一个MySQL客户端，通过网络和服务器进行通讯)
        Connection connection = dataSource.getConnection();

        // 3.构造一个 SQL 语句，来完成插入操作
        String sql = "select * from student";
        // jdbc中还需要搭配一个特定的对象，来搭配描述这里的sql情况
        PreparedStatement statement = connection.prepareStatement(sql);

        // 5.执行 SQL 语句 (控制客户端给服务器发送请求)
        ResultSet ret = statement.executeQuery();
        while(ret.next())
        {
            int id = ret.getInt("id");
            String name = ret.getString("name");
            System.out.println("id = " + id + "; name = " + name);
        }

        // 6.断开和数据库的连接，并且释放掉必要的资源
        statement.close();
        connection.close();
    }
}

五、总结与提炼

最后来总结一下本文所学习的内容:book:

• 在本文中，我们首先了解了JDBC的概念以及其相关工作原理，然后的话就通过调用这些JDBC相关的API去加载MySQL数据库的驱动，一步步地去创建数据源、建立连接、构造与执行SQL语句，最后释放连接，完成了通过后端代码去操作数据库，成功往数据表中插入了一条记录
• 接下去呢我们又对代码去进行了一个优化，既提高了代码的灵活性，还可以防止SQL注入攻击，加固了代码的安全性。然后又完成了查询数据表的相关记录的操作，需要涉及对集合的遍历

可能本文的读者不会很多，但如果你读到这里的话那我要和你说一个事实：因为现在几乎都不用JDBC了，市面上有一个很成熟的框架叫做【MyBatis】，它是⼀款优秀的持久层框架，它⽀持⾃定义 SQL、存储过程以及⾼级映射，但是其底层的实现还是基于JDBC的。框架都是层出不穷的，唯有内部核心是永恒不变的，学到底层才是关键。

tcp syn_sent 状态错误问题如何解决完整攻略（图文详解1）