Java JDBC 批量操作事务三阶段提交
jdbc 本身不支持原生的三阶段提交（3pc），处理批量操作时通常采用两阶段提交（2pc）或本地事务管理。核心做法是关闭自动提交，将 sql 语句加入批次，执行后根据结果决定提交或回滚。若需实现类似 3pc 的增强可靠性，需在应用层引入协调者逻辑或使用支持 xa 协议的事务管理器。
使用 Statement.addBatch 与 Connection.commit
在单数据源场景下，通过 Connection.setAutoCommit(false) 开启事务，使用 Statement.addBatch() 累积 SQL，最后调用 executeBatch() 并 commit()。这是最标准的 JDBC 批量处理方式。
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.Statement;
public class JdbcBatchExample {
public static void main(String[] args) {
String url = "jdbc:mysql://localhost:3306/test";
String user = "root";
String password = "password";
try (Connection conn = DriverManager.getConnection(url, user, password)) {
// 1. 关闭自动提交
conn.setAutoCommit(false);
try (Statement stmt = conn.createStatement()) {
// 2. 添加批量 SQL
stmt.addBatch("INSERT INTO users (name) VALUES ('Alice')");
stmt.addBatch("INSERT INTO users (name) VALUES ('Bob')
stmt.addBatch("UPDATE users SET name='Charlie' WHERE id=1");
// 3. 执行批量
int[] results = stmt.executeBatch();
// 4. 提交事务
conn.commit();
System.out.println("Batch executed successfully. Results: " + java.util.Arrays.toString(results));
} catch (Exception e) {
// 5. 失败回滚
conn.rollback();
e.printStackTrace();
}
} catch (Exception e) {
e.printStackTrace();
}
}
}
上述代码中，executeBatch() 返回 int[]，每个元素表示对应 SQL 语句影响的行数。若某条语句失败，默认行为取决于驱动配置，但整个事务会因异常而进入回滚分支。
XA 事务与分布式协调
当涉及多个数据源时，JDBC 的本地事务无法保证跨库一致性。此时需使用支持 XA 协议的数据库驱动，并通过 javax.transaction.xa.XAResource 或 Spring 的 DataSourceTransactionManager / JtaTransactionManager 来管理分布式事务。虽然这本质仍是 2PC，但可通过引入协调者模拟 3PC 的部分特性（如预提交阶段）以提高可用性。
import javax.sql.XAConnection;
import javax.sql.XADataSource;
import javax.transaction.xa.XAResource;
import javax.transaction.xa.Xid;
import java.sql.Connection;
import java.sql.Statement;
public class XaBatchExample {
public static void main(String[] args) {
// 假设已配置 XADataSource
XADataSource xaDs = getXADataSource(); // 实际需从 JNDI 或容器获取
try {
XAConnection xaConn = xaDs.getXAConnection();
XAResource xaRes = xaConn.getXAResource();
Connection sqlConn = xaConn.getConnection();
// 生成唯一 XID
Xid xid = new SimpleXid(1, new byte[]{1}, new byte[]{1});
// 1. 开始事务分支
xaRes.start(xid, XAResource.TMNOFLAGS);
try (Statement stmt = sqlConn.createStatement()) {
stmt.addBatch("INSERT INTO orders (id) VALUES (1)");
stmt.executeBatch();
}
// 2. 结束事务分支（准备阶段）
xaRes.end(xid, XAResource.TMSUCCESS);
// 3. 预提交（Pre-commit，模拟 3PC 的预备阶段）
int prepareResult = xaRes.prepare(xid);
if (prepareResult == XAResource.XA_OK) {
// 4. 正式提交
xaRes.commit(xid, false);
} else {
xaRes.rollback(xid);
}
xaConn.close();
} catch (Exception e) {
e.printStackTrace();
}
}
}
在 XA 流程中，xaRes.prepare() 相当于 3PC 中的“预提交”阶段，用于确认资源是否可提交。若所有参与者都返回 XA_OK，则协调者发起 commit；否则任一参与者失败则触发 rollback。这种机制比传统 2PC 更具容错性，但仍非标准 3PC。
基于程序中某个输入、条件或结果的具体问题
当批量操作中某条 SQL 语法错误时，executeBatch() 的行为取决于 JDBC 驱动和数据库类型。例如 MySQL 驱动默认在遇到错误时抛出 BatchUpdateException，并中断后续执行；而 PostgreSQL 驱动可能继续执行剩余语句并返回部分成功结果。因此，必须检查 BatchUpdateException.getUpdateCounts() 以区分哪些语句成功、哪些失败，从而决定是否需要部分回滚或重试。
Java免费学习笔记：立即使用
解锁 Java 大师之旅：从入门到精通的终极指南
