spring，mybatis，atomikos多數(shù)據(jù)源的整合

instl 2015-06-10

展開全文

由于在接下來的項目中要用到多數(shù)據(jù)源，我負責(zé)這塊的工作，所以查了一下資料，但是網(wǎng)上的資料還多都是千篇一律，抄襲過去，抄襲過來，所以自己試著成功了，希望對有需要的人幫助，如果有不正確的地方請扔磚頭，經(jīng)測試成功。話入正題。了解spring的大蝦門肯定一看就知道這個原理，所以我就沒有貼太多的注解了。如果有需要的可以留言交流

一、spring3.0.5，mybatis3.0.5、的包都不多說了，需要引入關(guān)于atomikos的包如下

二、關(guān)于spring的applicationcontext的配置：

讀取數(shù)據(jù)庫的信息

點擊(此處)折疊或打開

<bean id="propertyConfigurer" class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
<property name="locations">
<list>
<value>classpath*:jdbc.properties</value>
</list>
</property>
</bean>

jdbc.properties的配置文件

點擊(此處)折疊或打開

jdbc.username=root
jdbc.password=123456
jdbc.url=jdbc:mysql://192.168.1.8:3310/sitestone?useUnicode=true&characterEncoding=utf-8
jdbc.driver=com.mysql.jdbc.Driver
jdbca.url=jdbc:mysql://192.168.1.8:3310/sitesttwo?useUnicode=true&characterEncoding=utf-8
jdbca.username=root
jdbca.password=123456
jdbca.driver=com.mysql.jdbc.Driver

配置mysql的兩個數(shù)據(jù)源

點擊(此處)折疊或打開

<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中選擇相應(yīng)的SqlSessionTemplate，給sqlsession注入相應(yīng)的session工廠，這樣dao和有相應(yīng)的數(shù)據(jù)庫可以連接了

點擊(此處)折疊或打開

<bean id="sqlSession" class="org.mybatis.spring.SqlSessionTemplate">
<constructor-arg index="0" ref="sqlSessionFactory" />
</bean>
<bean id="sqlSessionb" class="org.mybatis.spring.SqlSessionTemplate">
<constructor-arg index="0" ref="sqlSessionFactoryB" />
</bean>

舉例說下關(guān)于dao的調(diào)用，注意下劃線的地方；

點擊(此處)折疊或打開

private SqlSession sqlSessionb;
public T create(String sql_ID,T entity) {
this.getSqlSessionb().insert(sql_ID, entity);
return entity;
}
public SqlSession getSqlSessionb() {
return sqlSessionb;
}
public void setSqlSessionb(SqlSession sqlSessionb) {
this.sqlSessionb = sqlSessionb;
}
這兒得sqlSessionb是和spring配置文件中的
<bean id="sqlSessionb" class="org.mybatis.spring.SqlSessionTemplate">
<constructor-arg index="0" ref="sqlSessionFactoryB" />
</bean> 相對用的，名稱和bean中的id要相同，
調(diào)用另一個數(shù)據(jù)session也是一樣的原理：private SqlSession sqlSession;
    public SqlSession getSqlSession() {
        return sqlSession;
    }

    public void setSqlSession(SqlSession sqlSession) {
        this.sqlSession = sqlSession;
    }
<bean id="sqlSession" class="org.mybatis.spring.SqlSessionTemplate">
<constructor-arg index="0" ref="sqlSessionFactory" />
</bean>

配置事務(wù)

點擊(此處)折疊或打開

<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" />
</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>
<aop:aspectj-autoproxy />
<aop:config proxy-target-class="true">
<aop:advisor pointcut="execution(* com.suntel.linkup.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="*" read-only="true"/>
</tx:attributes>
</tx:advice>