【MySQL】使用 JDBC 连接数据库

JDBC 连接数据库

文章目录

前言
1. 认识 JDBC
- 1.1 概念
- 1.2 好处
2. 使用 JDBC
- 2.1 安装数据驱动包
- 2.2 把 jar 包导入到项目中
- 2.3 代码编写
- 2.4 测试结果
3. 代码优化
4. 源码展示
结语

前言

在 MySQL 系列中，我们介绍了很多内容，包括但不限于建库建表，增删查改等等，但是这些操作都是直接在本机上的 MySQL 进行的，而在实际的开发过程中，我们很少会这样做，更多的是通过代码（C++、Java、Python……）来操作数据库的。今天我们就会简单介绍如何通过 Java 代码来操作数据库

1. 认识 JDBC

1.1 概念

JDBC（Java Database Connectivity）是一个 Java API，它提供了一种标准的方法，用于 Java 程序与各种数据库进行交互。简单来说，JDBC 是一个桥梁，使得 Java 应用程序能够执行 sql 语句，以查询、更新和管理数据库中的数据

1.2 好处

平台无关性：JDBC 使我们可以在任何支持 Java 的平台上运行的数据库访问代码，而无需关心底层数据库的类型
数据库无关性：JDBC 提供了统一的 API，使得我们可以使用相同的代码结构来访问不同类型的数据库，如 MySQL、Oracle、SQL Server 等
简化数据库访问：JDBC 简化了数据库访问的过程，我们不需要深入了解底层数据库的复杂性，就可以通过 JDBC 提供的接口轻松地执行数据库操作

2. 使用 JDBC

2.1 安装数据驱动包

所谓的数据驱动包，实际上就是包含了 JDBC 操作数据库的 API 的一个 jar 包，里面有很多的 .class 文件，我们可以在官网下载驱动包（https://dev.mysql.com/downloads/）

也可以在 Maven 中央仓库下载（https://mvnrepository.com/），此处我们简单演示一下在 Maven 下载数据驱动包

打开 Maven 网址，搜索栏输入“Mysql”，此时最上面会出现两个结果。因为博主使用的 MySQL 版本比较老，所以选择 “经典版”
点进去后就是各种版本的驱动包了。这里需要下载和你 MySQL 安装的版本一致才可，我的MySQL是 5.7 的，所以要选择 5.1 开头的，后面的小版本无所谓；如果你的 MySQL 是 8.x 版本的，那你就要选择 8 开头的驱动包了
博主这里选择 5.1.49 这个版本，点进去后下载 jar 包
这样就下载好啦~

2.2 把 jar 包导入到项目中

先新建一个 Java 项目，并在这个项目下右键建立一个目录，命名为 lib（注意不要带有中文/特殊字符）
接着找到我们下载好的 jar 包，直接复制然后粘贴到 lib 目录中（ctrl c 和 ctrl v 即可），点击 OK
然后右键 lib 目录，点击 add as library，再点击 OK 就行了。此时 idea 就能自动分析出 jar 包里有什么内容了
这样就大功告成啦

2.3 代码编写

1. 创建数据源：要连接数据库时，我们需要知道这个数据库的位置；我们可以通过 DataSource 对象来获取

        DataSource dataSource = new MysqlDataSource();
        ((MysqlDataSource)dataSource).setURL("jdbc:mysql://127.0.0.1:3306/javatest?characterEncoding=utf8&useSSL=false"); // “Javatest”是数据库名
        ((MysqlDataSource)dataSource).setUser("root");
        ((MysqlDataSource)dataSource).setPassword("xxxxxxxxx"); // 根据你安装是设置的密码填入

DataSourse 是 Java 中的一个接口，不能直接创建对象，因此我们使用 MysqlDataSource 这个子类来创建对象
接下来是 setURL( )、setUser( )、setPassWord( )，它们都是 MysqlDataSource 中的方法，分别服务器的 url（统一资源定位符）、服务器的账号、服务器的密码（）
此处我们还使用了向上转型和向下转型，目的是为了降低耦合。若之后我们使用的数据库不是 MySQL，那修改代码就十分方便

2. 和数据库服务器建立网络连接

Connection connection = dataSource.getConnection();

要注意此处的导入的包是 import java.sql.Connection 这个，不要选错了
此处的 Connection 对象，表示的就是一个数据库连接（抽象的客户端服务器连接）
此处的异常可以使用 throw 直接抛出

