现在的位置: 首页 > 综合 > 正文

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

2019年06月21日 ⁄ 综合 ⁄ 共 6855字 ⁄ 字号 小 中 大 ⁄ 评论关闭


话入正题。了解spring的大虾门肯定一看就知道这个原理，所以我就没有贴太多的注解了。如果有需要的可以留言交流

 一、spring3.0.5，mybatis3.0.5、的包都不多说了，需要引入关于atomikos的包如下

 二、关于spring的applicationcontext的配置：

读取数据库的信息

点击(此处)折叠或打开

  1. <!--属性文件读入,使用JdbcPlaceholderConfigurer则可以从数据库读取配置信息
    -->
  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的配置文件

点击(此处)折叠或打开

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

配置mysql的两个数据源

点击(此处)折叠或打开

  1. <!-- 两个数据源的功用配置，方便下面直接引用
    -->
  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.         <!-- 最大空闲时间
    -->
  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.     <!-- 配置第一个数据源
    -->
  21.     <bean
    id    ="dataSource"
    parent="abstractXADataSource">
  22.     <!-- value只要两个数据源不同就行，随便取名
    -->
  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.     <!-- 配置第二个数据源-->
  36.     <bean
    id    ="dataSourceB"
    parent="abstractXADataSource">
  37. <!-- value只要两个数据源不同就行，随便取名
    -->
  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

点击(此处)折叠或打开

  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. <!----选择数据源------>
  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中选择相应的SqlSessionTemplate，给sqlsession注入相应的session工厂，这样dao和有相应的数据库可以连接了

点击(此处)折叠或打开

  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>

举例说下关于dao的调用，注意下划线的地方；

点击(此处)折叠或打开

  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> 相对用的，名称和bean中的id要相同，
  18. 调用另一个数据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>

配置事务

点击(此处)折叠或打开

  1. <!-- 事务这块用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.         <!-- 必须设置，否则程序出现异常 JtaTransactionManager does
    not support custom isolation levels by
    default     -->
  21.          <property
    name    ="allowCustomIsolationLevels"
    value="true"/>
  22.         
  23.     </bean>
  24.     <!-- 支持 @AspectJ 标记-->
  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.      <!-- 配置事务传播特性:如果存在一个事务，则支持当前事务。如果没有事务则开启：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>
返回
【上篇】
【下篇】

作者:

抱歉!评论已关闭.

返回首页

Copyright © 2013-2018 学步园  保留所有权利.
软文销售 QQ客服：2265327166 点击这里给我发消息（其他合作也可洽谈）
必威体育
必威电竞