Spring动态配置多数据源

Spring对于多数据源，以数据库表为参照，大体上可以分成两大类情况：
　　一是，表级上的跨数据库。即，对于不同的数据库却有相同的表（表名和表结构完全相同）。
　　二是，非表级上的跨数据库。即，多个数据源不存在相同的表。
Spring2.x的版本中采用Proxy模式，就是我们在方案中实现一个虚拟的数据源，并且用它来封装数据源选择逻辑，这样就可以有效地将数据源选择逻辑从Client中分离出来。Client提供选择所需的上下文（因为这是Client所知道的），由虚拟的DataSource根据Client提供的上下文来实现数据源的选择。
　　
具体的实现就是，虚拟的DataSource仅需继承AbstractRoutingDataSource实现determineCurrentLookupKey（）在其中封装数据源的选择逻辑。

1. 数据源的名称常量类：
package com.test;
public class DataSourceMap {
public static final String TEST="test";
public static final String LJH="ljh";
}
2. 建立一个获得和设置上下文环境的类，主要负责改变上下文数据源的名称
package com.test;
public class CustomerContextHolder {
private static final ThreadLocal<String> customer = new ThreadLocal<String>();// 线程本地环境
// 设置数据源类型
public static void setCustomerType(String customerType){
customer.set(customerType);
}
// 获取数据源类型
public static String getCustomerType(){
return customer.get();
}
// 清除数据源类型
public static void remove(){
customer.remove();
}
}
3. 建立动态数据源类，注意，这个类必须继承AbstractRoutingDataSource，且实现方determineCurrentLookupKey，该方法返回一个Object，一般是返回字符串
package com.test;
import org.springframework.jdbc.datasource.lookup.AbstractRoutingDataSource;

public class DynamicDataSource extends AbstractRoutingDataSource{

@Override
protected Object determineCurrentLookupKey() {
// 在进行DAO操作前，通过上下文环境变量，获得数据源的类型
return CustomerContextHolder.getCustomerType();
}
}
4. 编写spring的配置文件配置多个数据源
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.5.xsd">
<!-- 数据源公共的内容 -->
<bean id="abstractDataSource"
class="com.mchange.v2.c3p0.ComboPooledDataSource">
<property name="user" value="root"></property>
<property name="password" value="root"></property>
<property name="driverClass" value="com.mysql.jdbc.Driver"></property>
</bean>
<!-- 数据库ljh -->
<bean id="ljhDataSource" parent="abstractDataSource" >
<property name="jdbcUrl"
value="jdbc:mysql://localhost:3306/ljh">
</property>
</bean>
<!-- 数据库test -->
<bean id="testDataSource" parent="abstractDataSource" >
<property name="jdbcUrl"
value="jdbc:mysql://localhost:3306/test">
</property>
</bean>
<!-- 配置多数据源映射关系 -->
<bean id="dataSource" class="com.test.DynamicDataSource">
<property name="targetDataSources">
<map>
<entry key="ljh" value-ref="ljhDataSource"></entry>
</map>
</property>
<property name="defaultTargetDataSource" ref="testDataSource"></property>
</bean>
<!-- sessionFactory的配置 -->
<bean id="sessionFactory"
class="org.springframework.orm.hibernate3.LocalSessionFactoryBean">
<property name="dataSource">
<ref bean="dataSource"/>
</property>
<!-- 实体类资源映射 -->
<property name="mappingDirectoryLocations">
<list>
<value>classpath:com/test</value>
</list>
</property>
<!-- 为sessionFactory 配置Hibernate属性 -->
<property name="hibernateProperties">
<props>
<prop key="hibernate.dialect">org.hibernate.dialect.MySQLDialect</prop>
<prop key="hibernate.show_sql">true</prop>
</props>
</property>
</bean>
<!-- 为dao配置sessionFactory -->
<bean id="userDaoImpl" class="com.test.UserDaoImpl">
<property name="sessionFactory" ref="sessionFactory"></property>
</bean>

</beans>
User类
package com.test;
public class User {
private Integer id;
private String name;

public Integer getId() {
return id;
}
public void setId(Integer id) {
this.id = id;
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
}
user.hbm.xml文件
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE hibernate-mapping PUBLIC "-//Hibernate/Hibernate Mapping DTD 3.0//EN" "http://hibernate.sourceforge.net/hibernate-mapping-3.0.dtd" >
<hibernate-mapping>
<class name="com.test.User" table="tuser">
<id name="id">
<generator class="native"></generator>
</id>
<property name="name" length="15"></property>
</class>
</hibernate-mapping>

Dao类

package com.test;
import org.springframework.orm.hibernate3.support.HibernateDaoSupport;

public class UserDaoImpl extends HibernateDaoSupport{
public void save(User user){
this.getHibernateTemplate().save(user);
}
}

测试类
package com.test;

import org.springframework.context.support.ClassPathXmlApplicationContext;

public class Test {
public static void main(String[] args) {
ClassPathXmlApplicationContext ctx = new ClassPathXmlApplicationContext("applicationContext.xml");

CustomerContextHolder.setCustomerType(DataSourceMap.TEST);
UserDaoImpl userDaoImpl = (UserDaoImpl)ctx.getBean("userDaoImpl");
User user = new User();
user.setName("test");
userDaoImpl.save(user);

CustomerContextHolder.setCustomerType(DataSourceMap.LJH);
user.setName("ljh");
userDaoImpl.save(user);
CustomerContextHolder.remove();

}
}