java jdbc 实现数据合并的核心做法是关闭自动提交，将多条 sql 操作包裹在同一个事务中，并在所有步骤成功后显式调用 commit()，若中途发生异常则调用 rollback() 回滚。具体而言，通过 connection.setautocommit(false) 禁用自动提交，依次执行插入、更新或删除等语句，最后根据执行结果决定提交或回滚。这样做能确保要么所有数据变更全部生效，要么全部撤销，从而保证数据的一致性。
JDBC 事务的基本控制流程是怎样的
JDBC 事务控制依赖于 java.sql.Connection 对象的方法调用。默认情况下，JDBC 连接处于自动提交模式，每条 SQL 语句执行后立即持久化到数据库。要手动管理事务，必须首先调用 setAutoCommit(false)。随后，程序可以按顺序执行多个 SQL 语句。如果所有语句都成功执行，则调用 commit() 使更改永久生效。如果在执行过程中抛出 SQLException，则在 catch 块中调用 rollback() 以撤销自事务开始以来的所有更改。这种机制确保了原子性，即事务中的所有操作作为一个整体不可分割。
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.sql.Statement;
public class TransactionMergeExample {
public static void main(String[] args) {
String url = "jdbc:mysql://localhost:3306/mydb";
String user = "root";
String password = "password";
// 模拟两个账户之间的资金合并（转账）
int fromAccountId = 1;
int toAccountId = 2;
double amount = 100.0;
try (Connection conn = DriverManager.getConnection(url, user, password)) {
// 1. 关闭自动提交
conn.setAutoCommit(false);
try (Statement stmt = conn.createStatement()) {
// 2. 从源账户扣款
String updateFrom = "UPDATE accounts SET balance = balance - " + amount +
" WHERE id = " + fromAccountId;
int rowsUpdatedFrom = stmt.executeUpdate(updateFrom);
if (rowsUpdatedFrom == 0) {
throw new SQLException("源账户不存在或余额不足处理逻辑需前置检查");
}
// 3. 向目标账户加款
String updateTo = "UPDATE accounts SET balance = balance + " + amount +
" WHERE id = " + toAccountId;
int rowsUpdatedTo = stmt.executeUpdate(updateTo);
if (rowsUpdatedTo == 0) {
throw new SQLException("目标账户不存在");
}
// 4. 提交事务
conn.commit();
System.out.println("数据合并成功：账户 " + fromAccountId + " 向账户 " + toAccountId + " 合并了 " + amount);
} catch (SQLException e) {
// 5. 发生异常时回滚
conn.rollback();
System.err.println("数据合并失败，已回滚。错误信息：" + e.getMessage());
throw e;
}
} catch (SQLException e) {
e.printStackTrace();
}
}
}
如何处理事务中的异常以确保数据一致性
在事务执行过程中，任何一步 SQL 操作失败都会导致 SQLException 被抛出。此时，必须捕获该异常并立即调用 conn.rollback()。如果不进行回滚，数据库可能处于部分更新的状态，导致数据不一致。例如，在上述代码中，如果从源账户扣款成功，但向目标账户加款失败（如目标账户 ID 不存在），如果没有回滚，源账户的资金将丢失。因此，rollback() 是保证数据一致性的关键步骤。此外，建议使用 try-with-resources 或 finally 块来确保资源释放和事务状态的正确处理。即使在使用连接池的情况下，也必须在业务逻辑中显式管理事务边界，而不是依赖框架的隐式事务管理，除非明确配置了声明式事务。
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.sql.Statement;
public class TransactionRollbackTest {
public static void main(String[] args) {
String url = "jdbc:mysql://localhost:3306/mydb";
String user = "root";
String password = "password";
int fromAccountId = 1;
int toAccountId = 999; // 不存在的账户
double amount = 100.0;
try (Connection conn = DriverManager.getConnection(url, user, password)) {
conn.setAutoCommit(false);
try (Statement stmt = conn.createStatement()) {
// 第一步：扣款成功
String updateFrom = "UPDATE accounts SET balance = balance - " + amount +
" WHERE id = " + fromAccountId;
stmt.executeUpdate(updateFrom);
// 第二步：加款失败，因为目标账户不存在
String updateTo = "UPDATE accounts SET balance = balance + " + amount +
" WHERE id = " + toAccountId;
stmt.executeUpdate(updateTo); // 这里会抛出 SQLException
conn.commit(); // 这行代码不会执行
} catch (SQLException e) {
// 捕获异常并回滚
conn.rollback();
System.out.println("事务已回滚，数据保持一致。");
}
} catch (SQLException e) {
e.printStackTrace();
}
}
}
事务提交后如何验证数据合并结果
事务提交后，可以通过查询数据库来验证数据合并的结果。在上述示例中，可以分别查询源账户和目标账户的余额，确认源账户减少了指定金额，目标账户增加了相同金额。验证过程应在事务提交之后进行，以确保看到的是最新的数据状态。可以使用 SELECT 语句获取当前余额，并与预期值进行比较。如果数据一致，则说明事务管理正确；如果不一致，则可能存在并发问题或其他逻辑错误。在实际应用中，还可以结合日志记录或审计表来追踪事务的执行情况，以便在出现问题时进行排查。此外，对于高并发场景，可能需要考虑使用乐观锁或悲观锁来防止竞态条件，确保数据合并的准确性。
Java免费学习笔记：立即使用
解锁 Java 大师之旅：从入门到精通的终极指南
