小男孩‘自慰网亚洲一区二区,亚洲一级在线播放毛片,亚洲中文字幕av每天更新,黄aⅴ永久免费无码,91成人午夜在线精品,色网站免费在线观看,亚洲欧洲wwwww在线观看

搜索
分享

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

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

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

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

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

點(diǎn)擊(此處)折疊或打開

  1. <!--屬性文件讀入,使用JdbcPlaceholderConfigurer則可以從數(shù)據(jù)庫(kù)讀取配置信息 -->
  2.     <bean id="propertyConfigurer" class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
  3.         <property name="locations">
  4.             <list>
  5.                 <value>classpath*:jdbc.properties</value>
  6.             </list>
  7.         </property>
  8.     </bean>
jdbc.properties的配置文件

點(diǎn)擊(此處)折疊或打開

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

  6. jdbca.url=jdbc:mysql://192.168.1.8:3310/sitesttwo?useUnicode=true&characterEncoding=utf-8
  7. jdbca.username=root
  8. jdbca.password=123456
  9. jdbca.driver=com.mysql.jdbc.Driver
配置mysql的兩個(gè)數(shù)據(jù)源

點(diǎn)擊(此處)折疊或打開

  1. <!-- 兩個(gè)數(shù)據(jù)源的功用配置，方便下面直接引用 -->
  2.      <bean id="abstractXADataSource" class="com.atomikos.jdbc.AtomikosDataSourceBean" init-method="init"
  3.              destroy-method="close" abstract="true">
  4.         <property name="xaDataSourceClassName" value="com.mysql.jdbc.jdbc2.optional.MysqlXADataSource"/>
  5.         <property name="poolSize" value="10" />
  6.         <property name="minPoolSize" value="10"/>
  7.         <property name="maxPoolSize" value="30"/>
  8.         <property name="borrowConnectionTimeout" value="60"/>
  9.         <property name="reapTimeout" value="20"/>
  10.         <!-- 最大空閑時(shí)間 -->
  11.         <property name="maxIdleTime" value="60"/>
  12.         <property name="maintenanceInterval" value="60 />
  13.         <property name="loginTimeout" value="60"/>
  14.         <property name="logWriter" value="60"/>
  15.         <property name="testQuery">
  16.             <value>select 1</value>
  17.         </property>
  18.         
  19.     </bean>
  20.     <!-- 配置第一個(gè)數(shù)據(jù)源 -->
  21.     <bean id="dataSource" parent="abstractXADataSource">
  22.     <!-- value只要兩個(gè)數(shù)據(jù)源不同就行，隨便取名 -->
  23.         <property name="uniqueResourceName" value="mysql/sitestone" />
  24.         <property name="xaDataSourceClassName"
  25.             value="com.mysql.jdbc.jdbc2.optional.MysqlXADataSource" />
  26.         <property name="xaProperties">
  27.             <props>
  28.                 <prop key="URL">${jdbc.url}</prop>
  29.                 <prop key="user">${jdbc.username}</prop>
  30.                 <prop key="password">${jdbc.password}</prop>
  31.             </props>
  32.         </property>
  33.     </bean>

  35.     <!-- 配置第二個(gè)數(shù)據(jù)源-->
  36.     <bean id="dataSourceB" parent="abstractXADataSource">
  37. <!-- value只要兩個(gè)數(shù)據(jù)源不同就行，隨便取名 -->
  38.         <property name="uniqueResourceName" value="mysql/sitesttwo" />
  39.         <property name="xaDataSourceClassName"
  40.             value="com.mysql.jdbc.jdbc2.optional.MysqlXADataSource" />
  41.         <property name="xaProperties">
  42.             <props>
  43.                 <prop key="URL">${jdbca.url}</prop>
  44.                 <prop key="user">${jdbca.username}</prop>
  45.                 <prop key="password">${jdbca.password}</prop>
  46.             </props>
  47.         </property>
  48.     </bean>
配置sessionfactory


點(diǎn)擊(此處)折疊或打開

  1. <!-- 配置mybatis的SessionFactory -->
  2.     <bean id="sqlSessionFactoryB" class="org.mybatis.spring.SqlSessionFactoryBean">
  3.         <!--mybatis的總配置文件-->
  4. <property name="configLocation" value="classpath:configurationb.xml"/>
  5. <!--掃描mybatis的寫sql的mapper文件-->
  6.         <property name="mapperLocations" value="classpath*:/com/suntel/linkup/model/mappert/*Mapper.xml"/>
  7. <!----選擇數(shù)據(jù)源------>
  8.         <property name="dataSource" ref="dataSourceB" />
  9.     </bean>

  11.     <bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean">
  12.         <property name="configLocation" value="classpath:configuration.xml"/>
  13.         <property name="mapperLocations" value="classpath*:/com/suntel/linkup/model/mapper/*Mapper.xml"/>
  14.         <property name="dataSource" ref="dataSource" />
  15.     </bean>
為dao中選擇相應(yīng)的SqlSessionTemplate，給sqlsession注入相應(yīng)的session工廠，這樣dao和有相應(yīng)的數(shù)據(jù)庫(kù)可以連接了

