- 浏览: 1041218 次
- 性别:
- 来自: 长沙
文章分类
- 全部博客 (639)
- 服务器配置篇 (58)
- hibernate篇 (14)
- spring篇 (33)
- struts篇 (28)
- JS篇 (46)
- 其他技术篇 (46)
- 数据库集群配置 (6)
- JAVA基础相关 (48)
- 分布式框架HadHoop的应用 (2)
- FLEX篇 (8)
- SQLSERVER技术 (32)
- Android学习 (13)
- amchart学习笔记 (1)
- openfire+smark搭建即时通讯 (9)
- Linux学习 (18)
- Oracle数据库 (15)
- 网站优化技术 (12)
- mysql数据库 (2)
- 项目学习总结 (18)
- 工具类(JAVA) (12)
- 工具类(JS) (2)
- 设计模式 (10)
- Lucene学习 (24)
- EJB3学习 (6)
- Sphinx搜索引擎 (3)
- 工作中用到的软件小工具 (5)
- .NET (49)
- JAVA 连接SQLSERVER2008步骤 (1)
- MongoDB (19)
- Android手机开发 (3)
- Maven (6)
- vue (9)
- Shiro (4)
- mybatis (3)
- netty框架 (1)
- SpringCloud (3)
- spring-cloud (7)
- Git (1)
- dubbo (2)
- springboot (13)
- rocketmq (1)
- git学习 (2)
- kafka服务器 (2)
- linux (10)
- WEB系统辅助项目 (1)
- jenkins (2)
- docker (4)
- influxdb (3)
- python (2)
- nginx (1)
最新评论
-
jiangfuofu555:
这样数据量大,效率怎么样?
sqlserver 实现分页的前台代码 以及后台的sqlserver语句 -
w156445045:
博主请问下,如何做到实时的刷新呢,
另外我后台是Java 谢谢 ...
web 版本的汽车仪表盘,非常好看。还有各种图形 -
jackyin5918:
<transportConnector name=&qu ...
ActiveMQ的activemq.xml详细配置讲解 -
握着橄榄枝的人:
你这个不是spring1.x的吧
spring1.x使用AOP实例 -
xiaophai:
全乱套了!
openfire+spark搭建完美的及时通讯
测试环境:mysql-5.5.14,Oracle 10g Express,ow2-jotm-dist-2.1.9,JDK7,Win7
1,背景说明:两个数据库中分别有一张用户表,表结构设计类似,如下:
MySQL中:
CREATE TABLE TUSER ( id INT, name VARCHAR(10) NOT NULL, PRIMARY KEY (id) )
Oracle中:
2,新建Java Project,将两个数据库的驱动以及jotm中lib目录下的相关jar文件加入buildpath中
3,编写实体类
- package com.tanlan.jta.entity;
- public class User {
- private int id;
- private String name;
- public int getId() {
- return id;
- }
- public void setId(int id) {
- this.id = id;
- }
- public String getName() {
- return name;
- }
- public void setName(String name) {
- this.name = name;
- }
- }
package com.tanlan.jta.entity; public class User { private int id; private String name; public int getId() { return id; } public void setId(int id) { this.id = id; } public String getName() { return name; } public void setName(String name) { this.name = name; } }
4,编写DAO
- package com.tanlan.jta.dao;
- import java.sql.Connection;
- import java.sql.PreparedStatement;
- import java.sql.SQLException;
- import com.tanlan.jta.entity.User;
- public class UserDAO {
- /**
- * 增加用户信息到MySQL数据库中
- *
- * @param user
- * @param connection
- * @throws SQLException
- */
- public void addUserToMySQL(User user, Connection connection)
- throws SQLException {
- String sql = "insert into TUser values(?,?)";
- PreparedStatement pstmt = connection.prepareStatement(sql);
- pstmt.setInt(1, user.getId());
- pstmt.setString(2, user.getName());
- pstmt.execute();
- }
- /**
- * 增加用户信息到Oracle数据库中
- *
- * @param user
- * @param connection
- * @throws SQLException
- */
- public void addUserToOracle(User user, Connection connection)
- throws SQLException {
- String sql = "insert into TUser values(?,?)";
- PreparedStatement pstmt = connection.prepareStatement(sql);
- pstmt.setInt(1, user.getId());
- pstmt.setString(2, user.getName());
- pstmt.execute();
- }
- }
package com.tanlan.jta.dao; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.SQLException; import com.tanlan.jta.entity.User; public class UserDAO { /** * 增加用户信息到MySQL数据库中 * * @param user * @param connection * @throws SQLException */ public void addUserToMySQL(User user, Connection connection) throws SQLException { String sql = "insert into TUser values(?,?)"; PreparedStatement pstmt = connection.prepareStatement(sql); pstmt.setInt(1, user.getId()); pstmt.setString(2, user.getName()); pstmt.execute(); } /** * 增加用户信息到Oracle数据库中 * * @param user * @param connection * @throws SQLException */ public void addUserToOracle(User user, Connection connection) throws SQLException { String sql = "insert into TUser values(?,?)"; PreparedStatement pstmt = connection.prepareStatement(sql); pstmt.setInt(1, user.getId()); pstmt.setString(2, user.getName()); pstmt.execute(); } }
5,编写帮助类,实现启动与停止事务管理服务,以及取得数据库连接:
- package com.tanlan.jta.dao;
- import java.sql.Connection;
- import javax.naming.NamingException;
- import javax.sql.XAConnection;
- import javax.transaction.UserTransaction;
- import org.enhydra.jdbc.standard.StandardXADataSource;
- import org.objectweb.jotm.Jotm;
- import org.objectweb.transaction.jta.TMService;
- public class JotmHelper {
- private TMService jotm;
- private UserTransaction userTransaction;
- /**
- * 启动事务管理服务
- */
- public void startTMService() {
- try {
- jotm = new Jotm(true, false);
- userTransaction = jotm.getUserTransaction();
- } catch (NamingException e1) {
- e1.printStackTrace();
- }
- }
- /**
- * 取得数据库连接
- *
- * @param db
- * @return
- * @throws Exception
- */
- public Connection getConnection(String db) throws Exception {
- StandardXADataSource xads = new StandardXADataSource();
- XAConnection xaconn = null;
- if ("mysql".equals(db)) {
- xads.setDriverName("com.mysql.jdbc.Driver");
- xads.setUrl("jdbc:mysql://localhost/test");
- xads.setTransactionManager(jotm.getTransactionManager());
- xaconn = xads.getXAConnection("root", "root");
- } else if ("oracle".equals(db)) {
- xads.setDriverName("oracle.jdbc.driver.OracleDriver");
- xads.setUrl("jdbc:oracle:thin:@localhost:1521:XE");
- xads.setTransactionManager(jotm.getTransactionManager());
- xaconn = xads.getXAConnection("tanlan", "tanlan");
- } else {
- }
- return xaconn.getConnection();
- }
- public void begin() {
- try {
- userTransaction.begin();
- } catch (Exception e) {
- e.printStackTrace();
- }
- }
- public void commit() {
- try {
- userTransaction.commit();
- } catch (Exception e) {
- e.printStackTrace();
- }
- }
- public void rollback() {
- try {
- userTransaction.rollback();
- } catch (Exception e) {
- e.printStackTrace();
- }
- }
- /**
- * 停止事务管理服务
- */
- public void stopTMService() {
- jotm.stop();
- jotm = null;
- }
- }
package com.tanlan.jta.dao; import java.sql.Connection; import javax.naming.NamingException; import javax.sql.XAConnection; import javax.transaction.UserTransaction; import org.enhydra.jdbc.standard.StandardXADataSource; import org.objectweb.jotm.Jotm; import org.objectweb.transaction.jta.TMService; public class JotmHelper { private TMService jotm; private UserTransaction userTransaction; /** * 启动事务管理服务 */ public void startTMService() { try { jotm = new Jotm(true, false); userTransaction = jotm.getUserTransaction(); } catch (NamingException e1) { e1.printStackTrace(); } } /** * 取得数据库连接 * * @param db * @return * @throws Exception */ public Connection getConnection(String db) throws Exception { StandardXADataSource xads = new StandardXADataSource(); XAConnection xaconn = null; if ("mysql".equals(db)) { xads.setDriverName("com.mysql.jdbc.Driver"); xads.setUrl("jdbc:mysql://localhost/test"); xads.setTransactionManager(jotm.getTransactionManager()); xaconn = xads.getXAConnection("root", "root"); } else if ("oracle".equals(db)) { xads.setDriverName("oracle.jdbc.driver.OracleDriver"); xads.setUrl("jdbc:oracle:thin:@localhost:1521:XE"); xads.setTransactionManager(jotm.getTransactionManager()); xaconn = xads.getXAConnection("tanlan", "tanlan"); } else { } return xaconn.getConnection(); } public void begin() { try { userTransaction.begin(); } catch (Exception e) { e.printStackTrace(); } } public void commit() { try { userTransaction.commit(); } catch (Exception e) { e.printStackTrace(); } } public void rollback() { try { userTransaction.rollback(); } catch (Exception e) { e.printStackTrace(); } } /** * 停止事务管理服务 */ public void stopTMService() { jotm.stop(); jotm = null; } }
6,测试代码
- package com.tanlan.jta.test;
- import java.sql.Connection;
- import com.tanlan.jta.dao.JotmHelper;
- import com.tanlan.jta.dao.UserDAO;
- import com.tanlan.jta.entity.User;
- public class TestUSer {
- public static void main(String[] args) {
- User user=new User();
- user.setId(300);
- user.setName("a122456");
- UserDAO dao = new UserDAO();
- JotmHelper helper = new JotmHelper();
- try {
- helper.startTMService();
- Connection mysqlConn = helper.getConnection("mysql");
- Connection oracleConn = helper.getConnection("oracle");
- helper.begin();
- dao.addUserToMySQL(user, mysqlConn);
- dao.addUserToOracle(user, oracleConn);
- helper.commit();
- } catch (Exception e) {
- helper.rollback();
- e.printStackTrace();
- } finally {
- helper.stopTMService();
- }
- }
- }
package com.tanlan.jta.test; import java.sql.Connection; import com.tanlan.jta.dao.JotmHelper; import com.tanlan.jta.dao.UserDAO; import com.tanlan.jta.entity.User; public class TestUSer { public static void main(String[] args) { User user=new User(); user.setId(300); user.setName("a122456"); UserDAO dao = new UserDAO(); JotmHelper helper = new JotmHelper(); try { helper.startTMService(); Connection mysqlConn = helper.getConnection("mysql"); Connection oracleConn = helper.getConnection("oracle"); helper.begin(); dao.addUserToMySQL(user, mysqlConn); dao.addUserToOracle(user, oracleConn); helper.commit(); } catch (Exception e) { helper.rollback(); e.printStackTrace(); } finally { helper.stopTMService(); } } }经过测试,这种方法能够较好的控制对两个数据库操作数据的事务。
发表评论
-
非关系型数据库
2011-09-29 22:53 947随着互联网web2.0网站的兴起,非关系型的数据库现在成了一个 ... -
部署SQLSERVER2005群集
2011-02-21 08:46 949部署SQLSERVER2005群集 -
Squoia的后台管理
2008-11-19 17:12 1102虚拟数据库管理界面: 1. 在你的虚拟数据库安装目录中(我的 ... -
在做数据库集群的时候碰到的问题(连载一)
2008-11-19 17:03 1123[Sequoia] Not Starting VDB (Not ... -
Squoia集群数据库的安装
2008-11-19 16:57 1561Squoia是C-JDBC的一个子项 ...
相关推荐
2.Spring+Jotm整合实现JTA分布式事务,应用场景如转账等,同一事务内完成db1用户加100元、db2用户减100元。 3.Spring+Junit4单元测试,优点:不会破坏数据库现场,等等。 (特别注意:Spring3.0里不在提供对jotm的...
1 通过集成JOTM,直接在Spring中使用JTA事务 1.1. 将JOTM以下类库添加到类路径中 1.2. 编写JOTM配置文件,放到类路径下 1.3. 在MySQL上建立两个数据库 1.4. 在Spring配置文件中配置JOTM 1.5. 在Spring中运行测试 2 ...
例子虽小,可覆盖面广,设计spring载入.properties文件,spring配置jta和jotm分布式事务,设置数据源连接池,注解事务驱动。功能是在mysql上建立了两个数据库分别为dbone和dbtwo,在dbone里有表tb1,表中只有一个字段...
这就是正在实现的目标,目前我还没有将它分布在多个数据库上,并且只使用内部数据库作为测试的一部分:(下次有时间时将结合使用 mysql)Java:模型/Grails:域类: 在这方面,域类不是 Grails 的要求。 转换为...
Atomikos,JOTM 等框架 实现了 TCC 协议的框架有 Sharding、EasyTransaction、tcc-transaction 等框架 对于 XA 协议来说,它使用的是 2PC 协议的方式,是阻塞式的,并且它还依赖于数据库自身提供的 XA 接口的可靠性...
开发它是用于在UTF-8 Oracle实例中使用ASCII编码的Oracle 数据库中来正确的传输非ASCII字符。 Java模板语言 Beetl Beetl,是Bee Template Language的缩写,它绝不是简单的另外一种模板引擎,而是新一代的模板引擎,...
开发它是用于在UTF-8 Oracle实例中使用ASCII编码的Oracle 数据库中来正确的传输非ASCII字符。 Java模板语言 Beetl Beetl,是Bee Template Language的缩写,它绝不是简单的另外一种模板引擎,而是新一代的模板引擎,...
开发它是用于在UTF-8 Oracle实例中使用ASCII编码的Oracle 数据库中来正确的传输非ASCII字符。 Java模板语言 Beetl Beetl,是Bee Template Language的缩写,它绝不是简单的另外一种模板引擎,而是新一代的模板引擎,...
开发它是用于在UTF-8 Oracle实例中使用ASCII编码的Oracle 数据库中来正确的传输非ASCII字符。 Java模板语言 Beetl Beetl,是Bee Template Language的缩写,它绝不是简单的另外一种模板引擎,而是新一代的模板引擎,...
开发它是用于在UTF-8 Oracle实例中使用ASCII编码的Oracle 数据库中来正确的传输非ASCII字符。 Java模板语言 Beetl Beetl,是Bee Template Language的缩写,它绝不是简单的另外一种模板引擎,而是新一代的模板引擎,...
开发它是用于在UTF-8 Oracle实例中使用ASCII编码的Oracle 数据库中来正确的传输非ASCII字符。 Java模板语言 Beetl Beetl,是Bee Template Language的缩写,它绝不是简单的另外一种模板引擎,而是新一代的模板引擎,...
开发它是用于在UTF-8 Oracle实例中使用ASCII编码的Oracle 数据库中来正确的传输非ASCII字符。 Java模板语言 Beetl Beetl,是Bee Template Language的缩写,它绝不是简单的另外一种模板引擎,而是新一代的模板引擎,...
开发它是用于在UTF-8 Oracle实例中使用ASCII编码的Oracle 数据库中来正确的传输非ASCII字符。 Java模板语言 Beetl Beetl,是Bee Template Language的缩写,它绝不是简单的另外一种模板引擎,而是新一代的模板引擎,...
开发它是用于在UTF-8 Oracle实例中使用ASCII编码的Oracle 数据库中来正确的传输非ASCII字符。 Java模板语言 Beetl Beetl,是Bee Template Language的缩写,它绝不是简单的另外一种模板引擎,而是新一代的模板引擎,...
开发它是用于在UTF-8 Oracle实例中使用ASCII编码的Oracle 数据库中来正确的传输非ASCII字符。 Java模板语言 Beetl Beetl,是Bee Template Language的缩写,它绝不是简单的另外一种模板引擎,而是新一代的模板引擎,...
开发它是用于在UTF-8 Oracle实例中使用ASCII编码的Oracle 数据库中来正确的传输非ASCII字符。 Java模板语言 Beetl Beetl,是Bee Template Language的缩写,它绝不是简单的另外一种模板引擎,而是新一代的模板引擎,...
2个目标文件,FTP的目标是:(1)提高文件的共享性(计算机程序和/或数据),(2)鼓励间接地(通过程序)使用远程计算机,(3)保护用户因主机之间的文件存储系统导致的变化,(4)为了可靠和高效地传输,虽然用户...
开发它是用于在UTF-8 Oracle实例中使用ASCII编码的Oracle 数据库中来正确的传输非ASCII字符。 Java模板语言 Beetl Beetl,是Bee Template Language的缩写,它绝不是简单的另外一种模板引擎,而是新一代的模板引擎,...
开发它是用于在UTF-8 Oracle实例中使用ASCII编码的Oracle 数据库中来正确的传输非ASCII字符。 Java模板语言 Beetl Beetl,是Bee Template Language的缩写,它绝不是简单的另外一种模板引擎,而是新一代的模板引擎,...