Spring配置多数据源

public class DynamicDataSource extends AbstractRoutingDataSource{   
   
    @Override   
    protected Object determineCurrentLookupKey() {   
        return DBContextHolder.getDBType();   
    }   
}  

public class DBContextHolder{   
    public static final String DATA_SOURCE_FROM = "dataSourceFrom";   
    public static final String DATA_SOURCE_TO = "dataSourceTo";   
       
    private static final ThreadLocal<String> contextHolder = new ThreadLocal<String>();   
       
    public static void setDBType(String dbType) {   
        contextHolder.set(dbType);   
    }   
       
    public static String getDBType() {   
        return contextHolder.get();   
    }   
       
    public static void clearDBType() {   
        contextHolder.remove();   
    }   
}  

<!-- JdbcTemplate使用动态数据源的配置 -->   
<bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">   
    <property name="dataSource">   
        <ref bean="dynamicDataSource" />   
    </property>   
</bean>   
   
<!-- 对JdbcTemplate的应用封装类 -->   
<bean id="sqlBaseDAO" class="com.whty.dao.BaseDAOImpl">   
    <property name="jdbcTemplate">   
        <ref bean="jdbcTemplate" />   
    </property>   
</bean>

ApplicationContext context = new ClassPathXmlApplicationContext("applicationContext.xml");   
BaseDAO dao = (BaseDAO) context.getBean("sqlBaseDAO", BaseDAOImpl.class);   
   
try {   
    DBContextHolder.setCustomerType(DBContextHolder.DATA_SOURCE_FROM);   
    System.err.println(dao.select("select count(*) sum from TEST t ").get(0).get("SUM"));   
    DBContextHolder.setCustomerType(DBContextHolder.DATA_SOURCE_TO);   
    System.err.println(dao.select("select count(*) sum from TEST t ").get(0).get("SUM"));   
       
} catch (Exception e) {   
    e.printStackTrace();   
}  

DBContextHolder.clearDBType();