文章目录
- 前言
- 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 了。但是理解上述的操作方法对我们来说肯定是有作用，在后续使用框架的时候，底层原理还是离不开这个操作思路的。接下来是博主的一些碎碎念 (●’◡’●)
一个月没写博客了，有点生疏，加上需要回顾前面的知识以及查阅资料，确实需要消耗更多的时间。不知道值不值得继续✍，但是总觉得学习完一个知识点后不总结篇博客就不得劲，自己写的东西到时候来回顾应该也更加得心应手吧。接下来我更加努力更新博客，加油 (ง •_•)ง
希望大家能够喜欢本篇博客，有总结不到位的地方还请多多谅解。若有纰漏，希望大佬们能够在私信或评论区指正，博主会及时改正，共同进步
