java 事務(wù)

Java中的事務(wù)處理

成都創(chuàng)新互聯(lián)公司是一家專注于網(wǎng)站制作、做網(wǎng)站和聯(lián)通服務(wù)器托管的網(wǎng)絡(luò)公司，有著豐富的建站經(jīng)驗(yàn)和案例。

一般情況下，J2EE應(yīng)用服務(wù)器支持JDBC事務(wù)、JTA（Java Transaction API）事務(wù)、容器管理事務(wù)。一般情況下，最好不要在程序中同時(shí)使用上述三種事務(wù)類型，比如在JTA事務(wù)中嵌套JDBC事務(wù)。第二方面，事務(wù)要在盡可能短的時(shí)間內(nèi)完成，不要在不同方法中實(shí)現(xiàn)事務(wù)的使用。下面我們列舉兩種事務(wù)處理方式。

1、JavaBean中使用JDBC方式進(jìn)行事務(wù)處理

在JDBC中怎樣將多個(gè)SQL語句組合成一個(gè)事務(wù)呢？在JDBC中，打開一個(gè)連接對象Connection時(shí)，缺省是auto-commit模式，每個(gè)SQL語句都被當(dāng)作一個(gè)事務(wù)，即每次執(zhí)行一個(gè)語句，都會(huì)自動(dòng)的得到事務(wù)確認(rèn)。為了能將多個(gè)SQL語句組合成一個(gè)事務(wù)，要將auto-commit模式屏蔽掉。在auto-commit模式屏蔽掉之后，如果不調(diào)用commit()方法，SQL語句不會(huì)得到事務(wù)確認(rèn)。在最近一次commit()方法調(diào)用之后的所有SQL會(huì)在方法commit()調(diào)用時(shí)得到確認(rèn)。

public int delete(int sID) {

dbc = new DataBaseConnection();

Connection con = dbc.getConnection();

try {

con.setAutoCommit(false);// 更改JDBC事務(wù)的默認(rèn)提交方式

dbc.executeUpdate("delete from bylaw where ID=" + sID);

dbc.executeUpdate("delete from bylaw _content where ID=" + sID);

dbc.executeUpdate("delete from bylaw _affix where bylawid=" + sID);

con.commit();//提交JDBC事務(wù)

con.setAutoCommit(true);// 恢復(fù)JDBC事務(wù)的默認(rèn)提交方式

dbc.close();

return 1;

}

catch (Exception exc) {

con.rollBack();//回滾JDBC事務(wù)

exc.printStackTrace();

dbc.close();

return -1;

}

}

2、SessionBean中的JTA事務(wù)

JTA 是事務(wù)服務(wù)的 J2EE 解決方案。本質(zhì)上，它是描述事務(wù)接口（比如 UserTransaction 接口，開發(fā)人員直接使用該接口或者通過 J2EE 容器使用該接口來確保業(yè)務(wù)邏輯能夠可靠地運(yùn)行）的 J2EE 模型的一部分。JTA 具有的三個(gè)主要的接口分別是 UserTransaction 接口、TransactionManager 接口和 Transaction 接口。這些接口共享公共的事務(wù)操作，例如 commit() 和 rollback()， 但是也包含特殊的事務(wù)操作，例如 suspend()，resume() 和 enlist()，它們只出現(xiàn)在特定的接口上，以便在實(shí)現(xiàn)中允許一定程度的訪問控制。例如，UserTransaction 能夠執(zhí)行事務(wù)劃分和基本的事務(wù)操作，而 TransactionManager 能夠執(zhí)行上下文管理。

應(yīng)用程序可以調(diào)用UserTransaction.begin()方法開始一個(gè)事務(wù)，該事務(wù)與應(yīng)用程序正在其中運(yùn)行的當(dāng)前線程相關(guān)聯(lián)。底層的事務(wù)管理器實(shí)際處理線程與事務(wù)之間的關(guān)聯(lián)。UserTransaction.commit()方法終止與當(dāng)前線程關(guān)聯(lián)的事務(wù)。UserTransaction.rollback()方法將放棄與當(dāng)前線程關(guān)聯(lián)的當(dāng)前事務(wù)。

