java jdbc 处理批量操作事务隔离级别的核心做法是调用 connection 对象的 settransactionisolation() 方法，并在执行完所有 addbatch() 和 executebatch() 后提交或回滚。jdbc 驱动会确保在事务期间，数据库连接上的隔离级别设置生效，从而保证批量操作的原子性和数据一致性。
JDBC 中如何设置事务隔离级别
通过 Connection.setTransactionIsolation(int level) 可以改变当前连接的隔离行为。常用的级别包括 TRANSACTION_READ_COMMITTED、TRANSACTION_REPEATABLE_READ 和 TRANSACTION_SERIALIZABLE。设置后，该连接上后续的所有 SQL 语句（包括批量插入）都将遵循新的隔离规则。
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.SQLException;
public class BatchTransactionExample {
public static void main(String[] args) {
String url = "jdbc:mysql://localhost:3306/testdb";
String user = "root";
String password = "password";
try (Connection conn = DriverManager.getConnection(url, user, password)) {
// 1. 关闭自动提交，开启事务
conn.setAutoCommit(false);
// 2. 设置事务隔离级别为可重复读
conn.setTransactionIsolation(Connection.TRANSACTION_REPEATABLE_READ);
String sql = "INSERT INTO users (name, email) VALUES (?, ?)";
try (PreparedStatement pstmt = conn.prepareStatement(sql)) {
for (int i = 0; i < 100; i++) {
pstmt.setString(1, "User" + i);
pstmt.setString(2, "user" + i + "@example.com");
pstmt.addBatch();
}
// 3. 执行批量操作
int[] results = pstmt.executeBatch();
// 4. 提交事务
conn.commit();
System.out.println("Batch insert completed successfully.");
} catch (SQLException e) {
// 5. 发生异常时回滚
conn.rollback();
e.printStackTrace();
}
} catch (SQLException e) {
e.printStackTrace();
}
}
}上述代码展示了标准的批量事务流程：先禁用自动提交，再设置隔离级别，接着填充批次并执行，最后根据结果决定提交或回滚。如果中间任何一步失败，rollback() 将撤销所有已执行的批量操作，确保数据不会部分写入。
立即学习“Java免费学习笔记（深入）”；
不同隔离级别对批量操作的影响
不同的隔离级别会影响并发环境下批量操作的表现。例如，READ_UNCOMMITTED 允许脏读，可能导致其他线程读取到未提交的中间状态；而 SERIALIZABLE 则通过严格的锁机制防止任何并发干扰，但可能降低吞吐量。在实际开发中，应根据业务需求选择合适的级别，平衡一致性与性能。
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
public class IsolationLevelComparison {
public static void main(String[] args) {
String url = "jdbc:mysql://localhost:3306/testdb";
String user = "root";
String password = "password";
try (Connection conn = DriverManager.getConnection(url, user, password)) {
conn.setAutoCommit(false);
// 设置为读已提交
conn.setTransactionIsolation(Connection.TRANSACTION_READ_COMMITTED);
String insertSql = "INSERT INTO orders (order_id, amount) VALUES (?, ?)";
try (PreparedStatement pstmt = conn.prepareStatement(insertSql)) {
pstmt.setInt(1, 1001);
pstmt.setDouble(2, 99.99);
pstmt.addBatch();
pstmt.executeBatch();
// 在同一事务中查询，确保看到自己写入的数据
String selectSql = "SELECT * FROM orders WHERE order_id = ?";
try (PreparedStatement pstmtSelect = conn.prepareStatement(selectSql);
ResultSet rs = pstmtSelect.executeQuery()) {
if (rs.next()) {
System.out.println("Order found: " + rs.getDouble("amount"));
}
}
}
conn.commit();
} catch (SQLException e) {
e.printStackTrace();
}
}
}此示例演示了在 READ_COMMITTED 级别下，同一事务内的查询能立即看到自己写入的数据，符合预期。若切换到 REPEATABLE_READ，则在整个事务期间，即使其他事务修改了数据，当前事务看到的也不会变化。开发者需根据是否允许不可重复读或幻读来选择合适配置。
批量操作中如何处理主键冲突
当批量插入涉及唯一约束字段（如主键）时，若出现重复值，数据库会抛出 SQLException。此时应捕获异常并决定是否跳过、重试或整体回滚。建议在插入前检查数据唯一性，或使用 INSERT IGNORE / ON DUPLICATE KEY UPDATE 等数据库特性来优雅处理冲突。
