自己先跟一帖
import javax.transaction.*;
import java.sql.*;
import java.util.*;
import java.io.*;
import javax.naming.Context;
import javax.naming.InitialContext;
import javax.naming.NamingException;
import javax.sql.DataSource;

public class JTATest
{
public static void main(String args[])
{
Context ctx=null;
Hashtable ht=new Hashtable();
DataSource ds=null;
Statement stmt=null;
ResultSet rs=null;
Connection myConn = null;
UserTransaction tx = null;
String tablename="student";
String str1="INSERT INTO student VALUES ('01001001','ixucheng', 33)";
String str2="INSERT INTO student VALUES ('01001002','hangsan', 44)";
try
{
ht.put(Context.INITIAL_CONTEXT_FACTORY,"weblogic.jndi.WLInitialContextFactory");
ht.put(Context.PROVIDER_URL,"t3://localhost:7001");
ctx=new InitialContext(ht);
String str="javax.transaction.UserTransaction";
tx =(UserTransaction)ctx.lookup(str);
tx.begin();
ds = (javax.sql.DataSource)ctx.lookup("TestData");
myConn= ds.getConnection();
stmt = myConn.createStatement();
stmt.executeUpdate (str1);
stmt.executeUpdate (str2);
tx.commit();
System.out.println("Success!");
}
catch (Exception E)
{
try{tx.rollback();}catch(Exception e){}
System.out.println("事務(wù)發(fā)生錯(cuò)誤，事務(wù)被取消！ ");
}
finally
{
if (rs != null)
{
try{ rs.close(); } catch (Exception ignore) {};
}
if (stmt != null)
{
try{ stmt.close(); } catch (Exception ignore) {};
}
if (myConn != null)
{
try { myConn.close(); } catch (Exception ignore) {};
}

}
}
}  回復(fù)  更多評(píng)論
  

精通EJB上的例子
try{
/*
*1:設(shè)置環(huán)境。為訪問(wèn)JNDI，碧血初始化上下文工廠、提供URL、所需的用戶名、密碼
*2：具體細(xì)節(jié)，可以參考應(yīng)用服務(wù)器的給出的產(chǎn)品文檔
*3：注意，重點(diǎn)參考文檔中有關(guān)JNDI的部分
*/
java.util.Properties env = ...
/*
*2:獲得JNDI初始上下文
*/
Context ctx = new InitialContext(env);
/*
*3:借助于JNDI，查找JTA UserTransaction接口
*通常，容器都回江JTA暴露在“java:comp/UserTransaction”位置

*
*/
userTran = (javax.transaction.UserTransaction)
ctx.lookup("java:comp/UserTransaction");
/*
*4:執(zhí)行事務(wù)
*/
userTran.begin();
//完成業(yè)務(wù)操作
userTran.commit();
}
catch(Exception e)
//處理異常，包括事務(wù)回滾的處理。

}  回復(fù)  更多評(píng)論