public int delete(int sID) {

DataBaseConnection dbc = null;

dbc = new DataBaseConnection();

dbc.getConnection();

UserTransaction transaction = sessionContext.getUserTransaction();//獲得JTA事務(wù)

try {

transaction.begin(); //開始JTA事務(wù)

dbc.executeUpdate("delete from bylaw where ID=" + sID);

dbc.executeUpdate("delete from bylaw _content where ID=" + sID);

dbc.executeUpdate("delete from bylaw _affix where bylawid=" + sID);

transaction.commit(); //提交JTA事務(wù)

dbc.close();

return 1;

}

catch (Exception exc) {

try {

transaction.rollback();//JTA事務(wù)回滾

}

catch (Exception ex) {

//JTA事務(wù)回滾出錯(cuò)處理

ex.printStackTrace();

}

exc.printStackTrace();

dbc.close();

return -1;

}

}

Java 編程 ，事務(wù)管理的作用

事務(wù)就是對一系列的數(shù)據(jù)庫操作進(jìn)行統(tǒng)一的提交或回滾操作，比如說做一個(gè)轉(zhuǎn)賬功能，要更改帳戶兩邊的數(shù)據(jù)，這時(shí)候就必須要用事務(wù)才能算是嚴(yán)謹(jǐn)?shù)淖龇āＲ闯晒Γ词。３謹(jǐn)?shù)據(jù)一致性。如果中間有一個(gè)操作出現(xiàn)異常，那么回滾之前的所有操作。

這樣有什么好處呢。

這樣可以防止在一些意外(例如說突然斷電)的情況下出現(xiàn)亂數(shù)據(jù)，防止數(shù)據(jù)庫數(shù)據(jù)出現(xiàn)問題。這邊加了錢，那邊卻還是一樣的數(shù)，這就完了。要是開放一個(gè)網(wǎng)上交易的平臺(tái)，這樣就會(huì)出大問題的！

還有其他的一些操作，像是要添加多條數(shù)據(jù)，如果程序要求必須全部正確才能插入的話，事務(wù)又起大作用了。

等等。。。開發(fā)中為了避免這種情況一般都會(huì)進(jìn)行事務(wù)管理。

在JDBC中是通過Connection對象進(jìn)行事務(wù)管理的，默認(rèn)是自動(dòng)提交事務(wù)，可以手工將自動(dòng)提交關(guān)閉，通過commit方法進(jìn)行提交，rollback方法進(jìn)行回滾，如果不提交，則數(shù)據(jù)不會(huì)真正的插入到數(shù)據(jù)庫中。

Hibernate中是通過Transaction進(jìn)行事務(wù)管理，處理方法與JDBC中類似。

Spring中也有自己的事務(wù)管理機(jī)制，使用TransactionMananger進(jìn)行管理，可以通過Spring的注入來完成此功能。

java事務(wù)處理

如果對數(shù)據(jù)庫進(jìn)行多次操作,每一次的執(zhí)行或步驟都是一個(gè)事務(wù).如果數(shù)據(jù)庫操作在某一步?jīng)]有執(zhí)行或出現(xiàn)異常而導(dǎo)致事務(wù)失敗,這樣有的事務(wù)被執(zhí)行有的就沒有被執(zhí)行,從而就有了事務(wù)的回滾,取消先前的操作.....

JavaBean中使用JDBC方式進(jìn)行事務(wù)處理

public int delete(int sID) {

　 dbc = new DataBaseConnection();

　 Connection con = dbc.getConnection();

　 try {

con.setAutoCommit(false);// 更改JDBC事務(wù)的默認(rèn)提交方式

dbc.executeUpdate("delete from xiao where ID=" + sID);

dbc.executeUpdate("delete from xiao_content where ID=" + sID);

dbc.executeUpdate("delete from xiao_affix where bylawid=" + sID);

con.commit();//提交JDBC事務(wù)

con.setAutoCommit(true);// 恢復(fù)JDBC事務(wù)的默認(rèn)提交方式

dbc.close();

return 1;

　 }

　 catch (Exception exc) {

con.rollBack();//回滾JDBC事務(wù)

exc.printStackTrace();

dbc.close();

return -1;

　 }

}

