import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.sql.Statement;
public class DCL {
public static void main(String[] args) {
Connection con=null;
Statement sta=null;
String sql="";
try {
Class.forName("com.mysql.jdbc.Driver");
con=DriverManager.getConnection("jdbc:mysql://126.0.0.1:3306/test,root,root");
con.setAutoCommit(false);
sta=con.createStatement();
sta.addBatch("update account set money=money-100 where card_id= '1234567890'");
sta.addBatch("update account set money=money+100 where card_id= '0987654321'");
sta.executeBatch();
con.commit();
} catch (Exception e) {
try {
con.rollback();
} catch (Exception e2) {
e2.printStackTrace();
}
e.printStackTrace();
}finally {
if(sta!=null) {
try {
sta.close();
} catch (Exception e) {
e.printStackTrace();
}
}
if(con!=null) {
try {
con.close();
} catch (Exception e) {
e.printStackTrace();
}
}
}
}
}
使用JDBC实现事务的回滚(只有代码,仍需补充)
猜你喜欢
转载自blog.csdn.net/qq_44724446/article/details/90176791
今日推荐
周排行