`
lxm3033
  • 浏览: 19691 次
  • 性别: Icon_minigender_1
  • 来自: 北京
社区版块
存档分类
最新评论

Spring多数据源的配置和使用

阅读更多

 

Spring多数据源的配置和使用

   最近开发一个数据同步的小功能,需要从A主机的Oracle数据库中把数据同步到B主机的Oracle库中。当然能够用dmp脚本或者SQL脚本是最好,但是对于两边异构的表结构来说,直接导入不可行。然后在需要实时同步的情况下用存储过程也不可行了。写一个数据同步的小程序是个不错的选择。使用框架的封装和连接池是必须的,Spring是首选,这里我们同样需要Spring的多数据源连接配置方式。 其实再进行项目开发的时候,一个项目有可能不止用到一个数据源,为了提高数据库的水平伸缩性,需要对多个数据库实例进行管理,需要配置多数据源。

 

     1. 配置多个数据源

     这里以两个c3p0数据库连接池的数据源作为实例。在Spring框架下使用c3p0的数据库需要加入c3p0-0.9.1.2.jar(现在最新的)这个支持包。这里以数据同步项目为例:

   数据来源库的连接池数据源配置:

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中取得的。

   通过Spring获取属性文件中的值,以供配置文件使用:

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。

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

   上下文DbContextHolder为一线程安全的ThreadLocal,具体代码如下:

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.配置动态数据源

 将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的类容选定特定的数据源。

 

分享到:
评论
1 楼 lihua0810 2015-01-08  
为什么我按照你的配置,切换到另外一个数据源时,hibernate查询时,提示表或试图不存在。

相关推荐

    基于注解和Spring的多数据源配置和使用

    本篇文章将深入探讨如何基于注解和Spring实现多数据源配置和使用。 首先,我们需要理解"注解"在Java中的作用。注解是一种元数据,它提供了一种安全的方法来关联信息和代码(类、方法、变量等)。Spring框架广泛使用...

    基于注解的Spring多数据源配置和使用

    通过以上步骤,我们可以看到基于Spring的多数据源配置和使用并不复杂。核心思路在于利用`AbstractRoutingDataSource`的灵活性以及`ThreadLocal`来管理数据源标识。这种方式不仅实现了多数据源的动态切换,还保持了...

    spring数据源配置

    ### Spring 数据源配置详解 #### 一、Spring与数据源简介 在Java企业级应用开发中,数据库操作是必不可少的一部分。Spring框架作为一种流行的轻量级Java应用开发框架,提供了强大的数据库访问支持,其中包括对数据...

    Spring多数据源配置

    Spring多数据源配置,支持mysql、oracle等多个数据源同时存在的情况

    spring boot多数据源配置

    在Spring Boot应用中,多数据源配置是一项关键的技术,它允许我们同时管理多个数据库,比如主库和从库,或者不同类型的数据库。本教程将详细阐述如何在Spring Boot项目中实现这一功能,从数据源配置、实体管理到...

    SSM(Spring+SpringMVC+MyBatis)多数据源配置框架

    在多数据源配置中,Spring能够帮助管理不同的数据源,通过配置bean来切换和控制数据源的使用。 **SpringMVC** 是Spring框架的一部分,专为Web开发设计。它简化了模型-视图-控制器(Model-View-Controller,MVC)的...

    SpringBoot配置多数据源实现动态切换数据源

    多数据源配置允许我们灵活地管理这些数据。 SpringBoot实现多数据源主要依靠Spring的`@Configuration`和`@DataSourceConfiguration`注解,以及Spring JDBC的`DataSource`接口。下面是一个基本的配置示例: ```java...

    spring 动态多数据源配置代码

    下面将详细介绍Spring动态多数据源配置的相关知识点。 1. **为什么要使用多数据源**: 在实际项目中,可能需要连接到不同的数据库,例如,一个用于存储主业务数据,另一个用于日志记录或数据分析。通过多数据源...

    springboot多数据源配置

    在Spring Boot应用中,多数据源配置是一项重要的技术实践,特别是在大型系统中,可能需要连接到多个数据库以实现数据隔离、读写分离或是分布式事务管理。Spring Boot以其强大的自动化配置能力,使得设置多数据源变得...

    Spring Boot使用spring-data-jpa配置Mysql多数据源

    # 主数据源配置 spring: datasource: primary: url: jdbc:mysql://localhost:3306/main_db?useSSL=false&serverTimezone=UTC username: root password: password driver-class-name: com.mysql.cj.jdbc.Driver...

    Spring Boot+Jpa多数据源配置Demo(支持不同数据库)

    Spring Boot结合JPA(Java Persistence API)和JdbcTemplate,为开发者提供了灵活且强大的多数据源配置能力。本示例将详细介绍如何在Spring Boot项目中实现这样的配置,以支持不同类型的数据库。 首先,我们要理解...

    Spring 数据源不同配置

    对于需要同时连接多个数据库的应用,Spring支持多数据源配置。可以通过`@Qualifier`注解指定使用哪个数据源,或者使用`AbstractRoutingDataSource`动态路由数据源。 6. **JNDI数据源** 在应用服务器中,数据源...

    spring mvc 配置多数据源

    # Oracle数据源配置 jdbc.driver=oracle.jdbc.OracleDriver jdbc.url=jdbc:oracle:thin:@127.0.0.1:1521:dev jdbc.username=ling jdbc.password=229 # MySQL数据源配置 jdbc-mysql.driver=com.mysql.jdbc.Driver ...

    Spring Boot多数据源(JdbcTemplate)配置与使用

    在本教程中,我们将深入探讨如何在Spring Boot项目中配置和使用多数据源以及JdbcTemplate。 首先,让我们了解什么是`JdbcTemplate`。它是Spring提供的一种模板类,用于执行SQL语句,通过回调机制将结果转换为Java...

    Spring配置多个数据源

    通过以上步骤,你可以在Spring应用中成功配置和使用多个数据源。这使得你的系统更具扩展性和灵活性,能够适应复杂的企业级需求。记住,正确管理和配置数据源对于系统的稳定性和性能至关重要,因此在实际操作时一定要...

    SpringBoot多数据源配置(方式一:配置多个mapper扫描不同的包路径实现多数据源配置).docx

    ### Spring Boot多数据源配置详解 #### 一、引言 在实际的软件开发过程中,随着业务需求的多样化,单一的数据源已经无法满足所有...希望这些内容能够帮助开发者更好地理解和掌握Spring Boot多数据源配置的相关知识。

    spring数据源配置解析

    阐述spring的数据源配置

    java spring 多数据源

    在Java Spring框架中,多数据源的实现是一个重要的特性,特别是在大型企业级应用中,它允许应用程序连接到多个数据库,从而实现数据隔离、...理解并熟练掌握多数据源配置是提升Spring应用灵活性和健壮性的重要一环。

    Springcloud 多数库 多数据源整合,查询动态切换数据库

    在Spring Boot和Spring Cloud的背景下,我们可以通过Spring的多数据源配置来实现这一目标。 1. **配置多数据源**:Spring Boot提供了DataSourceAutoConfiguration,它允许我们配置多个数据源。每个数据源可以有自己...

Global site tag (gtag.js) - Google Analytics