事务的四大特性(ACID):
原子性(Atomicity):事务中所有操作是不可再分割的原子单位。事务中所有操作要么全部执行成功,要么全部执行失败。
一致性(Consistency):事务执行后,数据库状态与其它业务规则保持一致。如转账业务,无论事务执行成功与否,参与转账的两个账号余额之和应该是不变的。
隔离性(Isolation):隔离性是指在并发操作中,不同事务之间应该隔离开来,使每个并发中的事务不会相互干扰。
持久性(Durability):一旦事务提交成功,事务中所有的数据操作都必须被持久化到数据库中,即使提交事务后,数据库马上崩溃,在数据库重启时,也必须能保证通过某种机制恢复数据。
在默认情况下,每执行一条SQL语句,都是一个单独的事务。如果需要在一个事务中包含多条SQL语句,那么需要开启事务和结束事务。
开启事务:start transaction;
结束事务:commit或rollback。
在执行SQL语句之前,先执行strat transaction,这就开启了一个事务(事务的起点),然后可以去执行多条SQL语句,最后要结束事务,commit表示提交,即事务中的多条SQL语句所做出的影响会持久化到数据库中。或者rollback,表示回滚,即回滚到事务的起点,之前做的所有操作都被撤消了!
Connection的三个方法与事务相关:
(1) setAutoCommit(boolean):设置是否为自动提交事务,如果true(默认值就是true)表示自动提交,也就是每条执行的SQL语句都是一个单独的事务。
如果设置false,那么就相当于开启了事务了;con.setAutoCommit(false)表示开启事务。
(2) commit():提交结束事务;con.commit();表示提交事务。
(3) rollback():回滚结束事务。con.rollback();表示回滚事务。
jdbc处理事务的代码格式:
try {
con.setAutoCommit(false);//开启事务…
….
…
con.commit();//try的最后提交事务
} catch() {
con.rollback();//回滚事务
}
首先做一些准备工作:
(1)配置数据源,确定使用的数据库。详细信息见http://blog.csdn.net/qq_25827845/article/details/50836362
(2)在数据库中建立表account,并且插入数据
create table account
(
id int,
balance int,
)
select * from account
insert into account values (1,1000)
insert into account values (2,1000)
在程序中,首先是程序没有发生异常,则,转账成功。
当程序发生异常时,查询数据库,则会发现转账操作并没有完成。符合ACID特性。
Demo代码展示:
package com.ywq;import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.SQLException;public class Dao {
/**
* 修改指定用户的余额!
* @param ct
* @param id
* @param balance
*///同一事务中必须使用同一个Connection对象,所以此处的Connection对象由调用处传入。
public void updateBalance(Connection ct,int id,int balance){try {
String sql="update account set balance=balance+? where id=?";
PreparedStatement pt=ct.prepareStatement(sql);pt.setInt(1, balance);
pt.setInt(2, id);pt.executeUpdate();} catch (SQLException e) {throw new RuntimeException(e);
}}}
package com.ywq;import java.sql.*;public class Demo {public static void main(String[] args) {
zhuanZhang(1, 2, 100);}public static void zhuanZhang(int from, int to, int money) {
// 对事务的操作必须使用Connection对象!
Connection ct = null;
try {
Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");
ct=DriverManager.getConnection("jdbc:odbc:ywq");
System.out.println(ct);//开启事务
ct.setAutoCommit(false);Dao dao = new Dao();
dao.updateBalance(ct, from, -money);//给from减去相应金额if(true) {
//把此处的if语句块注释掉,则转账成功 throw new RuntimeException("不好意思,此处发生了异常,但是转账操作进行了一半,请观察结果");
}dao.updateBalance(ct, to, money);//给to加上相应金额//提交事务
ct.commit();
ct.close();
} catch(Exception e) {
//回滚事务
try {
ct.rollback();
ct.close();
} catch (SQLException e1) {
}
throw new RuntimeException(e);
}
}}