在數(shù)據(jù)庫操作中，一項(xiàng)事務(wù)是指由一條或多條對數(shù)據(jù)庫更新的sql語句所組成的一個(gè)不可分割的工作單元。只有當(dāng)事務(wù)中的所有操作都正常完成了，整個(gè)事務(wù)才能被提交到數(shù)據(jù)庫，如果有一項(xiàng)操作沒有完成，就必須撤消整個(gè)事務(wù)。

例如在銀行的轉(zhuǎn)帳事務(wù)中，假定張三從自己的帳號上把1000元轉(zhuǎn)到李四的帳號上，相關(guān)的sql語句如下：

update account set monery=monery-1000 where name='zhangsan'

update account set monery=monery+1000 where name='lisi'

這個(gè)兩條語句必須作為一個(gè)完成的事務(wù)來處理。只有當(dāng)兩條都成功執(zhí)行了，才能提交這個(gè)事務(wù)。如果有一句失敗，整個(gè)事務(wù)必須撤消。

在connection類中提供了3個(gè)控制事務(wù)的方法：

（1） setAutoCommit(Boolean autoCommit):設(shè)置是否自動(dòng)提交事務(wù)；

（2） commit();提交事務(wù)；

（3） rollback();撤消事務(wù)；

在jdbc api中，默認(rèn)的情況為自動(dòng)提交事務(wù)，也就是說，每一條對數(shù)據(jù)庫的更新的sql語句代表一項(xiàng)事務(wù)，操作成功后，系統(tǒng)自動(dòng)調(diào)用commit（）來提交，否則將調(diào)用rollback（）來撤消事務(wù)。

在jdbc api中，可以通過調(diào)用setAutoCommit(false) 來禁止自動(dòng)提交事務(wù)。然后就可以把多條更新數(shù)據(jù)庫的sql語句做為一個(gè)事務(wù)，在所有操作完成之后，調(diào)用commit（）來進(jìn)行整體提交。倘若其中一項(xiàng)sql操作失敗，就不會(huì)執(zhí)行commit（）方法，而是產(chǎn)生相應(yīng)的sqlexception，此時(shí)就可以捕獲異常代碼塊中調(diào)用rollback（）方法撤消事務(wù)。

java中的事務(wù)

如果你用Spring框架，Spring中可以實(shí)現(xiàn)事務(wù)管理，在spring 配置文件中配置事務(wù)管理器，也可以使用Spring注解式事務(wù)，在方法上加上@Transactional注解。

@Transactional

public void save() {

//你的代碼邏輯

}

如果沒有使用Spring框架，可以用JDBC處理事務(wù)，如下：

try{

con.setAutoCommit(false);//開啟事務(wù) ......

con.commit();//try的最后提交事務(wù)

} catch（） {

con.rollback();//回滾事務(wù)

}

在java中，事務(wù)是什么？有什么用！

一、什么是Java事務(wù)

通常的觀念認(rèn)為，事務(wù)僅與數(shù)據(jù)庫相關(guān)。

事務(wù)必須服從ISO/IEC所制定的ACID原則。ACID是原子性（atomicity）、一致性（consistency）、隔離性

（isolation）和持久性（durability）的縮寫。事務(wù)的原子性表示事務(wù)執(zhí)行過程中的任何失敗都將導(dǎo)致事務(wù)所做的任何修改失效。一致性表示

當(dāng)事務(wù)執(zhí)行失敗時(shí)，所有被該事務(wù)影響的數(shù)據(jù)都應(yīng)該恢復(fù)到事務(wù)執(zhí)行前的狀態(tài)。隔離性表示在事務(wù)執(zhí)行過程中對數(shù)據(jù)的修改，在事務(wù)提交之前對其他事務(wù)不可見。持

久性表示已提交的數(shù)據(jù)在事務(wù)執(zhí)行失敗時(shí)，數(shù)據(jù)的狀態(tài)都應(yīng)該正確。

