7.1. JDBC简介

1. 什么是JDBC？
JDBC（Java Database Connectivity）是一个Java API，用于连接和执行SQL语句与关系型数据库进行交互。JDBC提供了一组接口和类，使Java程序能够与各种数据库通信，如MySQL、Oracle、PostgreSQL等。
2. JDBC的主要组件
JDBC主要由以下几个组件组成：

• DriverManager：负责加载数据库驱动，并建立与数据库的连接。
  
• Connection：表示与数据库的连接。
  
• Statement：用于执行SQL语句。
  
• PreparedStatement：用于执行预编译的SQL语句。
  
• ResultSet：表示查询结果集。
  

3. 连接数据库
在连接数据库之前，需要确保已经安装了相应的数据库驱动并将其添加到项目中。以下是一个简单示例，演示如何使用JDBC连接到MySQL数据库：
java
Copy

1. import java.sql.Connection;
2. import java.sql.DriverManager;
4. public class JdbcConnectExample {
5.     public static void main(String[] args) {
6.         try {
7.             // 加载数据库驱动
8.             Class.forName("com.mysql.cj.jdbc.Driver");
10.             // 连接到数据库
11.             String url = "jdbc:mysql://localhost:3306/mydb?useUnicode=true&characterEncoding=utf-8&useSSL=false&allowPublicKeyRetrieval=true";
12.             String username = "root";
13.             String password = "mypassword";
14.             Connection connection = DriverManager.getConnection(url, username, password);
16.             System.out.println("Connected to database!");
18.             // 关闭连接
19.             connection.close();
20.         } catch (Exception e) {
21.             e.printStackTrace();
22.         }
23.     }
24. }

复制代码

4. 执行SQL查询
要使用JDBC执行SQL查询，可以创建一个Statement对象，然后调用其executeQuery()方法。以下是一个简单示例，演示如何查询数据库中的数据：
java
Copy

1. import java.sql.Connection;
2. import java.sql.DriverManager;
3. import java.sql.ResultSet;
4. import java.sql.Statement;
6. public class JdbcQueryExample {
7.     public static void main(String[] args) {
8.         try {
9.             // 加载数据库驱动并连接到数据库
10.             Class.forName("com.mysql.cj.jdbc.Driver");
11.             String url = "jdbc:mysql://localhost:3306/mydb?useUnicode=true&characterEncoding=utf-8&useSSL=false&allowPublicKeyRetrieval=true";
12.             String username = "root";
13.             String password = "mypassword";
14.             Connection connection = DriverManager.getConnection(url, username, password);
16.             // 创建Statement对象并执行SQL查询
17.             Statement statement = connection.createStatement();
18.             String sql = "SELECT id, name FROM users";
19.             ResultSet resultSet = statement.executeQuery(sql);
21.             // 处理结果集
22.             while (resultSet.next()) {
23.                 int id = resultSet.getInt("id");
24.                 String name = resultSet.getString("name");
25.                 System.out.println("ID: " + id + ", Name: " + name);
26.             }
28.             // 关闭资源
29.             resultSet.close();
30.             statement.close();
31.             connection.close();
32.         } catch (Exception e) {
33.             e.printStackTrace();
34.         }
35.     }
36. }

复制代码

5. 执行SQL更新
要使用JDBC执行SQL更新（如插入、更新或删除），可以创建一个Statement对象，然后调用其executeUpdate()方法。以下是一个简单示例，演示如何向数据库中插入数据：
java
Copy

