Java如何在JDBC中提交或回滚事务？
由于无效数据，有时执行诸如插入，更新或删除之类的数据库操作命令可能会引发异常。为了保护我们的应用程序数据的完整性，我们必须确保在事务失败时必须回退所有已执行的命令，以便它影响数据的状态。
在此示例中，我们使用MySQL数据库。要在MySQL中启用事务处理功能，请确保您使用的是InnoDB存储引擎来创建表。
package org.nhooo.example.jdbc;
import java.sql.*;
public class TransactionRollbackExample {
private static final String URL = "jdbc:mysql://localhost/nhooo";
private static final String USERNAME = "root";
private static final String PASSWORD = "";
public static void main(String[] args) throws Exception {
try (Connection conn =
DriverManager.getConnection(URL, USERNAME, PASSWORD)) {
conn.setAutoCommit(false);
String query = "INSERT INTO orders (username, order_date) " +
"VALUES (?, ?)";
try (PreparedStatement stmt = conn.prepareStatement(query,
PreparedStatement.RETURN_GENERATED_KEYS)) {
stmt.setString(1, "javaduke");
stmt.setDate(2, new Date(System.currentTimeMillis()));
stmt.execute();
ResultSet keys = stmt.getGeneratedKeys();
int orderId = 1;
if (keys.next()) {
orderId = keys.getInt(1);
}
//这是一条无效的语句，将导致
//演示回滚。
query = "INSERT INTO order_details (order_id, product_id, " +
"quantity, price) VALUES (?, ?, ?, ?, ?)";
PreparedStatement detailStmt = conn.prepareStatement(query);
detailStmt.setInt(1, orderId);
detailStmt.setInt(2, 1);
detailStmt.setInt(3, 10);
detailStmt.setDouble(4, 29.99);
detailStmt.execute();
//提交事务以将其标记为成功数据库操作
conn.commit();
System.out.println("Transaction commit...");
} catch (SQLException e) {
//由于发生异常而回滚任何数据库事务
conn.rollback();
System.out.println("Transaction rollback...");
e.printStackTrace();
}
}
}
}Maven依赖
<!-- https://search.maven.org/remotecontent?filepath=mysql/mysql-connector-java/8.0.17/mysql-connector-java-8.0.17.jar -->
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
<version>8.0.17</version>
</dependency>