Spring多数据源的配置和使用
最近开发一个数据同步的小功能，需要从A主机的Oracle数据库中把数据同步到B主机的Oracle库中。当然能够用dmp脚本或者SQL脚本是最好，但是对于两边异构的表结构来说，直接导入不可行。然后在需要实时同步的情况下用存储过程也不可行了。写一个数据同步的小程序是个不错的选择。使用框架的封装和连接池是必须的，spring是首选，这里我们同样需要Spring的多数据源连接配置方式。其实再进行项目开发的时候，一个项目有可能不止用到一个数据源，为了提高数据库的水平伸缩性，需要对多个数据库实例进行管理，需要配置多数据源。
1.配置多个数据源
这里以两个c3p0数据库连接池的数据源作为实例。在Spring框架下使用c3p0的数据库需要加入c3p0-0.9.1.2.jar(现在最新的)这个支持包。这里以数据同步项目为例：
数据来源库的连接池数据源配置：
Xml代码收藏代码
<beanid="dataSourceFrom"class="com.mchange.v2.c3p0.ComboPooledDataSource">
<propertyname="driverClass"value="${jdbc.driver}"/>
<propertyname="jdbcUrl"value="${jdbc.from.url}"/>
<propertyname="user"value="${jdbc.from.username}"/>
<propertyname="password"value="${jdbc.from.password}"/>
<propertyname="autoCommitOnClose"value="true"/>
<propertyname="checkoutTimeout"value="${cpool.checkoutTimeout}"/>
<propertyname="initialPoolSize"value="${cpool.minPoolSize}"/>
<propertyname="minPoolSize"value="${cpool.minPoolSize}"/>
<propertyname="maxPoolSize"value="${cpool.maxPoolSize}"/>
<propertyname="maxIdleTime"value="${cpool.maxIdleTime}"/>
<propertyname="acquireIncrement"value="${cpool.acquireIncrement}"/>
<propertyname="maxIdleTimeExcessConnections"value="${cpool.maxIdleTimeExcessConnections}"/>
</bean>
数据插入库的连接池数据源配置：
Xml代码收藏代码
<beanid="dataSourceTo"class="com.mchange.v2.c3p0.ComboPooledDataSource">
<propertyname="driverClass"value="${jdbc.driver}"/>
<propertyname="jdbcUrl"value="${jdbc.to.url}"/>
<propertyname="user"value="${jdbc.to.username}"/>
<propertyname="password"value="${jdbc.to.password}"/>
<propertyname="autoCommitOnClose"value="true"/>
<propertyname="checkoutTimeout"value="${cpool.checkoutTimeout}"/>
<propertyname="initialPoolSize"value="${cpool.minPoolSize}"/>
<propertyname="minPoolSize"value="${cpool.minPoolSize}"/>
<propertyname="maxPoolSize"value="${cpool.maxPoolSize}"/>
<propertyname="maxIdleTime"value="${cpool.maxIdleTime}"/>
<propertyname="acquireIncrement"value="${cpool.acquireIncrement}"/>
<propertyname="maxIdleTimeExcessConnections"value="${cpool.maxIdleTimeExcessConnections}"/>
</bean>
注意：上面url，user，password等值是从classpath下的jdbc.properties中取得的。
通过Spring获取属性文件中的值，以供配置文件使用：
Xml代码收藏代码
<beanclass="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
<propertyname="locations"value="classpath:jdbc.properties"/>
</bean>
2.扩展Spring的AbstractRoutingDataSource抽象类，实现动态数据源。
AbstractRoutingDataSource中的抽象方法determineCurrentLookupKey是实现数据源的route的核心.这里对该方法进行Override。
Java代码收藏代码
publicclassDynamicDataSourceextendsAbstractRoutingDataSource{
@Override
protectedObjectdetermineCurrentLookupKey(){
returnDBContextHolder.getDBType();
}
}
上下文DbContextHolder为一线程安全的ThreadLocal，具体代码如下：
Java代码收藏代码
publicclassDBContextHolder{
publicstaticfinalStringDATA_SOURCE_FROM="dataSourceFrom";
publicstaticfinalStringDATA_SOURCE_TO="dataSourceTo";
privatestaticfinalThreadLocal<String>contextHolder=newThreadLocal<String>();
publicstaticvoidsetDBType(StringdbType){
contextHolder.set(dbType);
}
publicstaticStringgetDBType(){
returncontextHolder.get();
}
publicstaticvoidclearDBType(){
contextHolder.remove();
}
}
3.配置动态数据源
将DynamicDataSourceBean加入到Spring的上下文xml配置文件中去，同时配置DynamicDataSource的targetDataSources(多数据源目标)属性的Map映射。
Xml代码收藏代码
<beanid="dynamicDataSource"class="datasource.DynamicDataSource">
<!--通过key-value的形式来关联数据源-->
<propertyname="targetDataSources">
<map>
<entryvalue-ref="dataSourceFrom"key="dataSourceFrom"></entry>
<entryvalue-ref="dataSourceTo"key="dataSourceTo"></entry>
</map>
</property>
<propertyname="defaultTargetDataSource"ref="dataSourceFrom"/>
</bean>
4.使用动态数据源
例子中DynamicDataSource是继承与AbstractRoutingDataSource，而AbstractRoutingDataSource又是继承于org.springframework.jdbc.datasource.AbstractDataSource，AbstractDataSource实现了统一的DataSource接口，所以DynamicDataSource同样可以当一个DataSource使用。
在Spring的JdbcTemplate使用动态数据源的配置示例：
Xml代码收藏代码
<!--JdbcTemplate使用动态数据源的配置-->
<beanid="jdbcTemplate"class="org.springframework.jdbc.core.JdbcTemplate">
<propertyname="dataSource">
<refbean="dynamicDataSource"/>
</property>
</bean>
<!--对JdbcTemplate的应用封装类-->
<beanid="sqlBaseDAO"class="com.whty.dao.BaseDAOImpl">
<propertyname="jdbcTemplate">
<refbean="jdbcTemplate"/>
</property>
</bean>
在ORM框架hibernate中的使用配置示例：
Xml代码收藏代码
<beanid="sessionFactory"class="org.springframework.orm.hibernate3.annotation.AnnotationSessionFactoryBean">
<!--和普通的dataSource用法一样-->
<propertyname="dataSource"ref="dynamicDataSource"/>
<propertyname="configLocations"value="classpath:hibernate.cfg.xml"/>
<propertyname="hibernateProperties">
<props>
<propkey="hibernate.dialect">${hibernate.dialect}</prop>
</property>
</bean>
5.事务管理
使用动态数据源的时候，可以看出和使用单数据源的时候相比，在使用配置上几乎没有差别，在进行性事务管理配置的时候也没有差别：
使用Spring的JdbcTemplate的事务管理配置示例：
Xml代码收藏代码
<beanid="transactionManager"class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
<propertyname="dataSource"ref="dynamicDataSource"/>
</bean>
<beanid="sqlBaseDAOProxy"class="org.springframework.transaction.interceptor.TransactionProxyFactoryBean">
<propertyname="transactionManager"ref="transactionManager"/>
<propertyname="target"ref="sqlBaseDAO"/>
<propertyname="transactionAttributes">
<props>
<propkey="insert*">PROPAGATION_REQUIRED</prop>
<propkey="*">PROPAGATION_REQUIRED,readOnly</prop>
</props>
</property>
</bean>
使用Hibernate时的事务管理配置示例：
Xml代码收藏代码
<tx:annotation-driventransaction-manager="transactionManager"/>
<beanid="transactionManager"class="org.springframework.orm.hibernate3.HibernateTransactionManager">
<propertyname="sessionFactory"ref="sessionFactory"/>
</bean>
6.动态数据源的管理控制
如何选择控制每个业务中需要的具体数据源，可是使用手动控制：
Java代码收藏代码
ApplicationContextcontext=newClassPathXmlApplicationContext("applicationContext.xml");
BaseDAOdao=(BaseDAO)context.getBean("sqlBaseDAO",BaseDAOImpl.class);
try{
DBContextHolder.setCustomerType(DBContextHolder.DATA_SOURCE_FROM);
System.err.println(dao.select("selectcount(*)sumfromTESTt").get(0).get("SUM"));
DBContextHolder.setCustomerType(DBContextHolder.DATA_SOURCE_TO);
System.err.println(dao.select("selectcount(*)sumfromTESTt").get(0).get("SUM"));
}catch(Exceptione){
e.printStackTrace();
}
也可以采用AOP的控制方式：
Java代码收藏代码
@Aspect
publicclassDynamicDataSourceAspect{
@Pointcut("execution(publicservice.impl..*.*(..))")
publicvoidserviceExecution(){}
@Before("serviceExecution()")
publicvoidsetDynamicDataSource(JoinPointjp){
for(Objecto:jp.getArgs()){
//处理具体的逻辑，根据具体的境况CustomerContextHolder.setCustomerType()选取DataSource
}
}
}
7.总结
通过扩展Spring的AbstractRoutingDataSource可以很好的实现多数据源的rout效果，而且对扩展更多的数据源有良好的伸缩性，只要增加数据源和修改DynamicDataSource的targetDataSources属性配置就好。在数据源选择控制上，可以采用手动控制(业务逻辑并不多的时候)，也可以很好的用AOP的@Aspect在Service的入口加入一个切面@Pointcut，在@Before里判断JoinPoint的类容选定特定的数据源。