java单数据源改多数据源配置（hibernate）

xml配置

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans" 
  	   xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" 
       xmlns:context="http://www.springframework.org/schema/context"
	   xmlns:tx="http://www.springframework.org/schema/tx" 
	   xmlns:aop="http://www.springframework.org/schema/aop"
	   xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
	   http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx.xsd 
	   http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop.xsd
      http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd"
	default-lazy-init="false">
	<!-- 多数据原配置 -->
	 <beans profile="manyDataSource">
	 	<!-- 数据源2 -->
	    <bean id="dataSourceTwo" class="com.alibaba.druid.pool.DruidDataSource" init-method="init" destroy-method="close">  
	        <property name="driverClassName" value="${dbTwo.jdbc.driverClass}" />  
	        <property name="url" value="${dbTwo.jdbc.url}" />  
	        <property name="username" value="${dbTwo.jdbc.user}" />  
	        <property name="password" value="${dbTwo.jdbc.password}" />  
	       	<property name="filters" value="${jdbc.filters}" />
			<property name="maxActive" value="${jdbc.maxActive}" />
			<property name="initialSize" value="${jdbc.initialSize}" />
			<property name="maxWait" value="${jdbc.maxWait}" />
			<property name="minIdle" value="${jdbc.minIdle}" />
			<property name="timeBetweenEvictionRunsMillis" value="${jdbc.timeBetweenEvictionRunsMillis}" />
			<property name="minEvictableIdleTimeMillis" value="${jdbc.minEvictableIdleTimeMillis}" />
			<property name="testWhileIdle" value="${jdbc.testWhileIdle}" />
			<property name="testOnBorrow" value="${jdbc.testOnBorrow}" />
			<property name="testOnReturn" value="${jdbc.testOnReturn}" />
			<property name="poolPreparedStatements" value="${jdbc.poolPreparedStatements}" />
			<property name="maxPoolPreparedStatementPerConnectionSize" value="${jdbc.maxPoolPreparedStatementPerConnectionSize}" />
	    </bean>  
	    
	  	<!-- 多数据源配置 -->
	    <bean id="manyDataSource" class="com.moudels.core.DynamicDataSource">  
	        <property name="targetDataSources">  
	        	<!-- 待切换数据源 -->
	            <map key-type="java.lang.String">  
	                <entry value-ref="dataSource" key="dataSource"></entry>  
					<entry value-ref="dataSourceTwo" key="dataSourceTwo"></entry>
	            </map>  
	        </property>  
	        <!-- 默认使用数据源 -->
	        <property name="defaultTargetDataSource" ref="dataSource">  
	        </property>  
	    </bean>  
	    <!--  -->
	  	<bean id="sessionFactory" class="com.hibernate.core.SessionFactoryBean">
	  		<!-- 动态数据源修改开始 -->
			<property name="dataSource" ref="manyDataSource" />  
			<!-- 动态数据源修改结束 -->
			<property name="namingStrategy">
				<bean class="org.hibernate.cfg.ImprovedNamingStrategy" />
			</property>
			<property name="hibernateProperties">
				<props>
					<prop key="hibernate.dialect">${hibernate.dialect}</prop>
					<prop key="hibernate.show_sql">${hibernate.show_sql}</prop>
					<prop key="hibernate.format_sql">${hibernate.format_sql}</prop>
					<prop key="hibernate.current_session_context_class">org.springframework.orm.hibernate4.SpringSessionContext</prop>
					<prop key="hibernate.hbm2ddl.auto">${hibernate.hbm2ddl.auto}</prop>
					<prop key="hibernate.cache.use_second_level_cache">true</prop>
					<prop key="hibernate.cache.use_query_cache">true</prop>
					<prop key="hibernate.cache.region.factory_class">org.hibernate.cache.ehcache.EhCacheRegionFactory</prop>
					<prop key="net.sf.ehcache.configurationResourceName">com/cl/frame/config/cache/ehcache-hibernate-local.xml</prop>
				</props>
			</property>
			<property name="packagesToScan" value="#{property.getArray('hibernate.packagesToScan.')}" />
		</bean>
	  
		<!-- dataSource 事物控制 -->
		<bean id="txManagerDataSource" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
			<property name="dataSource" ref="manyDataSource" />
		</bean>
		<bean id="jdbcBaseDAO" class="com.cl.frame.hibernate.persistence.JdbcBaseDAO">
			<property name="dataSource" ref="manyDataSource"></property>
		</bean>
	</beans>
