數據庫事物操作

事務

什么是事務?
轉賬：
1. 給wc賬戶減1000元
2. 給wcxf賬戶加1000元

當給wc賬戶減1000元后，拋出了異常！這會怎么樣呢？我相信從此之后，wc再也不敢轉賬了。

使用事務就可以處理這一問題：把多個對數據庫的操作綁定成一個事務，要么都成功，要么都失敗！

---------------------------------------------------------------------------------------------------------------------------------------------

事物的特性：ACID

* 原子性：事務中所有操作是不可再分割的原子單位。事務中所有操作要么全部執行成功，要么全部執行失敗。
* 一致性：事務執行后，數據庫狀態與其它業務規則保持一致。如轉賬業務，無論事務執行成功與否，參與轉賬的兩個賬號余額之和應該是不變的。
* 隔離性：隔離性是指在并發操作中，不同事務之間應該隔離開來，使每個并發中的事務不會相互干擾。
* 持久性：一旦事務提交成功，事務中所有的數據操作都必須被持久化到數據庫中，即使提交事務后，數據庫馬上崩潰，在數據庫重啟時，也必須能保證通過某種機制恢復數據。

---------------------------------------------------------------------------------------------------------------------------------------------

MySQL操作事務

1. 開始事務：start transaction
2. 結束事務：commit//提交事物rollback//事物回滾

（1）事物回滾

（2）事物提交

?

?

---------------------------------------------------------------------------------------------------------------------------------------------

JDBC事務

1. 開始事務：con.setAutoCommit(false);
2. 結束事務；con.commit()或con.rollback();

?

public class Jdbc2 {public static void main(String[] args) {Connection con=null;PreparedStatement pst=null;try {con = JDBCUtils.getConnection();//開啟事物con.setAutoCommit(false);//開啟手動事物pst=con.prepareStatement("UPDATE  acction SET mun=mun-100 WHERE username=? ");pst.setString(1, "zhangsan");pst.executeUpdate();//人為創建異常int index=1/0;pst=con.prepareStatement("UPDATE  acction SET mun=mun+100 WHERE username=? ");pst.setString(1, "wangwu");pst.executeUpdate();con.commit();//提交事物
            } catch (Exception e) {try {con.rollback();} catch (SQLException e1) {e1.printStackTrace();}e.printStackTrace();}finally{//關閉JDBCUtils.createClose(null, pst, con);}}
}

?

?

?

---------------------------------------------------------------------------------------------------------------------------------------------

保存點

保存點的是可以回滾到事務中的某個位置，而不是回滾整個事務。
回滾到保存點不會結束事務。
設置保存點：Savepoint sp = con.setSavepoint();
回滾到保存點：con.rollback(sp);

public class Jdbc1 {public static void main(String[] args) {Connection con=null;PreparedStatement pst=null;Savepoint sp=null;try{con = JDBCUtils.getConnection();con.setAutoCommit(false);//手動開啟事物sp=con.setSavepoint();pst=con.prepareStatement("INSERT INTO acction(username,mun) VALUES(?,?)");for(int i=1;i<=2000;i++){if(i==1002){int index=i/0;}pst.setString(1, "lxp");pst.setInt(2, i);pst.executeUpdate();if(i%1000==0){sp=con.setSavepoint();} }con.commit();//事物提交}catch(Exception e){try {con.rollback(sp);con.commit();} catch (SQLException e1) {// TODO Auto-generated catch block
                e1.printStackTrace();}//回滾事物
              e.printStackTrace();}finally{JDBCUtils.createClose(null, pst, con) ;}}

---------------------------------------------------------------------------------------------------------------------------------------------

事務隔離級別

* 臟讀：讀到未提交

* 不可重復讀：兩次讀取不一致，讀取到另一事務修改的記錄

* 幻讀：兩次讀取不一致，讀取到另一事務插入的記錄

---------------------------------------------------------------------------------------------------------------------------------------------

四大隔離級別
* SERIALIZABLE（串行化）：對同一數據的訪問是串行的，即非并發的，所以不會出現任何并發問題。易出現死鎖，效率太低！不可用！
* REPEATABLE READ（可重復讀）：防止了臟讀、不可重復讀，但沒有防止幻讀
* READ COMMITTED（讀已提交）：防止了臟讀，但沒有防止不可重復讀，以及幻讀
* READ UNCOMMITTED（讀未提交）：可能出現所有并發問題，效率最高，但不可用！

MySQL默認事務隔離級別為：REPEATABLE READ
Oracle默認事務隔離級別為：READ COMMITTED

-------------------------------------------------------------------------------------------------------------------------------------------------

MySQL設置事務隔離級別

/* 查看：*/select @@tx_isolation
/* 設置：*/set transaction isolation level 四選一

JDBC設置事務隔離級別

con.setTransactionIsolation(四選一)

------------------------------------------------------------------------------------------------------------------------------------------------------

代碼JDBCUtils代碼：

需要配置dbconfig.properties文件

?

public class JDBCUtils {static Properties props = null;//綁定線程static private ThreadLocal<Connection> t1=new ThreadLocal<Connection>();static {// 加載本地配置文件try {InputStream in = JDBCUtils.class.getResourceAsStream("dbconfig.properties");props = new Properties();props.load(in);} catch (IOException e) {e.printStackTrace();}// 加載驅動try {Class.forName(props.getProperty("driverClassName"));} catch (ClassNotFoundException e) {e.printStackTrace();}}/*** 獲得Connection連接* @return* @throws Exception*/public static Connection getConnection() throws Exception {Connection conn = t1.get();if(conn==null){// 加載配合conn= DriverManager.getConnection(props.getProperty("url"),props.getProperty("username"), props.getProperty("password"));t1.set(conn);}return conn;}/*** 關閉所有連接* @param rs* @param statement* @param conn*/public static void createClose(ResultSet rs, PreparedStatement statement,Connection conn) {try {if (rs != null)rs.close();if (rs != null)statement.close();if (rs != null)   conn.close();
???         if(t1!=null){
?? ??? ??? ??? ?t1.remove();
?? ??? ??? ?}} catch (Exception e) {e.printStackTrace();}}
}

?