`
onlyor
  • 浏览: 381161 次
  • 性别: Icon_minigender_1
  • 来自: 南京
社区版块
存档分类
最新评论

spring mybatis jta jotm atomikos 配置

    博客分类：
  • java
jotm 2.2atomikos 3.7postgre xamysql xa 
阅读更多

 

<?xml version="1.0" encoding="UTF-8"?>

<beans xmlns="http://www.springframework.org/schema/beans"

xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:context="http://www.springframework.org/schema/context"

xmlns:aop="http://www.springframework.org/schema/aop" xmlns:tx="http://www.springframework.org/schema/tx"

xsi:schemaLocation="http://www.springframework.org/schema/beans 

http://www.springframework.org/schema/beans/spring-beans-2.0.xsd 

http://www.springframework.org/schema/context 

    http://www.springframework.org/schema/context/spring-context-2.0.xsd 

    http://www.springframework.org/schema/tx

    http://www.springframework.org/schema/tx/spring-tx-2.0.xsd

    http://www.springframework.org/schema/aop

    http://www.springframework.org/schema/aop/spring-aop-2.0.xsd"

default-lazy-init="true">

 

<!-- JOTM 数据源 

<bean id="jotm" class="com.demo.spring.jotm.jta.JotmFactoryBean" />

 

<bean id="springTransactionManager" class="org.springframework.transaction.jta.JtaTransactionManager">

<property name="userTransaction" ref="jotm" /> 

</bean>

<bean id="myDataSource1" class="org.enhydra.jdbc.pool.StandardXAPoolDataSource">

<property name="dataSource">

<bean class="org.enhydra.jdbc.standard.StandardXADataSource">

<property name="transactionManager">

<ref local="jotm" />

</property>

<property name="driverName">

<value>org.postgresql.Driver</value>

</property>

<property name="url">

<value>jdbc:postgresql://127.0.0.1:5432/test</value>

</property>

</bean>

</property>

<property name="user">

<value>postgres</value>

</property>

<property name="password">

<value>root</value>

</property>

<property name="maxSize">

<value>5</value>

</property>

<property name="minSize">

<value>2</value>

</property>

</bean>

<bean id="myDataSource2" class="org.enhydra.jdbc.pool.StandardXAPoolDataSource">

<property name="dataSource">

<bean class="org.enhydra.jdbc.standard.StandardXADataSource">

<property name="transactionManager">

<ref local="jotm" />

</property>

<property name="driverName">

<value>org.postgresql.Driver</value>

</property>

<property name="url">

<value>jdbc:postgresql://127.0.0.1:5432/news</value>

</property>

</bean>

</property>

<property name="user">

<value>postgres</value>

</property>

<property name="password">

<value>root</value>

</property>

<property name="maxSize">

<value>5</value>

</property>

<property name="minSize">

<value>2</value>

</property>

</bean>

-->

 

<!-- ATOMIKOS mysql 数据源 

<bean id="myDataSource1" class="com.atomikos.jdbc.AtomikosDataSourceBean">

<property name="uniqueResourceName">

<value>MYSQL/test</value>

</property>

<property name="xaDataSourceClassName">

<value>com.mysql.jdbc.jdbc2.optional.MysqlXADataSource</value>

</property>

<property name="xaProperties">

<props>

<prop key="user">root</prop>

<prop key="password">root</prop>

<prop key="URL">jdbc:mysql://127.0.0.1:3306/test</prop>

</props>

</property>

</bean>

<bean id="myDataSource2" class="com.atomikos.jdbc.AtomikosDataSourceBean">

<property name="uniqueResourceName">

<value>MYSQL/news</value>

</property>

<property name="xaDataSourceClassName">

<value>com.mysql.jdbc.jdbc2.optional.MysqlXADataSource</value>

</property>

<property name="xaProperties">

<props>

<prop key="user">root</prop>

<prop key="password">root</prop>

<prop key="URL">jdbc:mysql://127.0.0.1:3306/news</prop>

</props>

</property>

</bean>

-->

 

<!-- ATOMIKOS postgres 数据源 -->

<bean id="myDataSource1" class="com.atomikos.jdbc.AtomikosDataSourceBean">

<property name="uniqueResourceName">

<value>postgre/test</value>

</property>

<property name="xaDataSourceClassName">

<value>org.postgresql.xa.PGXADataSource</value>

</property>

<property name="xaProperties">

<props>

<prop key="user">postgres</prop>

<prop key="password">root</prop>

<prop key="databaseName">test</prop>

<prop key="serverName">127.0.0.1</prop>

<prop key="portNumber">5432</prop>

</props>

</property>

</bean>

<bean id="myDataSource2" class="com.atomikos.jdbc.AtomikosDataSourceBean">

<property name="uniqueResourceName">

<value>postgre/news</value>

</property>

<property name="xaDataSourceClassName">

<value>org.postgresql.xa.PGXADataSource</value>

</property>

<property name="xaProperties">

<props>

<prop key="user">postgres</prop>

<prop key="password">root</prop>

<prop key="databaseName">news</prop>

<prop key="serverName">127.0.0.1</prop>

<prop key="portNumber">5432</prop>

</props>

</property>

</bean>

 

 

<bean id="sqlSessionFactory1" class="org.mybatis.spring.SqlSessionFactoryBean">

<property name="configLocation" value="classpath:config1.xml" />

<property name="dataSource" ref="myDataSource1" />

</bean>

 

<bean id="sqlSessionFactory2" class="org.mybatis.spring.SqlSessionFactoryBean">

<property name="configLocation" value="classpath:config2.xml" />

<property name="dataSource" ref="myDataSource2" />

</bean>

 

<bean id="userDAO" class="com.anxin.dao.impl.UserDAOImpl">

<property name="sqlSessionFactory" ref="sqlSessionFactory1" />

</bean>

 

<bean id="studentDAO" class="com.anxin.dao.impl.StudentDAOImpl">

<property name="sqlSessionFactory" ref="sqlSessionFactory2" />

</bean>

 

<bean id="studentService" class="com.anxin.service.impl.StudentServiceImpl">

<property name="dao" ref="studentDAO" />

</bean>

 

<bean id="userService" class="com.anxin.service.impl.UserServiceImpl">

<property name="dao" ref="userDAO" />

</bean>

 

<bean id="complexService" class="com.anxin.service.impl.ComplexServiceImpl">

<property name="userDao" ref="userDAO" />

<property name="studentDao" ref="studentDAO" />

</bean>

 

<!-- atomikosTransactionManager -->

<bean id="atomikosTransactionManager" class="com.atomikos.icatch.jta.UserTransactionManager"

init-method="init" destroy-method="close">

<property name="forceShutdown">

<value>true</value>

</property>

</bean>

 

<bean id="atomikosUserTransaction" class="com.atomikos.icatch.jta.UserTransactionImp">

<property name="transactionTimeout">

<value>300</value>

</property>

</bean>

 

<bean id="springTransactionManager" class="org.springframework.transaction.jta.JtaTransactionManager">

<property name="transactionManager">

<ref bean="atomikosTransactionManager" />

</property>

<property name="userTransaction">

<ref bean="atomikosUserTransaction" />

</property>

</bean>

 

<aop:config>

<aop:pointcut id="pc" expression="execution(* com.anxin.service.*.*(..))" />

<aop:advisor advice-ref="txAdvice" pointcut-ref="pc" />

</aop:config>

 

<tx:advice id="txAdvice" transaction-manager="springTransactionManager">

<tx:attributes>

<tx:method name="get*" propagation="REQUIRED" read-only="true" />

<tx:method name="find*" propagation="REQUIRED" read-only="true" />

<tx:method name="has*" propagation="REQUIRED" read-only="true" />

<tx:method name="locate*" propagation="REQUIRED" read-only="true" />

<tx:method name="*" propagation="REQUIRED" rollback-for="Exception" />

</tx:attributes>

</tx:advice>

 

<!-- 手动代理

<bean id="transactionProxyFactoryBean" class="org.springframework.transaction.interceptor.TransactionProxyFactoryBean" 

abstract="true"> 

<property name="transactionManager"> 

<ref bean="springTransactionManager" /> 

</property> 

<property name="transactionAttributes"> 

<props> 

<prop key="save*">PROPAGATION_REQUIRED,-Exception</prop> 

</props>

</property> 

</bean> 

<bean id="complexServiceProxy" parent="transactionProxyFactoryBean"> 

<property name="target"> 

<ref bean="complexService" /> 

</property> 

</bean>

-->

 

 

</beans>

分享到：
| sql server 列索引
评论
发表评论

您还没有登录,请您登录后再发表评论

相关推荐

    spring+mybatis+atomikos配置文件及相关包（最新版）

    4. 配置数据源：为每个参与分布式事务的数据源创建AtomikosManagedDataSource实例，并在Spring配置中声明。 5. 配置MyBatis：配置MyBatis的SqlSessionFactory，使用Atomikos数据源，并在Mapper配置中启用事务。 6....

    spring+mybatis+atomikos配置文件及相关包

    同时，你需要在MyBatis的配置中启用JTA事务管理，确保Spring和Atomikos能够协同工作。这样，当你的应用执行跨库操作时，Atomikos会自动管理这些操作，保证其在分布式环境下的原子性、一致性、隔离性和持久性。 综上...

    spring+mybatis+atomikos配置所需包跟配置文件

    综上所述，Spring、MyBatis和Atomikos的集成主要涉及JTA标准的运用、Atomikos的配置以及Spring的事务管理。通过这种方式，可以实现在分布式环境下的事务一致性，确保多数据源操作的正确性。在实际开发中，根据具体的...

    spring+mybatis+atomikos配置文件及相关包.rar

    - 在Spring配置文件中声明SqlSessionTemplate或SqlSessionDaoSupport，这两个类是Spring对Mybatis的进一步封装，提供了事务管理功能。 2. **Atomikos的引入** - Atomikos提供了UserTransaction接口，用于开始、...

    Spring+MyBatis+Atomikos实现JTA分布式事务

    在Spring配置中，可以将MyBatis的SqlSessionFactory配置为受Spring管理，并开启事务支持。这样，当一个事务开始时，Spring会自动管理SqlSessionFactory的打开和关闭，以及在事务边界内的SQL执行。 为了使用Atomikos...

    Spring Boot + Druid + Mybatis + Atomikos 配置多数据源 并支持分布式事务

    本教程将探讨如何利用Spring Boot、Druid、Mybatis以及Atomikos来配置多数据源并实现分布式事务。 首先，Spring Boot是Java生态系统中的一个流行框架，它简化了设置和配置过程，使得开发人员可以快速启动新项目。在...

    springboot+mybatis+jta+atomikos解决多数据源事务问题.pdf

    本篇文档主要讲述如何使用Spring Boot结合MyBatis、JTA（Java Transaction API）以及Atomikos实现多数据源的事务管理。 ### Spring Boot框架 Spring Boot是Spring家族中的一个全新框架，用于简化新Spring应用的...

    SpringBoot+mybatisPlus+atomikos+druid.zip

    Spring Boot：mybatis-plus + atomikos + druid 实现不同实例数据库的多数据源配置和分布式事务管理（demo项目），想到工作上可能会用到多数据源，但是自己在这方面并不是很熟悉，于是在网上查阅了很多文章，结果...

    spring+mybatis+Atomikos JTA事务配置说明

    NULL 博文链接：https://lizhao6210-126-com.iteye.com/blog/1958831

    spring、mybatis、atomikos实现DB2、Mysql多数据源事务demo

    本示例中的"spring、mybatis、atomikos实现DB2、Mysql多数据源事务demo"提供了一个实用的框架，演示了如何在Spring框架中结合MyBatis持久层框架以及Atomikos事务管理器来处理来自DB2和MySQL两个不同数据库的数据源...

    spring、mybatis、atomikos实现多数据源事务demo

    1. 配置Atomikos：在Spring配置文件中引入Atomikos的相关依赖，配置两个UserTransaction和XAPool，分别对应两个数据源。 2. 定义数据源：为每个数据库创建一个DataSource bean，并配置相应的数据库连接信息。 3. ...

    spring mybatis atomikos 多库分布式事务demo

    然后，对于MyBatis，我们需要配置SqlSessionFactoryBean，并设置其数据源为Atomikos的JTA数据源。这样，MyBatis的操作将在同一个全局事务内进行： ```xml &lt;bean id="sqlSessionFactory" class="org.mybatis.spring....

    分布式事务操作之Spring+JTA+mybatis源码

    - 如何在Spring配置文件中设置JTA事务管理器。 - MyBatis是如何与JTA配合进行事务控制的，比如在XML映射文件或Mapper接口中定义的事务边界。 - JTA事务的开始、提交、回滚过程，以及异常传播规则。 - 如何处理...

    后端基于springmybatis的微信小程序商城

    后端基于springmybatis的微信小程序商城后端基于springmybatis的微信小程序商城后端基于springmybatis的微信小程序商城后端基于springmybatis的微信小程序商城后端基于springmybatis的微信小程序商城后端基于spring...

    Spring+Mybatis+Atomikos实现JAVA初始化并控制多个数据源+分布式事务

    这个项目可能包含了Spring配置文件，定义了数据源和事务管理器；Mybatis的相关配置，如Mapper接口和XML配置文件；以及业务逻辑代码，展示了如何在Spring和Mybatis的基础上，利用Atomikos处理分布式事务。 总的来说...

    Spring+SpringMVC+MyBatis+Atomikos整合

    2. 集成Atomikos：在Spring配置中引入Atomikos的事务管理器，配置全局事务超时、事务日志路径等参数，确保Atomikos可以在多数据源环境下正确处理分布式事务。 3. 配置MyBatis：将MyBatis的SqlSessionFactory与...

    SpringMVC+Spring+MyBatis jar包和配置文件

    6. 配置Spring与MyBatis的集成：使用MyBatis-Spring的SqlSessionTemplate或SqlSessionFactoryBean。 在提供的压缩包中，文件可能包括Spring、SpringMVC和MyBatis的jar包，以及相关的配置文件，例如spring-context....

    Spring配置JTA事务管理

    Spring框架在企业级Java应用中广泛用于实现...总的来说，Spring配置JTA事务管理是一项关键任务，它确保了在分布式环境下的数据一致性。理解并正确配置JTA事务管理，能够让你的应用程序更加健壮，适应复杂的企业级需求。

    Spring MyBatis企业应用实战pdf书籍

    接下来，重点讲解了Spring与MyBatis的集成过程，包括Spring的DataSource配置、事务管理、以及MyBatis-Spring的使用，让读者了解如何在Spring环境中优雅地使用MyBatis进行数据访问。此外，书中还会涉及Spring MVC的...

Magicbox
Global site tag (gtag.js) - Google Analytics