1. import java.sql.Connection;
2. import java.sql.DriverManager;
3. import java.sql.Statement;
5. public class JdbcUpdateExample {
6.     public static void main(String[] args) {
7.         try {
8.             // 加载数据库驱动并连接到数据库
9.             Class.forName("com.mysql.cj.jdbc.Driver");
10.             String url = "jdbc:mysql://localhost:3306/mydb?useUnicode=true&characterEncoding=utf-8&useSSL=false&allowPublicKeyRetrieval=true";
11.             String username = "root";
12.             String password = "mypassword";
13.             Connection connection = DriverManager.getConnection(url, username, password);
15.             // 创建Statement对象并执行SQL更新
16.             Statement statement = connection.createStatement();
17.             String sql = "INSERT INTO users (name, age) VALUES ('John Doe', 30)";
18.             int rowsAffected = statement.executeUpdate(sql);
20.             System.out.println("Rows affected: " + rowsAffected);
22.             // 关闭资源
23.             statement.close();
24.             connection.close();
25.         } catch (Exception e) {
26.             e.printStackTrace();
27.         }
28.     }
29. }
31. **6. 使用PreparedStatement**
33. `PreparedStatement`是一个预编译的`Statement`对象，可以提高SQL语句的执行效率。它还可以防止SQL注入攻击。以下是一个简单示例，演示如何使用`PreparedStatement`插入数据：
35. ```java
36. import java.sql.Connection;
37. import java.sql.DriverManager;
38. import java.sql.PreparedStatement;
40. public class JdbcPreparedStatementExample {
41.     public static void main(String[] args) {
42.         try {
43.             // 加载数据库驱动并连接到数据库
44.             Class.forName("com.mysql.cj.jdbc.Driver");
45.             String url = "jdbc:mysql://localhost:3306/mydb?useUnicode=true&characterEncoding=utf-8&useSSL=false&allowPublicKeyRetrieval=true";
46.             String username = "root";
47.             String password = "mypassword";
48.             Connection connection = DriverManager.getConnection(url, username, password);
50.             // 创建PreparedStatement对象并执行SQL更新
51.             String sql = "INSERT INTO users (name, age) VALUES (?, ?)";
52.             PreparedStatement preparedStatement = connection.prepareStatement(sql);
53.             preparedStatement.setString(1, "Jane Doe");
54.             preparedStatement.setInt(2, 28);
55.             int rowsAffected = preparedStatement.executeUpdate();
57.             System.out.println("Rows affected: " + rowsAffected);
59.             // 关闭资源
60.             preparedStatement.close();
61.             connection.close();
62.         } catch (Exception e) {
63.             e.printStackTrace();
64.         }
65.     }
66. }

复制代码

7. 事务处理
事务是一组逻辑操作单元，执行这些操作要么全部成功，要么全部失败。在JDBC中，可以使用Connection对象的commit()和rollback()方法进行事务处理。以下是一个简单示例，演示如何使用事务处理：
java
Copy

1. import java.sql.Connection;
2. import java.sql.DriverManager;
3. import java.sql.PreparedStatement;
5. public class JdbcTransactionExample {
6.     public static void main(String[] args) {
7.         Connection connection = null;
8.         PreparedStatement preparedStatement = null;
10.         try {
11.             // 加载数据库驱动并连接到数据库
12.             Class.forName("com.mysql.cj.jdbc.Driver");
13.             String url = "jdbc:mysql://localhost:3306/mydb?useUnicode=true&characterEncoding=utf-8&useSSL=false&allowPublicKeyRetrieval=true";
14.             String username = "root";
15.             String password = "mypassword";
16.             connection = DriverManager.getConnection(url, username, password);
18.             // 关闭自动提交（开启事务）
19.             connection.setAutoCommit(false);
21.             // 执行SQL更新
22.             String sql = "UPDATE users SET age = age + 1 WHERE id = ?";
23.             preparedStatement = connection.prepareStatement(sql);
24.             preparedStatement.setInt(1, 1);
25.             preparedStatement.executeUpdate();
27.             // 提交事务
28.             connection.commit();
29.             System.out.println("Transaction committed.");
30.         } catch (Exception e) {
31.             // 回滚事务
32.             try {
33.                 if (connection != null) {
34.                     connection.rollback();
35.                     System.out.println("Transaction rolled back.");
36.                 }
37.             } catch (Exception ex) {
38.                 ex.printStackTrace();
39.             }
40.             e.printStackTrace();
41.         } finally {
42.             // 关闭资源
43.             try {
44.                 if (preparedStatement != null) {
45.                     preparedStatement.close();
46.                 }
47.                 if (connection != null) {
48.                     connection.close();
49.                 }
50.             } catch (Exception e) {
51.                 e.printStackTrace();
52.             }
53.         }
54.     }
55. }

复制代码

8. 关闭资源
在JDBC中，需要确保及时关闭资源，如Connection、Statement和ResultSet等。可以使用close()方法或者Java 7中引入的try-with-resources语句进行资源关闭。以下是一个简单示例，演示如何使用try-with-resources关闭资源：
java
Copy

1. import java.sql.Connection;
2. import java.sql.DriverManager;
3. import java.sql.ResultSet;
4. import java.sql.Statement;
6. public class JdbcCloseResourceExample {
7.     public static void main(String[] args) {
8.         try {
9.             // 加载数据库驱动
10.             Class.forName("com.mysql.cj.jdbc.Driver");
12.             // 连接到数据库
13.             String url = "jdbc:mysql://localhost:3306/mydb?useUnicode=true&characterEncoding=utf-8&useSSL=false&allowPublicKeyRetrieval=true";
14.             String username = "root";
15.             String password = "mypassword";
17.             try (Connection connection = DriverManager.getConnection(url, username, password);
18.                  Statement statement = connection.createStatement()) {
20.                 // 执行SQL查询并处理结果集

复制代码

推荐阅读：
https://mp.weixin.qq.com/s/dV2JzXfgjDdCmWRmE0glDA
https://mp.weixin.qq.com/s/an83QZOWXHqll3SGPYTL5g


免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！