</beans>

           

jdbc配置文件

jdbc.driverClassName=oracle.jdbc.driver.OracleDriver
jdbc.url=jdbc\:oracle\:thin\:@ip\:1521\:orcl
jdbc.username=out_work
jdbc.password=out_work
dbTwo.jdbc.driverClass=oracle.jdbc.driver.OracleDriver
dbTwo.jdbc.url=jdbc\:oracle\:thin\:@ip\:1521\:orcl
dbTwo.jdbc.user=oa
dbTwo.jdbc.password=oa
dbTwo.jdbc.initialPoolSize= 4
dbTwo.jdbc.minPoolSize =1
dbTwo.jdbc.maxPoolSize=4
#hibernate.show_sql=true
           

java文件

package com.cl.frame.clfbs.moudels.core;

public class DatabaseContextHolder {  
	  
    private static final ThreadLocal<String> contextHolder = new ThreadLocal<String>();  
  
    public static void setCustomerType(String customerType) {  
        contextHolder.set(customerType);  
    }  
  
    public static String getCustomerType() {  
        return contextHolder.get();  
    }  
  
    public static void clearCustomerType() {  
        contextHolder.remove();  
    }  
}  

           

package com.cl.frame.clfbs.moudels.core;

import org.aspectj.lang.JoinPoint;


public class DataSourceInterceptor {  
  
    public void setdataSourceOne(JoinPoint jp) {  
    	System.out.println("AreaOnSeriveImp==="+"DataSourceInterceptor");
    	//清除原数据源
    	DatabaseContextHolder.clearCustomerType();
    	//设置新数据源
        DatabaseContextHolder.setCustomerType("dataSource");  
    }  
      
    public void setdataSourceTwo(JoinPoint jp) {  
    	System.out.println("AreaTwoServiceImp==="+"DataSourceInterceptor");
    	DatabaseContextHolder.clearCustomerType();
        DatabaseContextHolder.setCustomerType("dataSourceTwo");  
    }  
}  
           

package com.cl.frame.clfbs.moudels.core;

import java.lang.reflect.Method;

import org.springframework.aop.AfterReturningAdvice;
import org.springframework.aop.MethodBeforeAdvice;

public class DataSourceAspect implements MethodBeforeAdvice,AfterReturningAdvice   
{  
  
    @Override  
    public void afterReturning(Object returnValue, Method method,  
            Object[] args, Object target) throws Throwable {  
        // TODO Auto-generated method stub  
        DatabaseContextHolder.clearCustomerType();  
    }

	@Override
	public void before(Method method, Object[] args, Object target)
			throws Throwable {
		
	}  
  
    
}  
           

package com.cl.frame.clfbs.moudels.core;
import org.springframework.jdbc.datasource.lookup.AbstractRoutingDataSource;
/**
 * 每次请求数据库都会访问该类，调用下面方法
 * @author lovem
 *
 */
public class DynamicDataSource extends AbstractRoutingDataSource{

	//
	protected Object determineCurrentLookupKey() {
		/*System.out.println(DatabaseContextHolder.getCustomerType()+"===DynamicDataSource");
		System.out.println("===========================");*/
		return DatabaseContextHolder.getCustomerType();
	}

}

           

注意：数据源切换只能在业务层或者控制层，不能再持久层做数据源的切换