事務在 更新和 插入中的用法(轉自他人)


 一 、事務的幾個重要特性

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);
}
}

 


免責聲明!

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



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