spring，mybatis，atomikos多数据源的整合

骑猪看日落 2022-04-06 14:22 197阅读 0赞

原文：http://blog.chinaunix.net/uid-21162795-id-3424973.html

<bean id="abstractXADataSource" class="com.atomikos.jdbc.AtomikosDataSourceBean" init-method="init" 
                 destroy-method="close" abstract="true"> 
            <property name="xaDataSourceClassName" value="com.mysql.jdbc.jdbc2.optional.MysqlXADataSource"/> 
            <property name="poolSize" value="10" /> 
            <property name="minPoolSize" value="10"/> 
            <property name="maxPoolSize" value="30"/> 
            <property name="borrowConnectionTimeout" value="60"/> 
            <property name="reapTimeout" value="20"/> 
             
            <property name="maxIdleTime" value="60"/> 
            <property name="maintenanceInterval" value="60 />
            <property name="loginTimeout" value="60"/>
            <property name="logWriter" value="60"/>
            <property name="testQuery">
                <value>select 1</value>
            </property>
    
        </bean> 
        
        <bean id="dataSource" parent="abstractXADataSource">
        
            <property name="uniqueResourceName" value="mysql/sitestone" />
            <property name="xaDataSourceClassName"
                value="com.mysql.jdbc.jdbc2.optional.MysqlXADataSource" />
            <property name="xaProperties">
                <props>
                    <prop key="URL">${jdbc.url}</prop>
                    <prop key="user">${jdbc.username}</prop>
                    <prop key="password">${jdbc.password}</prop>
                </props>
            </property>
        </bean>
    
        
        <bean id="dataSourceB" parent="abstractXADataSource">
    
            <property name="uniqueResourceName" value="mysql/sitesttwo" />
            <property name="xaDataSourceClassName"
                value="com.mysql.jdbc.jdbc2.optional.MysqlXADataSource" />
            <property name="xaProperties">
                <props>
                    <prop key="URL">${jdbca.url}</prop>
                    <prop key="user">${jdbca.username}</prop>
                    <prop key="password">${jdbca.password}</prop>
                </props>
            </property>
        </bean>

配置sessionfactory

<bean id="sqlSessionFactoryB" class="org.mybatis.spring.SqlSessionFactoryBean">
    
    <property name="configLocation" value="classpath:configurationb.xml"/>
            <property name="mapperLocations" value="classpath*:/com/suntel/linkup/model/mappert/*Mapper.xml"/>
    
            <property name="dataSource" ref="dataSourceB" />
        </bean>
    
        <bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean">
            <property name="configLocation" value="classpath:configuration.xml"/>
            <property name="mapperLocations" value="classpath*:/com/suntel/linkup/model/mapper/*Mapper.xml"/>
            <property name="dataSource" ref="dataSource" />
        </bean>

为dao中选择相应的SqlSessionTemplate，给sqlsession注入相应的session工厂，这样dao和有相应的数据库可以连接了

事务  
<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="30000" />  
</bean>  
  
<bean id="springTransactionManager" class="org.springframework.transaction.jta.JtaTransactionManager">  
<property name="transactionManager">  
<ref bean="atomikosTransactionManager" />  
</property>  
<property name="userTransaction">  
<ref bean="atomikosUserTransaction" />  
</property>  
  
<property name="allowCustomIsolationLevels" value="true"/>  
</bean>  
  
  
<tx:annotation-driven transaction-manager="springTransactionManager" proxy-target-class="true" />  
  
<aop:aspectj-autoproxy />  
  
  
<aop:config proxy-target-class="true">  
<aop:advisor pointcut="execution(\* com.chainup.operate.service..\*.\*(..))" advice-ref="txAdvice"/>  
</aop:config>  
  
  
  
<tx:advice id="txAdvice" transaction-manager="springTransactionManager">  
<tx:attributes>  
<tx:method name="add\*" propagation="REQUIRED" rollback-for="Exception"/>  
<tx:method name="save\*" propagation="REQUIRED" rollback-for="Exception"/>  
<tx:method name="insert\*" propagation="REQUIRED" rollback-for="Exception"/>  
<tx:method name="create\*" propagation="REQUIRED" rollback-for="Exception"/>  
<tx:method name="del\*" propagation="REQUIRED" rollback-for="Exception"/>  
<tx:method name="update\*" propagation="REQUIRED" rollback-for="Exception"/>  
<tx:method name="modify\*" propagation="REQUIRED" rollback-for="Exception"/>  
<tx:method name="createOrder\*" propagation="REQUIRED" rollback-for="Exception"/>  
<tx:method name="cancel\*" propagation="REQUIRED" rollback-for="Exception"/>  
<tx:method name="pendingCancel\*" propagation="REQUIRED" rollback-for="Exception"/>  
<tx:method name="trade\*" propagation="REQUIRED" rollback-for="Exception"/>  
<tx:method name="\*" read-only="true"/>  
</tx:attributes>  
</tx:advice>  
原文：http://blog.chinaunix.net/uid-21162795-id-3424973.html