通俗的理解，事務(wù)是一組原子操作單元，從數(shù)據(jù)庫角度說，就是一組SQL指令，要么全部執(zhí)行成功，若因?yàn)槟硞€(gè)原因其中一條指令執(zhí)行有錯(cuò)誤，則撤銷先前執(zhí)行過的所有指令。更簡答的說就是：要么全部執(zhí)行成功，要么撤銷不執(zhí)行。

既然事務(wù)的概念從數(shù)據(jù)庫而來，那Java事務(wù)是什么？之間有什么聯(lián)系？

實(shí)際上，一個(gè)Java應(yīng)用系統(tǒng)，如果要操作數(shù)據(jù)庫，則通過JDBC來實(shí)現(xiàn)的。增加、修改、刪除都是通過相應(yīng)方法間接來實(shí)現(xiàn)的，事務(wù)的控制也相應(yīng)轉(zhuǎn)移到Java程序代碼中。因此，數(shù)據(jù)庫操作的事務(wù)習(xí)慣上就稱為Java事務(wù)。

二、為什么需要事務(wù)

事務(wù)是為解決數(shù)據(jù)安全操作提出的，事務(wù)控制實(shí)際上就是控制數(shù)據(jù)的安全訪問。具一個(gè)簡單例子：比如銀行轉(zhuǎn)帳業(yè)務(wù)，賬戶A要將自己賬戶上的1000元

轉(zhuǎn)到B賬戶下面，A賬戶余額首先要減去1000元，然后B賬戶要增加1000元。假如在中間網(wǎng)絡(luò)出現(xiàn)了問題，A賬戶減去1000元已經(jīng)結(jié)束，B因?yàn)榫W(wǎng)絡(luò)中

斷而操作失敗，那么整個(gè)業(yè)務(wù)失敗，必須做出控制，要求A賬戶轉(zhuǎn)帳業(yè)務(wù)撤銷。這才能保證業(yè)務(wù)的正確性，完成這個(gè)操走就需要事務(wù)，將A賬戶資金減少和B賬戶資

金增加方到一個(gè)事務(wù)里面，要么全部執(zhí)行成功，要么操作全部撤銷，這樣就保持了數(shù)據(jù)的安全性。

三、Java事務(wù)的類型

Java事務(wù)的類型有三種：JDBC事務(wù)、JTA(Java Transaction API)事務(wù)、容器事務(wù)。

1、JDBC事務(wù)

JDBC 事務(wù)是用 Connection 對象控制的。JDBC Connection 接口( java.sql.Connection )提供了兩種事務(wù)模式：自動(dòng)提交和手工提交。 java.sql.Connection 提供了以下控制事務(wù)的方法：

public void setAutoCommit(boolean)

public boolean getAutoCommit()

public void commit()

public void rollback()

使用 JDBC 事務(wù)界定時(shí)，您可以將多個(gè) SQL 語句結(jié)合到一個(gè)事務(wù)中。JDBC 事務(wù)的一個(gè)缺點(diǎn)是事務(wù)的范圍局限于一個(gè)數(shù)據(jù)庫連接。一個(gè) JDBC 事務(wù)不能跨越多個(gè)數(shù)據(jù)庫。

2、JTA(Java Transaction API)事務(wù)

JTA是一種高層的，與實(shí)現(xiàn)無關(guān)的，與協(xié)議無關(guān)的API，應(yīng)用程序和應(yīng)用服務(wù)器可以使用JTA來訪問事務(wù)。

JTA允許應(yīng)用程序執(zhí)行分布式事務(wù)處理–在兩個(gè)或多個(gè)網(wǎng)絡(luò)計(jì)算機(jī)資源上訪問并且更新數(shù)據(jù)，這些數(shù)據(jù)可以分布在多個(gè)數(shù)據(jù)庫上。JDBC驅(qū)動(dòng)程序的JTA支持極大地增強(qiáng)了數(shù)據(jù)訪問能力。

如果計(jì)劃用 JTA 界定事務(wù)，那么就需要有一個(gè)實(shí)現(xiàn) javax.sql.XADataSource 、

