JBoss+Oracle+JTA配置分布式事务

首先讲一下我的配置：
   JBoss是JBoss-4.2.2.GA
   Oracle是Oracle10g
（1）（假如我的JBoss装在D盘）把JBoss路径中(D:\jboss-4.2.2.GA\docs\examples\jca)oracle-xa-ds.xml文件复制一份放到JBoss路径D:\jboss-4.2.2.GA\server\default\deploy下面，然后打开可以看到这个XML文件是一个配置数据库信息模板如：

<datasources>
  <xa-datasource>
    <jndi-name>XAOracleDS</jndi-name>
    <isSameRM-override-value>false</isSameRM-override-value>
    <xa-datasource-class>oracle.jdbc.xa.client.OracleXADataSource</xa-datasource-class>
    <xa-datasource-property name="URL">jdbc:oracle:thin:@localhost:1521:hong</xa-datasource-property>
    <xa-datasource-property name="User">hong</xa-datasource-property>
    <xa-datasource-property name="Password">hong</xa-datasource-property> <exception-sorter-class-name>org.jboss.resource.adapter.jdbc.vendor.OracleExceptionSorter</exception-sorter-class-name>
    <no-tx-separate-pools/>
      <metadata>
         <type-mapping>Oracle10g</type-mapping>
      </metadata>
  </xa-datasource>
  <mbean code="org.jboss.resource.adapter.jdbc.vendor.OracleXAExceptionFormatter" 
         name="jboss.jca:service=OracleXAExceptionFormatter">
    <depends optional-attribute-name="TransactionManagerService">jboss:service=TransactionManager</depends>
  </mbean>
</datasources>

其中需要修改的是<xa-datasource-class>节点如果是Oracl数据库一般都是（oracle.jdbc.xa.client.OracleXADataSource）如果是其他数据库就需要修改成相应的数据库驱动类。
还要修改<xa-datasource-property name="URL">jdbc:oracle:thin:@IP地址:Oracle的端口号:SID
修改<xa-datasource-property name="User">节点为自己的数据库用户名。
修改<xa-datasource-property name="Password">节点为自己数据库的密码。
修改<type-mapping>节点为相应的数据库产品如：9i,10g,11g.
（2）编写测试类：

package myjta.dao;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;

import javax.naming.Context;
import javax.naming.InitialContext;
import javax.naming.NamingException;
import javax.sql.DataSource;
import javax.transaction.UserTransaction;

import myjta.util.MyException;

public class DataBase {
	//事务管理对象
	private UserTransaction ut = null;
	//数据库连接对象
	private Connection conn = null;
	//（Context）上下文对象
	private Context context = null;
	//本身的对象
	private static DataBase dataBase = null;
	//操作数据库对象
	private PreparedStatement pstmt = null;
	//数据集对象
	public ResultSet res = null;
	private DataBase(){
		try {
			context = new InitialContext();
		} catch (NamingException e) {
			e.printStackTrace();
		}
	}
	/**
	 * 返回自己本身的对象。
	 * @return 返回DataBase对象
	 */
	public static DataBase getDataBase(){
		if(dataBase==null){
			dataBase = new DataBase();
		}
		return dataBase;
	}
	/**
	 * 创建事务管理对象UserTransaction
	 * @return 返回事务管理对象UserTransaction
	 */
	public UserTransaction getUserTransaction(){
		try{
//java:comp/UserTransaction是固定写法。
			ut = (UserTransaction)context.lookup("java:comp/UserTransaction");
			System.out.println("ut = "+ut);
		}catch(Exception ex){
			ex.printStackTrace();
			System.out.println("创建UserTransaction"+ex.getMessage());
		}
		return ut;
	}
	/**
	 * 创建数据库连接
	 */
	public void getConn(){
		try{
//其中java:/是前缀XAoracleDs是上面配置的oracle-ax-ds.xml中<jndi-name>节点的名称。
			DataSource ds =  (DataSource)context.lookup("java:/XAOracleDS");
			conn = ds.getConnection();
		}catch(Exception ex){
			ex.printStackTrace();
			System.out.println("创建数据库连接失败~！"+ex.getMessage());
		}
	}
	
	/**
	 * 对数据进行增删改操作的方法
	 * @param sql 要执行的SQL语句
	 * @param arrgs 需要想SQL语句中绑定的数据
	 * @return 返回受影响行数
	 */
	public int excuteUpdate(String sql,String[] arrgs){
		this.getConn();
		int result = 0;
		try {
			pstmt = conn.prepareStatement(sql);
			if(arrgs!=null && arrgs.length>0){
				for(int i=0;i<arrgs.length;i++){
					pstmt.setString(i+1, arrgs[i]);
				}
			}
			result = pstmt.executeUpdate();
		} catch (SQLException e) {
			e.printStackTrace();
			throw new MyException("增加删除修改数据错误！"+e.getMessage(),e);
		}finally{
			this.closePstmt();
			this.closeConn();
		}
		return result;
	}
	/**
	 * 查询数据库数据的方法
	 * @param sql 要执行查询的SQL语句
	 * @param arrgs 要该SQL语句绑定的数据
	 * @return 返回结果集ResultSet
	 */
	public ResultSet excuteQuery(String sql,String[] arrgs){
		try {
			pstmt = conn.prepareStatement(sql);
			if(arrgs!=null && arrgs.length>0){
				for(int i=0;i<arrgs.length;i++){
					pstmt.setString(i+1, arrgs[i]);
				}
			}
			res = pstmt.executeQuery();
		} catch (SQLException e) {
			e.printStackTrace();
			throw new MyException("查询数据错误"+e.getMessage(),e);
		}
		return res;
	}
	/**
	 * 关闭数据库连接
	 */
	public void closeConn(){
		try{
			if(conn!=null){
				conn.close();
				conn = null;
			}
		}catch(Exception ex){
			ex.printStackTrace();
		}
	}
	/**
	 * 关闭PreparedStatement对象
	 */
	public void closePstmt(){
		try {
			if(pstmt!=null){
				pstmt.close();
				pstmt=null;
			}
		} catch (SQLException e) {
			e.printStackTrace();
		}
	}
	/**
	 * 关闭ResultSet对象
	 */
	public void closeRes(){
		try {
			if(res!=null){
				res.close();
				res=null;
			}
		} catch (SQLException e) {
			e.printStackTrace();
		}
	}
}

  这样在JBoss中配置Oracle数据库的JTA就完成了。希望能给广大java学习者提供一些帮助。