3. 构造 SQL 语句

比如我们现在想要在表中插入一条信息，就可以使用字符串来表示

String sql = "insert into student values ('qiqi', 77)";

接着使用 PreparedStatement 来预编译这个 sql 语句

PreparedStatement statement = connection.prepareStatement(sql);

我们写的 sql 语句就可以放在 statement 这个对象里面
预编译指的是它可以在客户端发送 sql 语句前，先解析一下，从而降低服务器的工作压力

4. 执行 SQL 语句

我们需要把 sql 发送到服务器上进行执行，可以使用 statement 里的方法

如果我们要执行的是增、删、改的操作，那就使用 executeUpdate 方法
```
statement.executeUpdate();
```
如果我们要执行的是查操作，那就使用 executeQuery 方法
```
statement.executeQuery();
```

5. 断开连接，释放资源

在进行类似的网络通信时，在使用完后一定要记得释放资源。我们上面创建了 connection 和 statement 两个对象，它们都需要释放，我们按照创造顺序的相反来关闭（先 statement，后 connection）

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

完整代码如下：

package jdbc;

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 TestUpdate {
    public static void main(String[] args) throws SQLException {
        //1.创建数据源对象(基本是默认的)
        DataSource dataSource = new MysqlDataSource();
        ((MysqlDataSource)dataSource).setURL("jdbc:mysql://127.0.0.1:3306/javatest?characterEncoding=utf8&useSSL=false");
        ((MysqlDataSource)dataSource).setUser("root");
        ((MysqlDataSource)dataSource).setPassword("xxxxxxxxx");

        //2.和数据库服务器建立网络连接(选择Connection java.sql包)
        Connection connection = dataSource.getConnection();
        //System.out.println(connection);//测试连接是否成功

        //3.构造sql语句(基于PreparedStatement预处理)
        String sql = "insert into student values ('qiqi', 77)";//写死的

        //4.把sql发送到服务器上进行执行
        //statement.executeQuery()查询
        //statement.executeUpdate()增删改
        int n = statement.executeUpdate();//影响的行数
        System.out.println(n);

        //5.释放上述资源(倒着释放)
        statement.close();
        connection.close();
    }
}

2.4 测试结果

最终打印 1，即影响的行数，表示插入成功

3. 代码优化

String sql = "insert into student values ('qiqi', 77)";//写死的

我们这里是把插入的 sql 给写死了，如果我们能够在控制台输入我们需要插入的信息，岂不美哉。因此得把代码修改一下

        //用户输入
        Scanner scanner = new Scanner(System.in);
        System.out.println("请输入姓名：");
        String name = scanner.nextLine();
        System.out.println("请输入分数：");
        int grade = scanner.nextInt();

		//修改sql语句
		String sql = "insert into a values ('"+ name +"',"+ grade +")";

这时候就可以通过控制台输入信息了。但是此处还有点小瑕疵，它有可能会引起 sql 注入攻击，别人可以通过代码直接拼接构造 sql 语句导致 sql 语句被恶意篡改（有一篇 2012 年的新闻报道了 sql 注入事件，感兴趣的可以看一下（网传技术流号牌遮挡能干掉交警数据库警方辟谣）
所以我们可以把 sql 语句再修改一下，使用占位符 “ ？”

String sql = "insert into a values (?,?)";//?为占位符

接着通过 statement 对象里面的 setInt() 和 setString() 方法来设置这两个字段，从而将这个 sql 语句构造完整，这样就能防止 sql 注入攻击啦

PreparedStatement statement = connection.prepareStatement(sql);
statement.setInt(1, id);
statement.setString(2, name);

补充：数据库的查找操作

上面我们提到了，如果我们要执行的是查操作，那就得使用 executeQuery 方法

除此之外，返回的结果也不一样：

如果是增、删、改操作的话，返回的就只是一个 int 类型的值，表示影响的行数，可以检验 sql 语句是否执行成功
但是对于查操作，它会返回一个结果集，也就是我们查询的结果，因此我们可以使用ResultSet 对象来进行接收，接着遍历里面的内容。最后也要记得关闭它哦
其他的代码就和上面的插入是一样的

