MySql事務及JDBC對事務的使用

 一 、事務的幾個重要特性

1. 原子性

　　事務內的每個內容不可分割，是一個統一的整體。或同時進行或同時消亡。

2.一致性

      事務執行前和事務執行后，狀態都是統一的。如A轉B 100元，A和B數據總額度沒有在這個轉賬過程中增加或者減小。

3.隔離性【isolation】

　　事務的隔離性指的是幾個事務同時執行，事務a不應該干擾到事務b內的操作（在並發過程中很有可能會發生事務間的影響，例如臟讀、不可重復讀等。需要在編程的時候選擇適當的方式進行選擇）

3.可持久性

　　事務執行后的結果可以存儲（序列化）到硬盤上，形成一個固定的內容存儲起來。

 

 二、事務的使用

　　事務的生命周期有2個，1開啟事務 2提交或者回滾事務。事務開始后一定要提交或者回滾，以免引起數據庫內存泄漏

　　使用Mysql開啟事務及使用。

　　表內數據如下，現需要從a賬號轉100money到b賬號。

 

具體步驟如下：

 　　Mysql 中與事務使用有關的三個關鍵語句：

      (1) 開啟事務 ： start transaction

      (2)回滾事務 ：rollback , 提交事務：commit

 三、使用JDBC對事務進行調用

 △注意： 事務只能對DML語句進行操作，對數據定義類語句DDL無法操作，例如建表、建立索引、建立分區等。

 JDBC使用事務時，需要使用Java語言中的Connection對事務進行操作，具體的事務對應一個數據庫連接。

package com.scl.test.transcaction;

import java.sql.Connection;
import java.sql.Statement;

import org.junit.Test;

public class TestTranscaction
{

    @Test
    public void testTransaction() throws Exception
    {
        Connection conn = null;
        Statement statement = null;

        try
        {
            conn = JDBCHelper.getConnection();

            conn.setAutoCommit(false); //開啟事務，禁止自動提交
            String sql1 = "update t_account t set t.money=t.money-100 where t.name ='a'";
            String sql2 = "update t_account t set t.money=t.money+100 where t.name ='b'";
            statement = conn.createStatement();
            // statement.setString(1, "a");

            statement.addBatch(sql1);
            statement.addBatch(sql2);


            statement.executeBatch();
            conn.commit(); //執行成功，提交事務

        }
        catch (Exception e)
        {
            conn.rollback(); //發生異常，事務回滾
        }
        finally
        {
            JDBCHelper.disposeConnect(statement, conn);
        }
    }
}

 

　　最后進行一個知識點補漏：JDBC執行多條sql腳本。

　　JDBC提供了執行多條sql語句的方法，使用PrepareStatement或Statement實例調用addBatch方法。目前發現該方法有幾個缺點：

　　1. 無法通過PrepareStatement實例對多條不同的sql腳本進行參數化設置。因為PrepareStatement是由一個鏈接產生的，不能同時用一個prepareStatement實例同時對應兩個不同的預處理文件。

　　 如需求：需要插入更新一張表里面的兩行不同的數據。 

        sql1： update t_account t set t.money=t.money-100 where t.name ='a'；

　　 sql2： update t_account t set t.money=t.money-100 where t.name ='b'；

　　 這時候沒辦法使用prepareStatement的addBatch方法執行操作。見代碼：

    @Test
    public void testTransaction() throws Exception
    {
        Connection conn = null;
        Statement st = null;
        PreparedStatement pst = null;
        try
        {
            conn = JDBCHelper.getConnection();

            conn.setAutoCommit(false);
            String sql1 = "update t_account t set t.money=t.money-100 where t.name =?";
            String sql2 = "update t_account t set t.money=t.money+100 where t.name =?";
            pst = conn.prepareStatement(sql1);
            // 只能批量執行某一條固定的sql語句，並且進行參數化設置
            pst.setString(1, "a"); // 為name 為 a的用戶減少100元
            pst.addBatch();
            pst.setString(1, "b"); // 為name 為b的用戶減少100元
            pst.addBatch();
            pst.executeBatch(); // 只能在執行完成以后提交一次，然后改成新的sql腳本。但容易引發內存泄漏

            pst = conn.prepareStatement(sql2); // 內存泄漏，存在未關閉的鏈接
            pst.setString(1, "c");
            pst.addBatch();
            pst.executeBatch();
            conn.commit();

        }
        catch (Exception e)
        {
            conn.rollback();
        }
        finally
        {
            JDBCHelper.disposeConnect(pst, conn);
        }
    }

 

       2. 使用statement實例對多條腳本進行提交（只提交一次，但無法進行預編譯sql腳本）

    @Test
    public void testTransaction() throws Exception
    {
        Connection conn = null;
        Statement st = null;
        PreparedStatement pst = null;
        try
        {
            conn = JDBCHelper.getConnection();

            conn.setAutoCommit(false);
            String sql1 = "update t_account t set t.money=t.money-100 where t.name =?";
            String sql2 = "update t_account t set t.money=t.money+100 where t.name =?";
            pst = conn.prepareStatement(sql1);
            // 只能批量執行某一條固定的sql語句，並且進行參數化設置
            pst.setString(1, "a"); // 為name 為 a的用戶減少100元
            pst.addBatch();
            pst.setString(1, "b"); // 為name 為b的用戶減少100元
            pst.addBatch();
            pst.executeBatch(); // 只能在執行完成以后提交一次，然后改成新的sql腳本。但容易引發內存泄漏

            pst = conn.prepareStatement(sql2); // 內存泄漏，存在未關閉的鏈接
            pst.setString(1, "c");
            pst.addBatch();
            pst.executeBatch();
            conn.commit();

        }
        catch (Exception e)
        {
            conn.rollback();
        }
        finally
        {
            JDBCHelper.disposeConnect(pst, conn);
        }
    }