J2EE中的不同数据库之间事务(续)

类别:Java 点击:0 评论:0 推荐:

又朋友说我上篇说的太简单了,其实我本人及比较懒,不知不觉就把blog当作记流水账了。
下面详细说一下,平台(windows2000+sqlserver2000+msjdbc+weblogic+eclipse+lomoz),基本配置本文不作介绍,不明白者请google一下即可。
具体步骤:
1:首先去微软网站下在最新的jdbc驱动并且安装,要让它支持分布式事务你需要做以下事情(帮助文件中有)首先copy   msjdbc安装目录下\SQLServer JTA\sqljdbc.dll  到 sqlserver安装目录下\binn目录下面,然后打开查询分析器,装载 msjdbc安装目录下\SQLServer JTA\instjdbc.sql并执行,(可能需要重新启动)
2:在sqlserver中建立2个数据库,分别建立2个表。然后启动weblogic 控制台,建立2个connection pool分别指向前面的2个数据库,这里要注意要选择type 4xa的微软jdbc驱动程序,然后建立2个data source指向connection pool。
3:OK,现在我们就可以写程序了,在eclipse建立一个war类型的lomoz项目,server选择weblogc。
建立a.jsp ,这里说明一下,使用jta,只需要Context  ctx = new InitialContext(htx);   UserTransaction tx = (UserTransaction)  ctx.lookup("javax.transaction.UserTransaction"); 就可以使用tx了,下面就是a.jsp的例子,不过这个例子是不同是操作的,如果你想同时向2个数据库插入数据成功,将tx.rollback()修改为tx.commit()即可。

a.jsp代码如下
<%@ page language="java" import="java.sql.*,java.util.*,javax.naming.*,javax.transaction.*"%>
<!DOCTYPE HTML PUBLIC "-//w3c//dtd html 4.0 transitional//en">
<html>
<head>
<title>Lomboz JSP</title>
</head>
<body bgcolor="#FFFFFF">
<%
Context ctx = null; 
Hashtable htx = new Hashtable(); 
UserTransaction tx = null;
htx.put(Context.INITIAL_CONTEXT_FACTORY,"weblogic.jndi.WLInitialContextFactory"); 
htx.put(Context.PROVIDER_URL,"t3://localhost:7001");
Connection conn = null; 
Statement stmt = null; 
javax.sql.DataSource ds = null;

Connection connx = null; 
Statement stmtx = null; 
javax.sql.DataSource dsx = null;
 try{   
        ctx = new InitialContext(htx);   
        tx = (UserTransaction)  ctx.lookup("javax.transaction.UserTransaction"); 
        tx.begin();
       
        ds = (javax.sql.DataSource) ctx.lookup ("WeblogicOneSqlserverPool");   
        conn = ds.getConnection();
        stmt = conn.createStatement();       
        stmt.execute("insert into TUser values('x','x','x')");
       
       
        dsx = (javax.sql.DataSource) ctx.lookup ("WeblogicOneMysqlPool");   
        connx = dsx.getConnection();
        stmtx = connx.createStatement();       
        stmtx.execute("insert into user values('x','x','x')");
       
        tx.rollback();
 } 
 catch (Exception e) {    e.printStackTrace();   }
  finally { 
        try {     if(ctx != null)    ctx.close();     }
        catch (Exception e) {e.printStackTrace();}  
        try {     if (stmt != null) stmt.close();   }
        catch (Exception e) {       e.printStackTrace(); } 
        try {     if (conn != null) conn.close();   }
        catch (Exception e) {       e.printStackTrace(); }
        try {     if (stmtx != null) stmtx.close();   }
        catch (Exception e) {       e.printStackTrace(); } 
        try {     if (connx != null) connx.close();   }
        catch (Exception e) {       e.printStackTrace(); }
 }
%>
</body>
</html>
这只是测试,所以就简单的写在jsp页面中了,你可以根据你实际的不同需要来安排具体情况。

本文地址:http://com.8s8s.com/it/it14728.htm