1、声明式事务:@Transactional
2、编程式开启:
- 建立数据库连接
- 关闭自动提交,开启事务
- 执行sql
- 提交事务/回滚事务
- 关闭连接
Connection conn = null;
2
3try {
4 // 建立数据库连接
5 conn = DriverManager.getConnection(DB_URL, USER, PASS);
6 // 关闭自动提交,开启事务
7 conn.setAutoCommit(false);
8
9 // 执行SQL语句
10 PreparedStatement pstmt = conn.prepareStatement("INSERT INTO table_name (column1, column2) VALUES (?, ?)");
11 pstmt.setString(1, "value1");
12 pstmt.setInt(2, 123);
13 pstmt.executeUpdate();
14
15 // 如果一切顺利,提交事务
16 conn.commit();
17} catch (SQLException ex) {
18 // 发生错误时回滚事务
19 if (conn != null) {
20 try {
21 conn.rollback();
22 } catch (SQLException e) {
23 e.printStackTrace();
24 }
25 }
26 ex.printStackTrace();
27} finally {
28 // 清理资源
29 if (conn != null) {
30 try {
31 conn.close();
32 } catch (SQLException e) {
33 e.printStackTrace();
34 }
35 }
36}