java jdbc 实现批量操作隔离性，核心在于关闭自动提交（auto-commit）并手动调用 commit()。通过 connection.setautocommit(false) 挂起事务，使用 statement.addbatch() 累积 sql，最后用 executebatch() 统一执行。若中途发生异常，调用 rollback() 可确保所有已添加的语句要么全部成功，要么全部回滚，从而保证原子性和隔离性。
如何配置连接以支持事务控制
要实现事务，必须显式禁用连接的自动提交模式。默认情况下，JDBC 连接是自动提交的，每条 SQL 都会立即生效，无法进行批量回滚。通过调用 setAutoCommit(false)，数据库会将后续操作视为一个逻辑单元，直到显式调用 commit() 或 rollback() 才结束该单元。这一步是开启事务管理的前提。
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
public class TransactionConfig {
public static void main(String[] args) {
String url = "jdbc:mysql://localhost:3306/test";
try (Connection conn = DriverManager.getConnection(url, "user", "pass")) {
// 关闭自动提交，开启事务上下文
conn.setAutoCommit(false);
System.out.println("Transaction started. Auto-commit is disabled.");
// 模拟业务逻辑...
// 确认提交
conn.commit();
System.out.println("Transaction committed successfully.");
} catch (SQLException e) {
// 异常时回滚
try {
if (conn != null) conn.rollback();
} catch (SQLException ex) {
ex.printStackTrace();
}
e.printStackTrace();
}
}
}
如何使用 Statement 进行批量处理
在事务上下文中，使用 Statement 或 PreparedStatement 的 addBatch() 方法将多条 SQL 语句加入队列。这些语句在内存中暂存，不会立即发送给数据库执行。当调用 executeBatch() 时，驱动程序会一次性将所有累积的语句发送给数据库服务器执行。这种机制减少了网络往返次数，提高了性能，同时因为处于同一事务中，所有语句共享同一个事务 ID，确保了操作的原子性。
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.sql.Statement;
public class BatchOperation {
public static void main(String[] args) {
String url = "jdbc:mysql://localhost:3306/test";
try (Connection conn = DriverManager.getConnection(url, "user", "pass")) {
conn.setAutoCommit(false);
Statement stmt = conn.createStatement();
// 添加批量语句
stmt.addBatch("INSERT INTO users (name) VALUES ('Alice')");
stmt.addBatch("INSERT INTO users (name) VALUES ('Bob')");
stmt.addBatch("UPDATE accounts SET balance = balance - 100 WHERE user_id = 1");
// 执行批量操作
int[] results = stmt.executeBatch();
conn.commit();
for (int result : results) {
System.out.println("Executed update count: " + result);
}
} catch (SQLException e) {
try {
if (e.getSQLState() != null && e.getSQLState().startsWith("40")) {
// 死锁等事务相关错误
}
throw e;
} finally {
// 实际项目中应更严谨地处理 rollback
}
}
}
}
批量操作中如何处理部分失败与回滚
在批量执行过程中，如果某条 SQL 语句失败（如违反约束、语法错误），executeBatch() 的行为取决于驱动和数据库。通常，它会抛出 BatchUpdateException。此时，之前已成功执行的语句在事务中依然有效，但整个事务尚未提交。开发者需要在 catch 块中捕获异常，检查 getUpdateCounts() 数组以确定哪些语句成功，然后决定是继续处理剩余语句还是调用 rollback() 撤销所有更改。对于强一致性要求，通常选择直接回滚，确保数据状态的一致性。
Java免费学习笔记：立即使用
解锁 Java 大师之旅：从入门到精通的终极指南
