一、啥是JDBC事务管理
咱先聊聊啥是JDBC事务管理。简单来说，JDBC就是Java用来和数据库打交道的一套工具。而事务管理呢，就像是给数据库操作加上了一个“保护罩”，把一组数据库操作当成一个整体，要么这一组操作都成功，要么都失败。就好比你去超市买东西，你选了一堆商品，最后结账的时候，要么这一单都能成功付款，东西都拿到手；要么一个都买不了，就跟这单交易没发生过一样。
在Java里，JDBC事务管理有手动和自动两种模式。自动模式下，每个SQL语句执行完就自动提交了，就像你买一件东西付一次钱。而手动模式呢，就需要我们自己来控制什么时候提交事务，什么时候回滚事务，就像你把所有东西都选好，最后一起结账。
二、手动事务的开启
要开启手动事务，其实很简单。在Java里，我们得先建立和数据库的连接，然后把自动提交的功能关掉。下面是一个示例，用的是Java技术栈：
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
public class ManualTransactionExample {
public static void main(String[] args) {
// 数据库连接信息
String url = "jdbc:mysql://localhost:3306/testdb";
String username = "root";
String password = "password";
Connection connection = null;
try {
// 加载数据库驱动
Class.forName("com.mysql.cj.jdbc.Driver");
// 建立数据库连接
connection = DriverManager.getConnection(url, username, password);
// 关闭自动提交，开启手动事务
connection.setAutoCommit(false);
System.out.println("手动事务已开启");
} catch (ClassNotFoundException e) {
e.printStackTrace();
} catch (SQLException e) {
e.printStackTrace();
} finally {
// 关闭连接
if (connection != null) {
try {
connection.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
}
}
}
在这个示例里，我们先加载了MySQL的驱动，然后建立了和数据库的连接。接着，通过connection.setAutoCommit(false)把自动提交关掉，这样就开启了手动事务。
三、事务提交
当我们开启手动事务后，对数据库进行了一系列操作，比如插入、更新、删除等，这些操作不会马上生效，而是要等我们手动提交事务。提交事务就相当于你在超市选好东西后去结账，确认这一单交易完成。
下面是一个包含事务提交的示例：
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.sql.Statement;
public class TransactionCommitExample {
public static void main(String[] args) {
String url = "jdbc:mysql://localhost:3306/testdb";
String username = "root";
String password = "password";
Connection connection = null;
Statement statement = null;
try {
Class.forName("com.mysql.cj.jdbc.Driver");
connection = DriverManager.getConnection(url, username, password);
connection.setAutoCommit(false);
// 创建Statement对象
statement = connection.createStatement();
// 执行插入操作
String insertQuery = "INSERT INTO users (name, age) VALUES ('John', 25)";
statement.executeUpdate(insertQuery);
// 提交事务
connection.commit();
System.out.println("事务已提交");
} catch (ClassNotFoundException e) {
e.printStackTrace();
} catch (SQLException e) {
// 发生异常，回滚事务
if (connection != null) {
try {
connection.rollback();
System.out.println("事务已回滚");
} catch (SQLException ex) {
ex.printStackTrace();
}
}
e.printStackTrace();
} finally {
// 关闭资源
if (statement != null) {
try {
statement.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
if (connection != null) {
try {
connection.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
}
}
}
在这个示例中，我们先开启了手动事务，然后执行了一个插入操作。最后，通过connection.commit()方法提交了事务，这样插入操作就生效了。如果在执行过程中发生了异常，我们就会调用connection.rollback()方法回滚事务，让数据库回到操作之前的状态。
四、事务回滚
事务回滚就像是你在超市选好东西后，突然不想买了，把东西都放回货架，这单交易就取消了。在Java里，当我们在事务执行过程中遇到错误，或者某些条件不满足时，就需要回滚事务。
下面是一个事务回滚的示例：
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.sql.Statement;
public class TransactionRollbackExample {
public static void main(String[] args) {
String url = "jdbc:mysql://localhost:3306/testdb";
String username = "root";
String password = "password";
Connection connection = null;
Statement statement = null;
try {
Class.forName("com.mysql.cj.jdbc.Driver");
connection = DriverManager.getConnection(url, username, password);
connection.setAutoCommit(false);
statement = connection.createStatement();
// 执行一个错误的SQL语句
String wrongQuery = "INSERT INTO non_existent_table (name, age) VALUES ('Jane', 30)";
statement.executeUpdate(wrongQuery);
// 提交事务
connection.commit();
} catch (ClassNotFoundException e) {
e.printStackTrace();
} catch (SQLException e) {
// 发生异常，回滚事务
if (connection != null) {
try {
connection.rollback();
System.out.println("事务已回滚，因为执行了错误的SQL语句");
} catch (SQLException ex) {
ex.printStackTrace();
}
}
e.printStackTrace();
} finally {
if (statement != null) {
try {
statement.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
if (connection != null) {
try {
connection.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
}
}
}
在这个示例中，我们执行了一个错误的SQL语句，试图向一个不存在的表中插入数据。当发生异常时，我们就调用connection.rollback()方法回滚事务，保证数据库不会因为这个错误操作而产生异常数据。
五、应用场景
银行转账
在银行转账的场景中，从一个账户扣款和向另一个账户存钱这两个操作必须作为一个事务来处理。如果只扣了款，而没有成功存钱，或者只存了钱，没有扣款，都会导致数据不一致。使用JDBC手动事务管理，我们可以确保这两个操作要么都成功，要么都失败。
订单处理
在电商系统中，当用户下单时，需要同时更新库存和生成订单记录。如果库存扣减成功，但订单记录生成失败，或者订单记录生成成功，但库存扣减失败，都会导致数据错误。通过手动事务管理，我们可以保证这两个操作的一致性。
六、技术优缺点
优点
- 数据一致性：手动事务管理可以确保一组数据库操作要么全部成功，要么全部失败，保证了数据的一致性。
- 灵活性：我们可以根据业务需求，灵活地控制事务的提交和回滚，满足不同的业务场景。
- 错误处理：在事务执行过程中，如果发生错误，可以及时回滚事务，避免数据错误。
缺点
- 复杂性：手动事务管理需要我们自己编写代码来控制事务的开启、提交和回滚，增加了代码的复杂性。
- 性能开销：事务的管理需要一定的性能开销，尤其是在高并发的情况下，可能会影响系统的性能。
七、注意事项
- 资源管理：在使用JDBC进行事务管理时，要注意及时关闭数据库连接、Statement和ResultSet等资源，避免资源泄漏。
- 异常处理：在事务执行过程中，要捕获并处理可能发生的异常，及时回滚事务，保证数据的一致性。
- 事务范围：要合理控制事务的范围，避免事务过长，影响系统的性能。
八、文章总结
通过本文，我们了解了Java中JDBC的手动事务管理，包括事务的开启、提交和回滚。手动事务管理可以帮助我们保证数据库操作的一致性，适用于一些对数据一致性要求较高的场景，如银行转账、订单处理等。同时，我们也了解了手动事务管理的优缺点和注意事项。在实际开发中，我们要根据业务需求合理使用手动事务管理，确保系统的稳定性和数据的一致性。
评论