package jdbc;

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 Testselect {
    public static void main(String[] args) throws SQLException {
        DataSource dataSource = new MysqlDataSource();
        ((MysqlDataSource)dataSource).setURL("jdbc:mysql://127.0.0.1:3306/javatest?characterEncoding=utf8&useSSL=false");
        ((MysqlDataSource)dataSource).setUser("root");
        ((MysqlDataSource)dataSource).setPassword("xxxxxxxxx");

        Connection connection = dataSource.getConnection();

        String sql = "select * from student";
        PreparedStatement statement = connection.prepareStatement(sql);

        //一个集合类，可以遍历得到
        ResultSet resultSet = statement.executeQuery();

        //遍历结果
        while (resultSet.next()) {
            System.out.println(resultSet.getString("name"));
            System.out.println(resultSet.getInt("grade"));
        }

        resultSet.close();
        statement.close();
        connection.close();
    }
}

运行结果如下：

4. 源码展示

插入操作

package jdbc;

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 TestUpdate {
    public static void main(String[] args) throws SQLException {
        //0.用户输入
        Scanner scanner = new Scanner(System.in);
        System.out.println("请输入姓名：");
        String name = scanner.nextLine();
        System.out.println("请输入分数：");
        int grade = scanner.nextInt();

        //1.创建数据源对象(基本是默认的)
        DataSource dataSource = new MysqlDataSource();
        ((MysqlDataSource)dataSource).setURL("jdbc:mysql://127.0.0.1:3306/javatest?characterEncoding=utf8&useSSL=false");
        ((MysqlDataSource)dataSource).setUser("root");
        ((MysqlDataSource)dataSource).setPassword("xxxxxxxxx");

        //2.和数据库服务器建立网络连接(选Connection java.sql包)
        Connection connection = dataSource.getConnection();
        //System.out.println(connection);//测试连接是否成功

        //3.构造sql语句(基于PreparedStatement预处理)
        //String sql = "insert into student values ('qiqi', 77)";//写死的
        //String sql = "insert into student values ('"+name+"',"+grade+")";
        //代码看起来乱，而且可能会被“sql注入攻击”---> ');drop database xxx;
        String sql = "insert into student values (?,?)";//?为占位符
        //String sql = "delete from a where name = ?";//删除也是一样
        PreparedStatement statement = connection.prepareStatement(sql); //预编译
        statement.setString(1,name); //1表示第一个问号
        statement.setInt(2,grade);

        //4.把sql发送到服务器上进行执行
        //executeQuery()查询
        //executeUpdate()增删改
        int n = statement.executeUpdate();//影响的行数
        System.out.println(n);

        //5.释放上述资源(倒着释放)
        statement.close();
        connection.close();
    }
}

查询操作

package jdbc;

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 Testselect {
    public static void main(String[] args) throws SQLException {
        DataSource dataSource = new MysqlDataSource();
        ((MysqlDataSource)dataSource).setURL("jdbc:mysql://127.0.0.1:3306/javatest?characterEncoding=utf8&useSSL=false");
        ((MysqlDataSource)dataSource).setUser("root");
        ((MysqlDataSource)dataSource).setPassword("xxxxxxxxx");

        Connection connection = dataSource.getConnection();

        String sql = "select * from student";
        PreparedStatement statement = connection.prepareStatement(sql);

        //一个集合类，可以遍历得到
        ResultSet resultSet = statement.executeQuery();

        //遍历结果
        while (resultSet.next()) {
            System.out.println(resultSet.getString("name"));
            System.out.println(resultSet.getInt("grade"));
        }

        resultSet.close();
        statement.close();
        connection.close();
    }
}

结语

今天我们介绍了如何使用 JDBC 连接数据库，通过代码来直接操作 MySQL 数据库，上面展示的操作方法还是比较粗糙的，而且随着技术的不断更新，我们也很少会直接使用 JDBC 了。但是理解上述的操作方法对我们来说肯定是有作用，在后续使用框架的时候，底层原理还是离不开这个操作思路的。接下来是博主的一些碎碎念 (●’◡’●)

一个月没写博客了，有点生疏，加上需要回顾前面的知识以及查阅资料，确实需要消耗更多的时间。不知道值不值得继续✍，但是总觉得学习完一个知识点后不总结篇博客就不得劲，自己写的东西到时候来回顾应该也更加得心应手吧。接下来我更加努力更新博客，加油 (ง •_•)ง

希望大家能够喜欢本篇博客，有总结不到位的地方还请多多谅解。若有纰漏，希望大佬们能够在私信或评论区指正，博主会及时改正，共同进步