Spring 的動態數據源實現

時間  2019-12-01
標籤 spring 動態 數據 實現 欄目 Spring 简体版
原文   原文鏈接

    1. 配置多個數據源spring

     這裏以兩個c3p0數據庫鏈接池的數據源做爲實例。在Spring框架下使用c3p0的數據庫須要加入c3p0-0.9.1.2.jar(如今最新的)這個支持包。這裏以數據同步項目爲例：sql

數據來源庫的鏈接池數據源配置：數據庫

Xml代碼   收藏代碼
  1. <bean id="dataSourceFrom" class="com.mchange.v2.c3p0.ComboPooledDataSource">  
  2.     <property name="driverClass" value="${jdbc.driver}" />  
  3.     <property name="jdbcUrl" value="${jdbc.from.url}" />  
  4.     <property name="user" value="${jdbc.from.username}" />  
  5.     <property name="password" value="${jdbc.from.password}" />  
  6.     <property name="autoCommitOnClose" value="true" />  
  7.     <property name="checkoutTimeout" value="${cpool.checkoutTimeout}" />  
  8.     <property name="initialPoolSize" value="${cpool.minPoolSize}" />  
  9.     <property name="minPoolSize" value="${cpool.minPoolSize}" />  
  10.     <property name="maxPoolSize" value="${cpool.maxPoolSize}" />  
  11.     <property name="maxIdleTime" value="${cpool.maxIdleTime}" />  
  12.     <property name="acquireIncrement" value="${cpool.acquireIncrement}" />  
  13.     <property name="maxIdleTimeExcessConnections" value="${cpool.maxIdleTimeExcessConnections}" />  
  14. </bean>  

 數據插入庫的鏈接池數據源配置：安全

Xml代碼   收藏代碼
  1. <bean id="dataSourceTo" class="com.mchange.v2.c3p0.ComboPooledDataSource">  
  2.     <property name="driverClass" value="${jdbc.driver}" />  
  3.     <property name="jdbcUrl" value="${jdbc.to.url}" />  
  4.     <property name="user" value="${jdbc.to.username}" />  
  5.     <property name="password" value="${jdbc.to.password}" />  
  6.     <property name="autoCommitOnClose" value="true" />  
  7.     <property name="checkoutTimeout" value="${cpool.checkoutTimeout}" />  
  8.     <property name="initialPoolSize" value="${cpool.minPoolSize}" />  
  9.     <property name="minPoolSize" value="${cpool.minPoolSize}" />  
  10.     <property name="maxPoolSize" value="${cpool.maxPoolSize}" />  
  11.     <property name="maxIdleTime" value="${cpool.maxIdleTime}" />  
  12.     <property name="acquireIncrement" value="${cpool.acquireIncrement}" />  
  13.     <property name="maxIdleTimeExcessConnections" value="${cpool.maxIdleTimeExcessConnections}" />  
  14. </bean>  

   注意：上面url，user，password等值是從classpath下的jdbc.properties中取得的。session

   經過Spring獲取屬性文件中的值，以供配置文件使用：app

Xml代碼   收藏代碼
  1. <bean class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">  
  2.     <property name="locations" value="classpath:jdbc.properties" />  
  3. </bean>  

 

     2. 擴展Spring的AbstractRoutingDataSource抽象類，實現動態數據源。框架

    AbstractRoutingDataSource中的抽象方法determineCurrentLookupKey是實現數據源的route的核心.這裏對該方法進行Override。xss

Java代碼   收藏代碼
  1. public class DynamicDataSource extends AbstractRoutingDataSource{  
  2.   
  3.     @Override  
  4.     protected Object determineCurrentLookupKey() {  
  5.         return DBContextHolder.getDBType();  
  6.     }  
  7. }  

   上下文DbContextHolder爲一線程安全的ThreadLocal，具體代碼以下：ide

Java代碼   收藏代碼
  1. public class DBContextHolder{  
  2.     public static final String DATA_SOURCE_FROM = "dataSourceFrom";  
  3.     public static final String DATA_SOURCE_TO = "dataSourceTo";  
  4.       
  5.     private static final ThreadLocal<String> contextHolder = new ThreadLocal<String>();  
  6.       
  7.     public static void setDBType(String dbType) {  
  8.         contextHolder.set(dbType);  
  9.     }  
  10.       
  11.     public static String getDBType() {  
  12.         return contextHolder.get();  
  13.     }  
  14.       
  15.     public static void clearDBType() {  
  16.         contextHolder.remove();  
  17.     }  
  18. }  

 

    3.配置動態數據源ui

 將DynamicDataSource Bean加入到Spring的上下文xml配置文件中去，同時配置DynamicDataSource的targetDataSources(多數據源目標)屬性的Map映射。

Xml代碼   收藏代碼
  1. <bean id="dynamicDataSource" class="datasource.DynamicDataSource" >  
  2.     <!-- 經過key-value的形式來關聯數據源 -->  
  3.     <property name="targetDataSources">  
  4.         <map>  
  5.             <entry value-ref="dataSourceFrom" key="dataSourceFrom"></entry>  
  6.             <entry value-ref="dataSourceTo" key="dataSourceTo"></entry>  
  7.         </map>  
  8.     </property>  
  9.     <property name="defaultTargetDataSource" ref="dataSourceFrom" />  
  10. </bean>   

 

    4.使用動態數據源

    例子中DynamicDataSource是繼承與AbstractRoutingDataSource，而AbstractRoutingDataSource又是繼承於org.springframework.jdbc.datasource.AbstractDataSource，AbstractDataSource實現了統一的DataSource接口，因此DynamicDataSource一樣能夠當一個DataSource使用。

 在Spring的JdbcTemplate使用動態數據源的配置示例：

