九、oracle 事務


一、什么是事務
事務用於保證數據的一致性,它由一組相關的dml語句組成,該組的dml(數據操作語言,增刪改,沒有查詢)語句要么全部成功,要么全部失敗。
如:網上轉賬就是典型的要用事務來處理,用於保證數據的一致性。

    

二、事務和鎖
當執行事務操作時(dml語句),oracle會在被作用的表上加鎖,防止其它用戶修改表的結構。這里對我們的用戶來講是非常重要的。

    

三、提交事務
當用commit語句執行時可以提交事務。當執行了commit語句之后,會確認事務的變化、結束事務。刪除保存點、釋放鎖,當使用commit語句結束事務之后,其它會話將可以查看到事務變化后的新數據。保存點就是為回滾做的。保存點的個數沒有限制。

                

四、回滾事務
在介紹回滾事務前,我們先介紹一下保存點(savepoint)的概念和作用。保存點是事務中的一點。用於取消部分事務,當結束事務時,會自動的刪除該事務所定義的所有保存點。當執行rollback 時,通過指定保存點可以回退到指定的點,這里我們作圖說明。

              

五、事務的幾個重要操作
1.設置保存點 savepoint a
2.取消部分事務 rollback to a
3.取消全部事務 rollback
eg、
SQL> savepoint a; --創建保存點a
Savepoint created
                  
SQL> delete from emp where empno=7782;
1 row deleted
               
SQL> savepoint b; --創建保存到b
Savepoint created
               
SQL> delete from emp where empno=7934;
1 row deleted
                  
SQL> select * from emp where empno=7934; --無法查詢到empno為7934這條記錄,因為這條記錄已被刪除
EMPNO ENAME      JOB         MGR HIREDATE          SAL      COMM DEPTNO
----- ---------- --------- ----- ----------- --------- --------- ------
               
SQL> rollback to b; --通過保持點來恢復這條記錄
Rollback complete
                  
SQL> select * from emp where empno=7934;
EMPNO ENAME      JOB         MGR HIREDATE          SAL      COMM DEPTNO
----- ---------- --------- ----- ----------- --------- --------- ------
 7934 MILLER     CLERK      7782 1982/1/23     1300.00               10
              
SQL> select * from emp where empno=7782; --無法查詢到empno為7982這條記錄,因為這條記錄已被刪除
EMPNO ENAME      JOB         MGR HIREDATE          SAL      COMM DEPTNO
----- ---------- --------- ----- ----------- --------- --------- ------
                
SQL> rollback to a; --通過保持點來恢復這條記錄
Rollback complete
              
SQL> select * from emp where empno=7782;
EMPNO ENAME      JOB         MGR HIREDATE          SAL      COMM DEPTNO
----- ---------- --------- ----- ----------- --------- --------- ------
 7782 CLARK      MANAGER    7839 1981/6/9      2450.00               10
               
SQL>
注意:這個回滾事務,必須是沒有commit前使用的;如果事務提交了,那么無論你剛才做了多少個保存點,都統統沒用。如果沒有手動執行commit,而是exit了,那么會自動提交。
eg、
SQL> savepoint a;
Savepoint created
               
SQL> delete from emp where empno=7782;
1 row deleted
           
SQL> commit;
Commit complete
       
SQL> rollback to a;
rollback to a
ORA-01086: 從未創建保存點 'A'
SQL>

           

六、java程序中如何使用事務
在java操作數據庫時,為了保證數據的一致性,比如賬戶操作(1)從一個賬戶中減掉10$(2)在另一個賬戶上加入10$,我們看看如何使用事務?

java代碼

package junit.test;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.sql.Statement;

public class TransationTest {

public static void main(String[] args) {

Connection conn = null;
try {
// 1.加載驅動
Class.forName("oracle.jdbc.driver.OracleDriver");
// 2.得到連接
conn = DriverManager.getConnection("jdbc:oracle:thin:@127.0.0.1:1521:orcl", "scott", "oracle");
Statement sm = conn.createStatement();
// 從scott的sal中減去100
sm.executeUpdate("update emp set sal=sal-100 where ename='SCOTT'");
int i = 7 / 0; //報java.lang.ArithmeticException: / by zero異常
// 給smith的sal加上100
sm.executeUpdate("update emp set sal=sal+100 where ename='SMITH'");
// 關閉打開的資源
sm.close();
conn.close();
} catch (Exception e) {
// 如果發生異常,就回滾
try {
conn.rollback();
} catch (SQLException e1) {
e1.printStackTrace();
}
e.printStackTrace();
}

}

}

運行,會出現異常,查看數據庫,SCOTT 的sal 減了100,但是SMITH 的sal 卻不變,很可怕。。。
我們怎樣才能保證,這兩個操作要么同時成功,要么同時失敗呢?

           
Java 代碼

package junit.test;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.sql.Statement;

public class TransationTest {

public static void main(String[] args) {

Connection conn = null;
try {
// 1.加載驅動
Class.forName("oracle.jdbc.driver.OracleDriver");
// 2.得到連接
conn = DriverManager.getConnection("jdbc:oracle:thin:@127.0.0.1:1521:orcl", "scott", "oracle");
// 加入事務處理
conn.setAutoCommit(false);// 設置不能默認提交
Statement sm = conn.createStatement();
// 從scott的sal中減去100
sm.executeUpdate("update emp set sal=sal-100 where ename='SCOTT'");
int i = 7 / 0;
// 給smith的sal加上100
sm.executeUpdate("update emp set sal=sal+100 where ename='SMITH'");
// 提交事務
conn.commit();
// 關閉打開的資源
sm.close();
conn.close();
} catch (Exception e) {
// 如果發生異常,就回滾
try {
conn.rollback();
} catch (SQLException e1) {
e1.printStackTrace();
}
e.printStackTrace();
}

}

}

再運行一下,會出現異常,查看數據庫,數據沒變化。。

            

七、只讀事務
只讀事務是指只允許執行查詢的操作,而不允許執行任何其它dml操作的事務,使用只讀事務可以確保用戶只能取得某時間點的數據。
假定機票代售點每天18點開始統計今天的銷售情況,這時可以使用只讀事務。在設置了只讀事務后,盡管其它會話可能會提交新的事務,但是只讀事務將不會取得最新數據的變化,從而可以保證取得特定時間點的數據信息。
設置只讀事務: set transaction read only;

       

比如有兩個用戶system、scott各自用sqlplus登陸,操作如下:
第一步:用system用戶登陸sqlplus,設置只讀事務。
SQL> set transaction read only;
事務處理集。
                        
第二步:用scott用戶登陸sqlplus,操作如下:
SQL> select count(*) from emp; --查詢emp表的總記錄數
  COUNT(*)
----------
        13

SQL> insert into emp values (7777, 'zhangsan', 'MANAGER', 7782, to_date('1988-02-18', 'yyyy-mm-dd'), 38.38, 45.45, 10); --插入一條記錄到emp表
1 row inserted
             
SQL> select count(*) from emp; --查詢emp表的總記錄數
  COUNT(*)
----------
        14
                 
SQL> commit; --提交
Commit complete

             

第三步:用system用戶查詢scott.emp表
SQL> select count(*) from scott.emp;
  COUNT(*)
----------
        13
SQL>


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM