數據庫事務性

TPL：事務控制語句

start transaction:開啟一次事務
rollback:回滾
commit：提交事務

JDBC中與事務有關的方法：
Connection.setAutoCommit(boolean b)
Connection.rollback()
Connection.rollback(Savepoint sp)
Connection.commit();

*****四、事務的特性（隔離級別）
A:原子性。說明事務是一個不可分割的單位。
C：一致性.事務必須使數據庫從一個一致性狀態變換到另外一個一致性狀態.(比如轉賬)
*I：隔離性。一個事務不能被其他事務打擾。
D：持久性。事務一旦提交，就應該被永久保存起來。

如果不考慮事務的隔離級別，會出現以下“不正確”的情況：
臟讀：指一個事務讀到了另一個事務中未提交的數據。
不可重復讀：針對一條記錄的，同一條記錄前后不一樣
虛讀（幻讀）：針對一張表，前后讀到的記錄條數不一樣。

MySQL中控制事務隔離級別的語句：
select @@tx_isolation; //查看當前的事務隔離級別
set transaction isolation level 你的級別（四種之一）;//設置隔離級別

 

隔離級別的分類：
READ UNCOMMITTED(未授權讀):臟讀、不可重復讀、虛讀都有可能發生。
READ COMMITTED(授權讀):能避免臟讀，不可重復讀、虛讀都有可能發生。
REPEATABLE READ(可重復讀):能避免臟讀、不可重復度，虛讀都有可能發生。
SERIALIZABLE(序列化):能避免臟讀、不可重復度、虛讀。

 

oracle隔離級別 只有READ COMMITTED和 SERIALIZABLE

因為當有人對數據庫的數據進行任何寫操作（DML操作）時，Oracle數據庫系統首先將原始的數據復制到回滾段中，之后才做相應的操作，在事務處理結束之前其他的用戶可以讀這些數據，但是讀到的都是回滾段上的數據。

create table bank
{
　　id int primary key,
　　name varchar(10),
　　money int
}

搭建數據庫連接

c3p0-config.xml下

<?xml version="1.0" encoding="UTF-8"?>
<c3p0-config>
    <default-config>
        <property name="driverClass">com.mysql.jdbc.Driver</property>
        <property name="jdbcUrl">jdbc:mysql://127.0.0.1:3306/bank</property>
        <property name="user">root</property>
        <property name="password">mima</property>
    </default-config>
</c3p0-config>

JdbcUtil.java   導入相關的類

public class JdbcUtil {
    private static ComboPooledDataSource dataSource =new ComboPooledDataSource();
    public static ComboPooledDataSource getDataSource()
    {
        return dataSource;
    }
}

測試代碼 。 注意 事務是針對一次連接Connection的，如果

 QueryRunner runner =new  QueryRunner(ds);    的話可能對於連接 會有不同的Connecton就達不到效果了

    public static void main(String[] args) throws Exception  {
        DataSource ds=JdbcUtil.getDataSource();
        Connection con=ds.getConnection();
        QueryRunner runner =new  QueryRunner();        
        try {
            con.setAutoCommit(false);
        } catch (SQLException e1) {
            e1.printStackTrace();
        }
        try {
            String sql1="update money_table set money=money+1000 where name = ?";
            runner.update(con,sql1, new Object[]{"aa"});
            int i=1/0;
            String sql2="update money_table set money=money-1000 where name = ?";
            runner.update(con,sql2, new Object[]{"bb"});
            con.commit();
        
        } catch (Exception e) {
            try {
                con.rollback();
            } catch (SQLException e1) {
                e1.printStackTrace();
            }
            e.printStackTrace();
        }
        finally
        {
            
        }

    }

數據正常。

 

    public static void main(String[] args) throws Exception  {
        DataSource ds=JdbcUtil.getDataSource();
        Connection con=ds.getConnection();
        QueryRunner runner =new  QueryRunner();        
        try {
            con.setAutoCommit(false);
        } catch (SQLException e1) {
            e1.printStackTrace();
        }
        Savepoint sp=null;
        try {
            String sql1="update money_table set money=money+1000 where name = ?";
            runner.update(con,sql1, new Object[]{"aa"});    
            String sql2="update money_table set money=money-1000 where name = ?";
            runner.update(con,sql2, new Object[]{"bb"});
            sp=con.setSavepoint();
            int i=1/0;
            String sql3="update money_table set money=money+1000 where name = ?";
            runner.update(con,sql3, new Object[]{"cc"});
            String sql4="update money_table set money=money-1000 where name = ?";
            runner.update(con,sql4, new Object[]{"dd"});
        
        
        } catch (Exception e) {
            try {
                con.rollback(sp);
            } catch (SQLException e1) {
                e1.printStackTrace();
            }
            e.printStackTrace();
        }
        finally
        {
            con.commit();
        }

    }