Xml代碼   收藏代碼
  1. <!-- JdbcTemplate使用動態數據源的配置 -->  
  2. <bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">  
  3.     <property name="dataSource">  
  4.         <ref bean="dynamicDataSource" />  
  5.     </property>  
  6. </bean>  
  7.   
  8. <!-- 對JdbcTemplate的應用封裝類 -->  
  9. <bean id="sqlBaseDAO" class="com.whty.dao.BaseDAOImpl">  
  10.     <property name="jdbcTemplate">  
  11.         <ref bean="jdbcTemplate" />  
  12.     </property>  
  13. </bean>  

在ORM框架Hibernate中的使用配置示例：

Xml代碼   收藏代碼
  1. <bean id="sessionFactory" class="org.springframework.orm.hibernate3.annotation.AnnotationSessionFactoryBean">  
  2.     <!-- 和普通的dataSource用法同樣 -->  
  3.     <property name="dataSource" ref="dynamicDataSource" />  
  4.     <property name="configLocations" value="classpath:hibernate.cfg.xml" />  
  5.     <property name="hibernateProperties">  
  6.         <props>  
  7.             <prop key="hibernate.dialect">${hibernate.dialect}</prop>     
  8.     </property>  
  9. </bean>  

   

    5.事務管理

使用動態數據源的時候，能夠看出和使用單數據源的時候相比，在使用配置上幾乎沒有差異，在進行性事務管理配置的時候也沒有差異：

使用Spring的JdbcTemplate的事務管理配置示例：

Xml代碼   收藏代碼
  1. <bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">  
  2.     <property name="dataSource" ref="dynamicDataSource" />  
  3. </bean>  
  4.   
  5. <bean id="sqlBaseDAOProxy" class="org.springframework.transaction.interceptor.TransactionProxyFactoryBean">  
  6.     <property name="transactionManager" ref="transactionManager" />  
  7.     <property name="target" ref="sqlBaseDAO" />  
  8.     <property name="transactionAttributes">  
  9.         <props>  
  10.             <prop key="insert*">PROPAGATION_REQUIRED</prop>  
  11.             <prop key="*">PROPAGATION_REQUIRED,readOnly</prop>  
  12.         </props>  
  13.     </property>  
  14. </bean>  

 

 

使用Hibernate時的事務管理配置示例：

Xml代碼   收藏代碼
  1. <tx:annotation-driven transaction-manager="transactionManager"/>  
  2.   
  3. <bean id="transactionManager" class="org.springframework.orm.hibernate3.HibernateTransactionManager">  
  4.     <property name="sessionFactory" ref="sessionFactory" />  
  5. </bean>  

 

 

    6.動態數據源的管理控制

如何選擇控制每一個業務中須要的具體數據源，但是使用手動控制：

Java代碼   收藏代碼
  1. ApplicationContext context = new ClassPathXmlApplicationContext("applicationContext.xml");  
  2. BaseDAO dao = (BaseDAO) context.getBean("sqlBaseDAO", BaseDAOImpl.class);  
  3.   
  4. try {  
  5.     DBContextHolder.setCustomerType(DBContextHolder.DATA_SOURCE_FROM);  
  6.     System.err.println(dao.select("select count(*) sum from TEST t ").get(0).get("SUM"));  
  7.     DBContextHolder.setCustomerType(DBContextHolder.DATA_SOURCE_TO);  
  8.     System.err.println(dao.select("select count(*) sum from TEST t ").get(0).get("SUM"));  
  9.       
  10. } catch (Exception e) {  
  11.     e.printStackTrace();  
  12. }  

也能夠採用AOP的控制方式：

Java代碼   收藏代碼
  1. @Aspect  
  2. public class DynamicDataSourceAspect {  
  3.     @Pointcut("execution (public service.impl..*.*(..))")  
  4.     public void serviceExecution(){}  
  5.       
  6.     @Before("serviceExecution()")  
  7.     public void setDynamicDataSource(JoinPoint jp) {  
  8.         for(Object o : jp.getArgs()) {  
  9.             //處理具體的邏輯 ，根據具體的境況CustomerContextHolder.setCustomerType()選取DataSource  
  10.         }  
  11.     }  
  12. }  

 

  7.總結

   經過擴展Spring的AbstractRoutingDataSource能夠很好的實現多數據源的rout效果，並且對擴展更多的數據源有良好的伸縮性，只要增長數據源和修改DynamicDataSource的targetDataSources屬性配置就好。在數據源選擇控制上，能夠採用手動控制(業務邏輯並很少的時候)，也能夠很好的用AOP的@Aspect在Service的入口加入一個切面@Pointcut，在@Before裏判斷JoinPoint的類容選定特定的數據源。

相關文章
相關標籤/搜索
每日一句
    每一个你不满意的现在，都有一个你没有努力的曾经。
本站公眾號
   歡迎關注本站公眾號,獲取更多信息
聯繫我們 最近搜索 最新文章 沪ICP备13005482号-10 MyBatis教程 SQL 教程 MySQL教程 Java 教程 Thymeleaf 教程 Hibernate教程 Spring教程 Redis教程