點(diǎn)擊(此處)折疊或打開

  1. <bean id="sqlSession" class="org.mybatis.spring.SqlSessionTemplate">
  2.             <constructor-arg index="0" ref="sqlSessionFactory" />
  3.         </bean>
  4.         <bean id="sqlSessionb" class="org.mybatis.spring.SqlSessionTemplate">
  5.             <constructor-arg index="0" ref="sqlSessionFactoryB" />
  6.         </bean>
舉例說(shuō)下關(guān)于dao的調(diào)用，注意下劃線的地方；

點(diǎn)擊(此處)折疊或打開

  1. private SqlSession sqlSessionb;
  2.     
  3.     public T create(String sql_ID,T entity) {
  4.         this.getSqlSessionb().insert(sql_ID, entity);
  5.         return entity;
  6.     }
  7.     public SqlSession getSqlSessionb() {
  8.         return sqlSessionb;
  9.     }

  11.     public void setSqlSessionb(SqlSession sqlSessionb) {
  12.         this.sqlSessionb = sqlSessionb;
  13.     }
  14. 這兒得sqlSessionb是和spring配置文件中的
  15. <bean id="sqlSessionb" class="org.mybatis.spring.SqlSessionTemplate">
  16.             <constructor-arg index="0" ref="sqlSessionFactoryB" />
  17.         </bean> 相對(duì)用的，名稱和bean中的id要相同，
  18. 調(diào)用另一個(gè)數(shù)據(jù)session也是一樣的原理：private SqlSession sqlSession;
  19.     public SqlSession getSqlSession() {
            return sqlSession;
        }

        public void setSqlSession(SqlSession sqlSession) {
            this.sqlSession = sqlSession;
        }
  20. <bean id="sqlSession" class="org.mybatis.spring.SqlSessionTemplate">
  21.             <constructor-arg index="0" ref="sqlSessionFactory" />
  22.  </bean>
配置事務(wù)

點(diǎn)擊(此處)折疊或打開

  1. <!-- 事務(wù)這塊用spring管理atomikos -->
  2.     <bean id="atomikosTransactionManager" class="com.atomikos.icatch.jta.UserTransactionManager"
  3.         init-method="init" destroy-method="close">
  4.         <property name="forceShutdown">
  5.             <value>true</value>
  6.         </property>
  7.     </bean>
  8.     <bean id="atomikosUserTransaction" class="com.atomikos.icatch.jta.UserTransactionImp">
  9.         <property name="transactionTimeout" value="300" />
  10.     </bean>

  12.     <bean id="springTransactionManager"
  13.         class="org.springframework.transaction.jta.JtaTransactionManager">
  14.         <property name="transactionManager">
  15.             <ref bean="atomikosTransactionManager" />
  16.         </property>
  17.         <property name="userTransaction">
  18.             <ref bean="atomikosUserTransaction" />
  19.         </property>
  20.         <!-- 必須設(shè)置，否則程序出現(xiàn)異常 JtaTransactionManager does not support custom isolation levels by default -->
  21.          <property name="allowCustomIsolationLevels" value="true"/>
  22.         
  23.     </bean>
  24.     <!-- 支持 @AspectJ 標(biāo)記-->
  25.      <aop:aspectj-autoproxy />
  26.     
  27.  
  28.         <!-- 以AspectJ方式 定義 AOP -->
  29.     <aop:config proxy-target-class="true">
  30.         <aop:advisor pointcut="execution(* com.suntel.linkup.service..*.*(..))" advice-ref="txAdvice"/>
  31.     </aop:config>
  32.     
  33.      <!-- 配置事務(wù)傳播特性:如果存在一個(gè)事務(wù)，則支持當(dāng)前事務(wù)。如果沒(méi)有事務(wù)則開啟：REQUIRED -->
  34.     <tx:advice id="txAdvice" transaction-manager="springTransactionManager">
  35.         <tx:attributes>
  36.            <tx:method name="add*" propagation="REQUIRED" rollback-for="Exception"/>
  37.            <tx:method name="save*" propagation="REQUIRED" rollback-for="Exception"/>
  38.            <tx:method name="insert*" propagation="REQUIRED" rollback-for="Exception"/>
  39.            <tx:method name="create*" propagation="REQUIRED" rollback-for="Exception"/>
  40.            <tx:method name="del*" propagation="REQUIRED" rollback-for="Exception"/>
  41.            <tx:method name="update*" propagation="REQUIRED" rollback-for="Exception"/>
  42.            <tx:method name="modify*" propagation="REQUIRED" rollback-for="Exception"/>
  43.            <tx:method name="*" read-only="true"/>
  44.        </tx:attributes>
  45.     </tx:advice>

好了，代碼貼完了，可以試著運(yùn)行了。

    本站是提供個(gè)人知識(shí)管理的網(wǎng)絡(luò)存儲(chǔ)空間，所有內(nèi)容均由用戶發(fā)布，不代表本站觀點(diǎn)。請(qǐng)注意甄別內(nèi)容中的聯(lián)系方式、誘導(dǎo)購(gòu)買等信息，謹(jǐn)防詐騙。如發(fā)現(xiàn)有害或侵權(quán)內(nèi)容，請(qǐng)點(diǎn)擊一鍵舉報(bào)。
    轉(zhuǎn)藏 分享 獻(xiàn)花（0）

    0條評(píng)論

    發(fā)表

    請(qǐng)遵守用戶 評(píng)論公約

    類似文章 更多