JDBC事务处理-四大原则
原子性
一致性
隔离性
持久性
第一步：实现转账操作
假设在账户中，盖伦有余额5000元，赵信有余额2000元，
盖伦要向赵信转账1000元。
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
|
public static void outMoney(Connection conn,String name,int account) throws SQLException{
String sql="update t_account set balance=balance-? where name=?";
PreparedStatement pst=conn.prepareStatement(sql);
pst.setInt(1, account);
pst.setString(2, name);
int result=pst.executeUpdate();
pst.close();
}public static void inMoney(Connection conn,String name,int account) throws SQLException{
String sql="update t_account set balance=balance+? where name=?";
PreparedStatement pst=conn.prepareStatement(sql);
pst.setInt(1, account);
pst.setString(2, name);
int result=pst.executeUpdate();
pst.close();
} |
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
|
System.out.println("盖伦正在给赵信转账1000元");
//转账操作try {
outMoney(conn,"盖伦",1000);
inMoney(conn,"赵信",1000);
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}finally{
try {
System.out.println("转账成功！");
conn.close();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
} |
运行：
正常转账成功。
假设 public static void inMoney(Connection conn,String name,int account)运行时出现意外。
人为构造意外
然后运行程序
查看数据库的数据
盖伦少了1000元，赵信余额没有变！
这样，赵信就坑了！！！
【改进】
所需要的函数
con.setAutoCommit(false); // 取消自动提交
con.rollback(); // 回滚
con.commit(); // 提交事务
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
|
Connection conn=null;
try {
conn = dbUtil.getConnection();
System.out.println("盖伦正在给赵信转账1000元");
conn.setAutoCommit(false);//取消自动提交
outMoney(conn,"盖伦",1000);
inMoney(conn,"赵信",1000);
} catch (ClassNotFoundException e) {
e.printStackTrace();
} catch (SQLException e) {
try {
conn.rollback();//回滚
} catch (SQLException e1) {
e1.printStackTrace();
}
e.printStackTrace();
}finally{
try {
conn.commit();//提交
conn.close();
} catch (SQLException e) {
e.printStackTrace();
}
} |