JDBC可以通過以下步驟實(shí)現(xiàn)事務(wù):
1. 創(chuàng)建Connection對(duì)象:使用DriverManager.getConnection()方法創(chuàng)建一個(gè)Connection對(duì)象,該對(duì)象表示與數(shù)據(jù)庫(kù)的連接。
2. 關(guān)閉自動(dòng)提交:通過調(diào)用Connection對(duì)象的setAutoCommit(false)方法關(guān)閉自動(dòng)提交。
3. 執(zhí)行SQL語句:使用Connection對(duì)象創(chuàng)建Statement或PreparedStatement對(duì)象,然后執(zhí)行SQL語句。
4. 提交事務(wù):如果所有SQL語句都執(zhí)行成功,調(diào)用Connection對(duì)象的commit()方法提交事務(wù)。
5. 回滾事務(wù):如果有任何SQL語句執(zhí)行失敗,可以調(diào)用Connection對(duì)象的rollback()方法回滾事務(wù)。
6. 關(guān)閉連接:無論事務(wù)是否成功,都需要關(guān)閉Connection對(duì)象來釋放資源。
以下是一個(gè)簡(jiǎn)單的示例代碼:
```java
import java.sql.*;
public class TransactionExample {
public static void main(String[] args) {
Connection conn = null;
try {
// 創(chuàng)建Connection對(duì)象
conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/test", "username", "password");
// 關(guān)閉自動(dòng)提交
conn.setAutoCommit(false);
// 執(zhí)行SQL語句
Statement stmt = conn.createStatement();
stmt.executeUpdate("INSERT INTO table1 VALUES (1, 'value1')");
stmt.executeUpdate("INSERT INTO table2 VALUES (2, 'value2')");
// 提交事務(wù)
conn.commit();
System.out.println("事務(wù)執(zhí)行成功!");
} catch (SQLException e) {
// 回滾事務(wù)
if (conn != null) {
try {
conn.rollback();
} catch (SQLException ex) {
ex.printStackTrace();
}
}
e.printStackTrace();
} finally {
// 關(guān)閉連接
if (conn != null) {
try {
conn.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
}
}
}
```
在上述示例中,首先創(chuàng)建了一個(gè)Connection對(duì)象,然后關(guān)閉了自動(dòng)提交。接下來執(zhí)行了兩個(gè)INSERT語句,如果兩個(gè)語句都成功執(zhí)行,則提交事務(wù)。否則,將回滾事務(wù),并打印出異常信息。最后,關(guān)閉Connection對(duì)象。