javax.sql.XAConnection 和 javax.sql.XAResource 接口的 JDBC

驅(qū)動(dòng)程序。一個(gè)實(shí)現(xiàn)了這些接口的驅(qū)動(dòng)程序?qū)⒖梢詤⑴c JTA 事務(wù)。一個(gè) XADataSource 對象就是一個(gè) XAConnection

對象的工廠。 XAConnection s 是參與 JTA 事務(wù)的 JDBC 連接。

您將需要用應(yīng)用服務(wù)器的管理工具設(shè)置 XADataSource 。從應(yīng)用服務(wù)器和 JDBC 驅(qū)動(dòng)程序的文檔中可以了解到相關(guān)的指導(dǎo)。

J2EE 應(yīng)用程序用 JNDI 查詢數(shù)據(jù)源。一旦應(yīng)用程序找到了數(shù)據(jù)源對象，它就調(diào)用 javax.sql.DataSource.getConnection() 以獲得到數(shù)據(jù)庫的連接。

XA 連接與非 XA 連接不同。一定要記住 XA 連接參與了 JTA 事務(wù)。這意味著 XA 連接不支持 JDBC

的自動(dòng)提交功能。同時(shí)，應(yīng)用程序一定不要對 XA 連接調(diào)用 java.sql.Connection.commit() 或者

java.sql.Connection.rollback() 。相反，應(yīng)用程序應(yīng)該使用 UserTransaction.begin()、

UserTransaction.commit() 和 serTransaction.rollback() 。

3、容器事務(wù)

容器事務(wù)主要是J2EE應(yīng)用服務(wù)器提供的，容器事務(wù)大多是基于JTA完成，這是一個(gè)基于JNDI的，相當(dāng)復(fù)雜的API實(shí)現(xiàn)。相對編碼實(shí)現(xiàn)JTA事

務(wù)管理，我們可以通過EJB容器提供的容器事務(wù)管理機(jī)制（CMT）完成同一個(gè)功能，這項(xiàng)功能由J2EE應(yīng)用服務(wù)器提供。這使得我們可以簡單的指定將哪個(gè)方

法加入事務(wù)，一旦指定，容器將負(fù)責(zé)事務(wù)管理任務(wù)。這是我們土建的解決方式，因?yàn)橥ㄟ^這種方式我們可以將事務(wù)代碼排除在邏輯編碼之外，同時(shí)將所有困難交給

J2EE容器去解決。使用EJB CMT的另外一個(gè)好處就是程序員無需關(guān)心JTA API的編碼，不過，理論上我們必須使用EJB。

四、三種事務(wù)差異

1、JDBC事務(wù)控制的局限性在一個(gè)數(shù)據(jù)庫連接內(nèi)，但是其使用簡單。

2、JTA事務(wù)的功能強(qiáng)大，事務(wù)可以跨越多個(gè)數(shù)據(jù)庫或多個(gè)DAO，使用也比較復(fù)雜。

3、容器事務(wù)，主要指的是J2EE應(yīng)用服務(wù)器提供的事務(wù)管理，局限于EJB應(yīng)用使用。

五、總結(jié)

事務(wù)控制是構(gòu)建J2EE應(yīng)用不可缺少的一部分，合理選擇應(yīng)用何種事務(wù)對整個(gè)應(yīng)用系統(tǒng)來說至關(guān)重要。一般說來，在單個(gè)JDBC

連接連接的情況下可以選擇JDBC事務(wù)，在跨多個(gè)連接或者數(shù)據(jù)庫情況下，需要選擇使用JTA事務(wù)，如果用到了EJB，則可以考慮使用EJB容器事務(wù)。

如果滿意請及時(shí)采納，謝謝~

如何用java開啟mysql事務(wù)，要求詳細(xì)

如何用java開啟mysql事務(wù)，要求詳細(xì)

看你是什么事務(wù)，jdbc事務(wù)，還是分布式事務(wù)，還是容器事務(wù)

1，編程式事務(wù)管理（jdbc的事務(wù)是綁定在connection上的）

