数据库事物操作
事務(wù)
什么是事務(wù)?
轉(zhuǎn)賬:
1. 給wc賬戶減1000元
2. 給wcxf賬戶加1000元
當(dāng)給wc賬戶減1000元后,拋出了異常!這會怎么樣呢?我相信從此之后,wc再也不敢轉(zhuǎn)賬了。
使用事務(wù)就可以處理這一問題:把多個對數(shù)據(jù)庫的操作綁定成一個事務(wù),要么都成功,要么都失敗!
---------------------------------------------------------------------------------------------------------------------------------------------
事物的特性:ACID
* 原子性:事務(wù)中所有操作是不可再分割的原子單位。事務(wù)中所有操作要么全部執(zhí)行成功,要么全部執(zhí)行失敗。
* 一致性:事務(wù)執(zhí)行后,數(shù)據(jù)庫狀態(tài)與其它業(yè)務(wù)規(guī)則保持一致。如轉(zhuǎn)賬業(yè)務(wù),無論事務(wù)執(zhí)行成功與否,參與轉(zhuǎn)賬的兩個賬號余額之和應(yīng)該是不變的。
* 隔離性:隔離性是指在并發(fā)操作中,不同事務(wù)之間應(yīng)該隔離開來,使每個并發(fā)中的事務(wù)不會相互干擾。
* 持久性:一旦事務(wù)提交成功,事務(wù)中所有的數(shù)據(jù)操作都必須被持久化到數(shù)據(jù)庫中,即使提交事務(wù)后,數(shù)據(jù)庫馬上崩潰,在數(shù)據(jù)庫重啟時,也必須能保證通過某種機制恢復(fù)數(shù)據(jù)。
---------------------------------------------------------------------------------------------------------------------------------------------
MySQL操作事務(wù)
1. 開始事務(wù):start transaction
2. 結(jié)束事務(wù):commit//提交事物rollback//事物回滾
(1)事物回滾
(2)事物提交
?
?
---------------------------------------------------------------------------------------------------------------------------------------------
JDBC事務(wù)
1. 開始事務(wù):con.setAutoCommit(false);
2. 結(jié)束事務(wù);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();//人為創(chuàng)建異常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{//關(guān)閉JDBCUtils.createClose(null, pst, con);}} }?
?
?
---------------------------------------------------------------------------------------------------------------------------------------------
保存點
保存點的是可以回滾到事務(wù)中的某個位置,而不是回滾整個事務(wù)。
回滾到保存點不會結(jié)束事務(wù)。
設(shè)置保存點:Savepoint sp = con.setSavepoint();
回滾到保存點:con.rollback(sp);
---------------------------------------------------------------------------------------------------------------------------------------------
事務(wù)隔離級別
* 臟讀:讀到未提交
* 不可重復(fù)讀:兩次讀取不一致,讀取到另一事務(wù)修改的記錄
* 幻讀:兩次讀取不一致,讀取到另一事務(wù)插入的記錄
---------------------------------------------------------------------------------------------------------------------------------------------
四大隔離級別
* SERIALIZABLE(串行化):對同一數(shù)據(jù)的訪問是串行的,即非并發(fā)的,所以不會出現(xiàn)任何并發(fā)問題。易出現(xiàn)死鎖,效率太低!不可用!
* REPEATABLE READ(可重復(fù)讀):防止了臟讀、不可重復(fù)讀,但沒有防止幻讀
* READ COMMITTED(讀已提交):防止了臟讀,但沒有防止不可重復(fù)讀,以及幻讀
* READ UNCOMMITTED(讀未提交):可能出現(xiàn)所有并發(fā)問題,效率最高,但不可用!
MySQL默認事務(wù)隔離級別為:REPEATABLE READ
Oracle默認事務(wù)隔離級別為:READ COMMITTED
-------------------------------------------------------------------------------------------------------------------------------------------------
MySQL設(shè)置事務(wù)隔離級別
/* 查看:*/select @@tx_isolation /* 設(shè)置:*/set transaction isolation level 四選一JDBC設(shè)置事務(wù)隔離級別
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();}// 加載驅(qū)動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;}/*** 關(guān)閉所有連接* @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();}} }
?
轉(zhuǎn)載于:https://www.cnblogs.com/lxp503238/p/6639178.html
總結(jié)
- 上一篇: Error0---local varia
- 下一篇: 14、数据库