一 、事務的幾個重要特性
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);
}
}