系列文章目录
目录
前言
本文介绍了MySQL数据库的JDBC操作流程，包括前置知识、写操作和读操作的实现步骤。内容涵盖：1）如何创建Maven项目并引入MySQL依赖；2）URL格式解析；3）JDBC写操作流程（创建数据源、建立连接、构造SQL、执行更新、释放资源）；4）使用PreparedStatement防止SQL注入；5）JDBC读操作流程（执行查询、处理ResultSet结果集）。文章通过代码示例详细演示了插入、查询等基本操作，并强调了资源释放的顺序和SQL语句参数化的安全性考虑。
一、前置知识
1. 引入依赖
创建 Maven 项目，同时在 Maven Respository 中找到 MySQL 的依赖，在 Maven 项目中引入；
<dependencies>
<!-- https://mvnrepository.com/artifact/mysql/mysql-connector-java -->
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
<version>5.1.49</version>
</dependency>
</dependencies>2. 认识 url
url 是资源在网路上的位置；
以下面 url 为例：
jdbc:mysql://127.0.0.1:3306/myjdbc?characterEncoding=utf8&useSS=false
jdbc:mysql 表示 url 的作用，是给 jdbc 操作 mysql 的；
127.0.0.1 表示 IP 地址，描述网络上主机所在的位置；
3306 表示端口号，代表操作网络的应用程序；
myjdbc 表示数据库名；
characterEncoding=utf8 指定字符集为 utf8；
useSS=false 表示设置为不加密；
? 前面表示资源，后面表示访问资源的参数；
& 表示参数间的分隔符，多个参数使用这个符号分割；
二、JDBC 操作流程
1. JDBC 的写操作
1. 创建数据源，设置好 url，用户名和密码；
2. 建立和数据库服务器的连接；
3. 构造 sql，使用 JDBC 操作数据库仍然需要手动构造 sql；
构造完 sql 之后需要预处理 sql 语句，目的是检查 sql 编写是否正确，避免直接发给服务器，导致服务器报错，浪费服务器资源；
除了检查 sql 是否正确，还会解析 sql 得到结构化的数据，直接把解析好的结构化数据发给数据库服务器，服务器就省下了这部分解析的工作；
4. 把 sql 发给服务器，服务器返回受到影响的行数；
5. 关闭连接，释放资源；先获得的资源后释放，后获得的资源先释放；
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 Demo1 {
public static void main(String[] args) throws SQLException {
// 1. 创建数据源
DataSource dataSource = new MysqlDataSource();
((MysqlDataSource)dataSource).setUrl("jdbc:mysql://127.0.0.1:3306/myjdbc?characterEncoding=utf8&useSSL=false");
// 设置用户名和密码
((MysqlDataSource)dataSource).setUser("root");
((MysqlDataSource)dataSource).setPassword("123456");
// 2. 建立和数据库服务器之间的连接
Connection connection = dataSource.getConnection();
// 3. 构造 sql
String sql = "insert into student values(1, '张三')";
// 预处理 sql 语句
PreparedStatement statement = connection.prepareStatement(sql);
// 4. 把 sql 发给服务器
int n = statement.executeUpdate();
// 5. 关闭连接，释放资源
statement.close();
connection.close();
}
}更新和删除记录的操作和插入的操作步骤相同，只需要更改 sql 语句；
注意：
为了解决 sql 写死的问题，代码中的 sql 是可以拼接参数的；
但是字符串中拼接上参数，容易被注入 sql 攻击，为了避免被注入 sql，可以使用占位符 “?”，再调用 PreparedStatement 的 setInt(), setString() 等方法进行替换；
// 3. 构造 sql
//String sql = "insert into student values(" + id + ", '" + name +"')";
String sql = "insert into student values (?, ?)";
// 预处理 sql 语句 - 检查 sql 是否存在问题
PreparedStatement statement = connection.prepareStatement(sql);
statement.setInt(1, id);
statement.setString(2, name);2. JDBC 的读操作
读操作和写操作的主要区别：
1. sql 语句：需要编写查询语句；
2. 执行 sql 的方法：executeQuery()；
3. 执行 sql 语句的返回值：返回的结果集的类型为 ResultSet；
ResultSet 默认指向第 0 行记录的前一个位置，调用 next() 方法，才会指向第 0 行记录；
如果 next() 指向的地方有数据记录，返回 true，否则返回 false；
4. 获取数据记录的列需要使用 getInt()，getString() 等方法，取决于列的数据类型，括号中填写要获取临时表的列名，如果使用别名，就写别名；
5. 关闭资源时，要注意关闭 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;
// jdbc 查询
public class Demo2 {
public static void main(String[] args) throws SQLException {
// 1. 创建数据源
DataSource dataSource = new MysqlDataSource();
((MysqlDataSource) dataSource).setUrl("jdbc:mysql://127.0.0.1:3306/myjdbc?characterEncoding=utf8&useSSL=false");
((MysqlDataSource) dataSource).setUser("root");
((MysqlDataSource) dataSource).setPassword("123456");
// 2. 建立连接
Connection connection = dataSource.getConnection();
// 3. 编写 sql 语句
String sql = "select * from student";
PreparedStatement statement = connection.prepareStatement(sql);
// 4. 执行 sql 语句
ResultSet resultSet = statement.executeQuery();
// 5. 遍历结果集合
// 通过 next() 方法，可以获取临时表的每一行数据，执行到最后一行的下一行会返回 false
while(resultSet.next()){
int id = resultSet.getInt("id");
String name = resultSet.getString("name");
System.out.println("id = " + id + ", name = " + name);
}
// 6. 释放资源
resultSet.close();
statement.close();
connection.close();
}
}注意：读操作同样可以使用占位符，后续用变量去替换；