文档章节

Spring多数据源的配置和使用

商者
 商者
发布于 2016/01/26 15:43
字数 1271
阅读 84
收藏 12

本文以Spring2.5 + Oracle10g 为例配置和使用多数据源。

 

     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>  


    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>  

  

    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.KindAzrael的BLOG《Spring多数据源的配置 》

2.xiaoZ5919的BLOG《 jdbctemplate与事务管理 》

 


本文转载自:http://kingxss.iteye.com/blog/1620314

商者

商者

粉丝 43
博文 142
码字总数 43255
作品 0
海淀
架构师
私信 提问
spring boot 2.0 jpa多数据源配置

spring boot 1.x内多数据源配置方式参考Spring Boot多数据源配置与使用,但升级到2后该配置无效,以下是自测可行的配置方式(spring boot版本2.0.6.RELEASE)。 1. application.properties配...

思与学
2018/11/04
0
0
Spring Boot 2.0.X 多数据源及连接池配置

一、单数据源 我们在使用Spring Boot配置单数据源的时候很简单,只要在配置文件中加上基本的数据库连接信息和连接池配置信息就可以,通常情况下不需要指定driver-class-name,Spring Boot可以...

皮皮猫32
01/14
1K
0
Spring+Mybatis 实现多数据源和多事物配置

没有相应的RPC接口,一个项目存在多个数据源,不想在代码端自己编写代码切换数据源? 你有可能需要下面的解决方案: 多数据源配置 多事物配置 配置事物拦截器 注解方式 在spring-mybatis配置文...

jeremyli90
2017/11/09
82
0
Spring Boot中的Mongodb多数据源扩展

在日常工作中,我们通过Spring Data Mongodb来操作Mongodb数据库,在Spring Boot中只需要引入spring-boot-starter-data-mongodb即可。 然后配置连接信息如下: 或者 spring-boot-starter-da...

尹吉欢
04/25
0
0
spring-boot-starter-mongodb-pool

在日常工作中,我们通过Spring Data Mongodb来操作Mongodb数据库,在Spring Boot中只需要引入spring-boot-starter-data-mongodb即可。 很多时候我们往往需要操作多个数据库(微服务架构下一个...

尹吉欢
2018/04/22
0
0

没有更多内容

加载失败,请刷新页面

加载更多

PhotoShop 色调:理解直方图/RGB通道信息

一、直方图:图表的形式,展示图像像素分布的情况 1.平均值:表示平均亮度 2.标准偏差值:表示亮度值范围内的中间值 3.像素: 表示用于计算直方图的像素总数 4.色阶:显示指针下面的区域亮度...

东方墨天
3分钟前
0
0
wildfly(JBoss AS)应用服务器快速入门

什么是wildfly JBoss AS 从8版本起名为wildfly。Wildfly是一个开源的基于JavaEE的轻量级应用服务器。可以在任何商业应用中免费使用。 WildFly是一个灵活的、轻量的、强大管理能力的应用程序服...

程序新视界
28分钟前
1
0
Java集合类常见面试知识点总结

Java集合类学习总结 这篇总结是基于之前博客内容的一个整理和回顾。 这里先简单地总结一下,更多详细内容请参考我的专栏:深入浅出Java核心技术 https://blog.csdn.net/column/details/21930...

Java技术江湖
31分钟前
5
0
怎么用for循环打出爱心

先上效果图: 这是用*组成的爱心,下面讲讲思路: 首先这个图形可以拆分成三部分:第一部分是上面三行的两个梯形,第二部分是中间三行的长方形,第三部分是最下面的倒三角形。 其实图形拆分好...

INEVITABLE
36分钟前
4
0
用HttpUrlConnection伪造成HttpClient

https://www.jianshu.com/p/27ad06cc39d2

shzwork
42分钟前
4
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部