zoukankan      html  css  js  c++  java

  • SpringMVC配置双数据源，一个java项目同时连接两个数据库

    数据源在配置文件中的配置

    请点击---》   java架构师项目实战,高并发集群分布式,大数据高可用,视频教程  

    [java] view plain copy
     
    1. <pre name="code" class="java"><?xml version="1.0" encoding="UTF-8"?>  
    2. <beans xmlns="http://www.springframework.org/schema/beans"  
    3.     xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:aop="http://www.springframework.org/schema/aop"  
    4.     xmlns:cache="http://www.springframework.org/schema/cache"  
    5.     xmlns:context="http://www.springframework.org/schema/context"  
    6.     xmlns:jdbc="http://www.springframework.org/schema/jdbc" xmlns:jee="http://www.springframework.org/schema/jee"  
    7.     xmlns:jms="http://www.springframework.org/schema/jms" xmlns:lang="http://www.springframework.org/schema/lang"  
    8.     xmlns:mvc="http://www.springframework.org/schema/mvc" xmlns:oxm="http://www.springframework.org/schema/oxm"  
    9.     xmlns:p="http://www.springframework.org/schema/p" xmlns:task="http://www.springframework.org/schema/task"  
    10.     xmlns:tx="http://www.springframework.org/schema/tx" xmlns:util="http://www.springframework.org/schema/util"  
    11.     xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd    
    12.     http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-3.1.xsd    
    13.     http://www.springframework.org/schema/cache http://www.springframework.org/schema/cache/spring-cache-3.1.xsd    
    14.     http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.1.xsd    
    15.     http://www.springframework.org/schema/jdbc http://www.springframework.org/schema/jdbc/spring-jdbc-3.1.xsd    
    16.     http://www.springframework.org/schema/jee http://www.springframework.org/schema/jee/spring-jee-3.1.xsd    
    17.     http://www.springframework.org/schema/jms http://www.springframework.org/schema/jms/spring-jms-3.1.xsd    
    18.     http://www.springframework.org/schema/lang http://www.springframework.org/schema/lang/spring-lang-3.1.xsd    
    19.     http://www.springframework.org/schema/mvc http://www.springframework.org/schema/mvc/spring-mvc-3.1.xsd    
    20.     http://www.springframework.org/schema/oxm http://www.springframework.org/schema/oxm/spring-oxm-3.1.xsd    
    21.     http://www.springframework.org/schema/task http://www.springframework.org/schema/task/spring-task-3.1.xsd    
    22.     http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-3.1.xsd    
    23.     http://www.springframework.org/schema/util http://www.springframework.org/schema/util/spring-util-3.1.xsd">  
    24.   
    25.     <context:annotation-config />  
    26.   
    27.     <context:component-scan base-package="com"></context:component-scan>  
    28.   
    29.     <bean class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">  
    30.         <property name="locations">  
    31.             <list>  
    32.                 <value>classpath:com/resource/config.properties</value>  
    33.             </list>  
    34.         </property>  
    35.     </bean>  
    36.   
    37.     <bean id="dataSourceOne" class="com.mchange.v2.c3p0.ComboPooledDataSource"  
    38.         destroy-method="close">  
    39.         <property name="driverClass" value="${dbOne.jdbc.driverClass}" />  
    40.         <property name="jdbcUrl" value="${dbOne.jdbc.url}" />  
    41.         <property name="user" value="${dbOne.jdbc.user}" />  
    42.         <property name="password" value="${dbOne.jdbc.password}" />  
    43.         <property name="initialPoolSize" value="${dbOne.jdbc.initialPoolSize}" />  
    44.         <property name="minPoolSize" value="${dbOne.jdbc.minPoolSize}" />  
    45.         <property name="maxPoolSize" value="${dbOne.jdbc.maxPoolSize}" />  
    46.     </bean>  
    47.   
    48.     <bean id="dataSourceTwo" class="com.mchange.v2.c3p0.ComboPooledDataSource"  
    49.         destroy-method="close">  
    50.         <property name="driverClass" value="${dbTwo.jdbc.driverClass}" />  
    51.         <property name="jdbcUrl" value="${dbTwo.jdbc.url}" />  
    52.         <property name="user" value="${dbTwo.jdbc.user}" />  
    53.         <property name="password" value="${dbTwo.jdbc.password}" />  
    54.         <property name="initialPoolSize" value="${dbTwo.jdbc.initialPoolSize}" />  
    55.         <property name="minPoolSize" value="${dbTwo.jdbc.minPoolSize}" />  
    56.         <property name="maxPoolSize" value="${dbTwo.jdbc.maxPoolSize}" />  
    57.     </bean>  
    58.   
    59.     <bean id="dynamicDataSource" class="com.core.DynamicDataSource">  
    60.         <property name="targetDataSources">  
    61.             <map key-type="java.lang.String">  
    62.                 <entry value-ref="dataSourceOne" key="dataSourceOne"></entry>  
    63.                 <entry value-ref="dataSourceTwo" key="dataSourceTwo"></entry>  
    64.             </map>  
    65.         </property>  
    66.         <property name="defaultTargetDataSource" ref="dataSourceOne">  
    67.         </property>  
    68.     </bean>  
    69.   
    70.     <bean id="sessionFactory" class="org.springframework.orm.hibernate4.LocalSessionFactoryBean">  
    71.         <property name="dataSource" ref="dynamicDataSource" />  
    72.         <property name="hibernateProperties">  
    73.             <props>  
    74.                 <prop key="hibernate.dialect">org.hibernate.dialect.MySQLDialect</prop>  
    75.                 <prop key="hibernate.current_session_context_class">org.springframework.orm.hibernate4.SpringSessionContext</prop>  
    76.                 <prop key="hibernate.show_sql">false</prop>  
    77.                 <prop key="hibernate.format_sql">true</prop>  
    78.                 <prop key="hbm2ddl.auto">create</prop>  
    79.             </props>  
    80.         </property>  
    81.         <property name="packagesToScan">  
    82.             <list>  
    83.                 <value>com.po</value>  
    84.             </list>  
    85.         </property>  
    86.     </bean>  
    87.   
    88.     <bean id="transactionManager" class="org.springframework.orm.hibernate4.HibernateTransactionManager">  
    89.         <property name="sessionFactory" ref="sessionFactory" />  
    90.     </bean>  
    91.   
    92.     <aop:config>  
    93.         <aop:pointcut id="transactionPointCut" expression="execution(* com.dao..*.*(..))" />  
    94.         <aop:advisor advice-ref="txAdvice" pointcut-ref="transactionPointCut" />  
    95.     </aop:config>  
    96.   
    97.     <tx:advice id="txAdvice" transaction-manager="transactionManager">  
    98.         <tx:attributes>  
    99.             <tx:method name="add*" propagation="REQUIRED" />  
    100.             <tx:method name="save*" propagation="REQUIRED" />  
    101.             <tx:method name="update*" propagation="REQUIRED" />  
    102.             <tx:method name="delete*" propagation="REQUIRED" />  
    103.             <tx:method name="*" read-only="true" />  
    104.         </tx:attributes>  
    105.     </tx:advice>  
    106.   
    107.     <aop:config>  
    108.         <aop:aspect id="dataSourceAspect" ref="dataSourceInterceptor">  
    109.             <aop:pointcut id="daoOne" expression="execution(* com.dao.one.*.*(..))" />  
    110.             <aop:pointcut id="daoTwo" expression="execution(* com.dao.two.*.*(..))" />  
    111.             <aop:before pointcut-ref="daoOne" method="setdataSourceOne" />  
    112.             <aop:before pointcut-ref="daoTwo" method="setdataSourceTwo" />  
    113.         </aop:aspect>  
    114.     </aop:config>  
    115. </beans>  


    请点击---》   java架构师项目实战,高并发集群分布式,大数据高可用,视频教程  

    

    DynamicDataSource.class
    



    

    

    [java] view plain copy

     
    

    

    

      

    1. package com.core;  
      2. 

    2.   
      3. 

    3. import org.springframework.jdbc.datasource.lookup.AbstractRoutingDataSource;  
      4. 

    4.   
      5. 

    5. public class DynamicDataSource extends AbstractRoutingDataSource{  
      6. 

    6.   
      7. 

    7.     @Override  
      8. 

    8.     protected Object determineCurrentLookupKey() {  
      9. 

    9.         return DatabaseContextHolder.getCustomerType();   
      10. 

    10.     }  
      11. 

    11.   
      12. 

    12. }  
      13. 

    

     DatabaseContextHolder.class设置数据源的类
    



    

    

    [java] view plain copy

     
    

    

    

      

    1. package com.core;  
      2. 

    2.   
      3. 

    3. public class DatabaseContextHolder {  
      4. 

    4.   
      5. 

    5.     private static final ThreadLocal<String> contextHolder = new ThreadLocal<String>();  
      6. 

    6. <span style="white-space:pre">    </span>//设置要使用的数据源  
      7. 

    7.     public static void setCustomerType(String customerType) {  
      8. 

    8.         contextHolder.set(customerType);  
      9. 

    9.     }  
      10. 

    10. <span style="white-space:pre">    </span>//获取数据源  
      11. 

    11.     public static String getCustomerType() {  
      12. 

    12.         return contextHolder.get();  
      13. 

    13.     }  
      14. 

    14. <span style="white-space:pre">    </span>//清除数据源，使用默认的数据源  
      15. 

    15.     public static void clearCustomerType() {  
      16. 

    16.         contextHolder.remove();  
      17. 

    17.     }  
      18. 

    18. }  
      19. 

    

    DataSourceInterceptor.class
    

    

    

    [java] view plain copy

     
    


    


    

      

    1. package com.core;  
      2. 

    2.   
      3. 

    3. import org.aspectj.lang.JoinPoint;  
      4. 

    4. import org.springframework.stereotype.Component;  
      5. 

    5.   
      6. 

    6. @Component  
      7. 

    7. public class DataSourceInterceptor {  
      8. 

    8. <span style="white-space:pre;"> </span>//数据源1  
      9. 

    9.     public static final String SOURCE_PLAN = "dataSourceOne;  
      10. 

    10.     //数据源2  
      11. 

    11.         public static final String SOURCE_FUND = dataSourceTwo;  
      12. 


    

    }
    

    请点击---》   java架构师项目实战,高并发集群分布式,大数据高可用,视频教程  
    

    

    springMVC数据源
    


    

    

    [html] view plain copy

     
    

    

    

      

    1. jdbc_driverClassName=com.microsoft.sqlserver.jdbc.SQLServerDriver  
      2. 

    2. dataSourceOne=jdbc:sqlserver://115.29.***.**;DatabaseName=DB_GuiHua  
      3. 

    

    jdbc_username=**jdbc_password=**
    

    

    

    [java] view plain copy

     
    

    

    

      

    1. dataSourceTwo=jdbc:sqlserver://115.29.***.*;DatabaseName=DB_Fund  
      2. 

    


    

    Spring MVC会默认有一个数据源，当需要更换数据源时，要在调用事务之前配置
    



    

    

    [java] view plain copy

     
    

    

    

      

    1. DataSourceContextHolder.setDbType(DataSourceType.SOURCE_FUND);//更换数据源  
      2. 

    

    

    

    [java] view plain copy

     
    

    

    

      

    1. /** 
      2. 

    2.  * @ClassName: DataSourceContextHolder 
      3. 

    3.  * @Description: 数据库切换工具类 
      4. 

    4.  * @author: wzx 
      5. 

    5.  * @date: 2016-07-27 上午10:26:01 
      6. 

    6.  */  
      7. 

    7. public class DataSourceContextHolder {  
      8. 

    8.     private static final ThreadLocal<String> contextHolder = new ThreadLocal<String>();  
      9. 

    9.   
      10. 

    10.     public static void setDbType(String dbType) {  
      11. 

    11.         contextHolder.set(dbType);  
      12. 

    12.     }  
      13. 

    13.   
      14. 

    14.     public static String getDbType() {  
      15. 

    15.         return ((String) contextHolder.get());  
      16. 

    16.     }  
      17. 

    17.   
      18. 

    18.     public static void clearDbType() {  
      19. 

    19.         contextHolder.remove();  
      20. 

    20.     }  
      21. 

    21. }  
      22. 

    


    请点击---》   java架构师项目实战,高并发集群分布式,大数据高可用,视频教程  
    

    
    
                
    
                
              
    • 
              
    
              
  • 

                相关阅读:
    
                
                  (双指针 二分) leetcode 167. Two Sum II
                    
    (双指针) leetcode 485. Max Consecutive Ones
                    
    (双指针) leetcode 27. Remove Element
                    
    (String) leetcode 67. Add Binary
                    
    (数组) leetcode 66. Plus One
                    
    (N叉树 BFS) leetcode429. N-ary Tree Level Order Traversal
                    
    (N叉树 递归) leetcode 590. N-ary Tree Postorder Traversal
                    
    (N叉树 递归) leetcode589. N-ary Tree Preorder Traversal
                    
    (N叉树 DFS 递归 BFS) leetcode 559. Maximum Depth of N-ary Tree
                    
    (BST 递归) leetcode98. Validate Binary Search Tree
                    
                        
              
    • 
              
    
              
  • 
                原文地址：https://www.cnblogs.com/a347911/p/8183452.html
              
    • 

            

          



          
          

            

            

          

        

      

      



      

      

        

          Copyright © 2011-2022 走看看