Connection conn = null;

try

{

Class.forName("com.mysql.jdbc.Driver");

conn = DriverManager.getConnection("jdbc:oracle:thin:@host:1521:SID","username","password");

conn.setAutoCommit(false); //取消自動(dòng)提交

PreparedStatement ps = conn.prepareCall("update something");

ResultSet rs = ps.executeQuery();

conn.commit(); //手動(dòng)提交

}

catch (Exception e)

{

conn.rollback();

e.printStackTrace();

}

finally

{

conn.close();

}

2，聲明式事務(wù)

先在工程的application.xml配置文件中添加如下代碼，開啟事務(wù)

!-- 聲明式事務(wù)控制配置 --

tx:annotation-driven transaction-manager="txManager"/

bean id="txManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager"

property name="datasource" ref="bassDataSource"/property

/bean

然后在你需要開啟事務(wù)的接口前面添加注解

@Transactional(rollbackFor = IOException.class)

public void add(String name) throws IOException

{

System.out.println("可以再類里和方法里面添加事務(wù)注解0~0");

throw new IOException();

}

直接調(diào)用接口方法就好

分布式事務(wù)處理（mysql貌似在5.X之后才支持） 的話，

1.可以直接使用spring+atomikos框架進(jìn)行管理

參考：

就不貼測試代碼了，自己看著配置吧

2，使用JTA（Java Transaction API）進(jìn)行分布式事務(wù)管理（測試代碼如下）

import java.sql.Connection;

import java.sql.PreparedStatement;

import java.sql.SQLException;

import javax.naming.InitialContext;

import javax.sql.DataSource;

import javax.transaction.SystemException;

import javax.transaction.UserTransaction;

import com.mysql.jdbc.jdbc2.optional.MysqlDataSource;

//分布式事務(wù)處理

public class transferAccount

{

@SuppressWarnings("null")

public void testTransferAccount()

{

UserTransaction userts = null;

Connection connA = null;

PreparedStatement psA = null;

InitialContext context = null;

Connection connB = null;

PreparedStatement psB = null;

try

{

//獲得事務(wù)管理對象

userts = (UserTransaction) context.lookup("java:comp/UserTransaction");

//獲取兩個(gè)數(shù)據(jù)庫

connA = getDataSourceA().getConnection();

connB = getDataSourceB().getConnection();

//開啟事務(wù)

userts.begin();

//sql語句

psA = connA.prepareStatement("我加1");

psB = connB.prepareStatement("我減1");

//執(zhí)行sql

psA.executeUpdate();

psB.executeUpdate();

//事務(wù)提交

userts.commit();

} catch (Exception e)

{

try

{

userts.rollback();

} catch (IllegalStateException | SecurityException

| SystemException e1)

{

e1.printStackTrace();

}

e.printStackTrace();

}

finally

{

try

{

psA.close();

psB.close();

connA.close();

connB.close();

} catch (SQLException e)

{

e.printStackTrace();

}

}

}

public DataSource getDataSourceA()

{

MysqlDataSource dataSource = new MysqlDataSource();

dataSource.setDatabaseName("mysql");

dataSource.setServerName("server");

dataSource.setPortNumber(1433);

dataSource.setUser("test");

dataSource.setPassword("test");

return dataSource;

}

public DataSource getDataSourceB()

{

MysqlDataSource dataSource = new MysqlDataSource();

dataSource.setDatabaseName("mysql");

dataSource.setServerName("server");

dataSource.setPortNumber(1435);

dataSource.setUser("test1");

dataSource.setPassword("test1");

return dataSource;

}

}

文章名稱：java代碼使用事務(wù) java代碼事務(wù)怎么寫
URL網(wǎng)址：http://chinadenli.net/article18/dodhcgp.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供網(wǎng)站改版、企業(yè)建站、網(wǎng)站制作、自適應(yīng)網(wǎng)站、手機(jī)網(wǎng)站建設(shè)、App設(shè)計(jì)

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請盡快告知，我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時(shí)需注明來源： 創(chuàng)新互聯(lián)